public class OrcEncodedDataConsumer extends EncodedDataConsumer<OrcBatchKey,Reader.OrcEncodedColumnBatch>
cvbPool
Constructor and Description |
---|
OrcEncodedDataConsumer(Consumer<ColumnVectorBatch> consumer,
ColumnVectorProducer.Includes includes,
boolean skipCorrupt,
QueryFragmentCounters counters,
LlapDaemonIOMetrics ioMetrics) |
Modifier and Type | Method and Description |
---|---|
protected void |
decodeBatch(Reader.OrcEncodedColumnBatch batch,
Consumer<ColumnVectorBatch> downstreamConsumer) |
org.apache.orc.impl.SchemaEvolution |
getSchemaEvolution() |
void |
init(ConsumerFeedback<Reader.OrcEncodedColumnBatch> upstreamFeedback,
Callable<Void> readCallable,
IoTrace trace) |
void |
setFileMetadata(ConsumerFileMetadata f) |
void |
setSchemaEvolution(org.apache.orc.impl.SchemaEvolution evolution) |
void |
setStripeMetadata(ConsumerStripeMetadata m) |
void |
setUseDecimal64ColumnVectors(boolean useDecimal64ColumnVectors) |
consumeData, getReadCallable, init, pause, returnData, setDone, setError, stop, unpause
public OrcEncodedDataConsumer(Consumer<ColumnVectorBatch> consumer, ColumnVectorProducer.Includes includes, boolean skipCorrupt, QueryFragmentCounters counters, LlapDaemonIOMetrics ioMetrics)
public void setUseDecimal64ColumnVectors(boolean useDecimal64ColumnVectors)
public void setFileMetadata(ConsumerFileMetadata f)
public void setStripeMetadata(ConsumerStripeMetadata m)
protected void decodeBatch(Reader.OrcEncodedColumnBatch batch, Consumer<ColumnVectorBatch> downstreamConsumer) throws InterruptedException
decodeBatch
in class EncodedDataConsumer<OrcBatchKey,Reader.OrcEncodedColumnBatch>
InterruptedException
public void setSchemaEvolution(org.apache.orc.impl.SchemaEvolution evolution)
public org.apache.orc.impl.SchemaEvolution getSchemaEvolution()
public void init(ConsumerFeedback<Reader.OrcEncodedColumnBatch> upstreamFeedback, Callable<Void> readCallable, IoTrace trace)
Copyright © 2022 The Apache Software Foundation. All rights reserved.