org.apache.hadoop.hive.ql.io.orc.encoded

Interface Consumer<T>

All Known Implementing Classes:

EncodedDataConsumer, OrcEncodedDataConsumer

public interface Consumer<T>

Data consumer; an equivalent of a data queue for an asynchronous data producer.

Method Summary

Modifier and Type	Method and Description
void	consumeData(T data) Some data has been produced.
void	setDone() No more data will be produced; done.
void	setError(Throwable t) No more data will be produced; error during production.

Method Detail

consumeData

void consumeData(T data)
          throws InterruptedException

Some data has been produced.

Throws:

InterruptedException

setDone

void setDone()
      throws InterruptedException

No more data will be produced; done.

Throws:

InterruptedException

setError

void setError(Throwable t)
       throws InterruptedException

No more data will be produced; error during production.

Throws:

InterruptedException