public class OrcEncodedDataConsumer extends EncodedDataConsumer<OrcBatchKey,Reader.OrcEncodedColumnBatch>
cvbPool
Constructor and Description |
---|
OrcEncodedDataConsumer(Consumer<ColumnVectorBatch> consumer,
int colCount,
boolean skipCorrupt,
QueryFragmentCounters counters,
LlapDaemonIOMetrics ioMetrics) |
Modifier and Type | Method and Description |
---|---|
protected void |
decodeBatch(Reader.OrcEncodedColumnBatch batch,
Consumer<ColumnVectorBatch> downstreamConsumer) |
boolean[] |
getIncludedColumns() |
org.apache.orc.impl.SchemaEvolution |
getSchemaEvolution() |
void |
setFileMetadata(ConsumerFileMetadata f) |
void |
setIncludedColumns(boolean[] includedColumns) |
void |
setSchemaEvolution(org.apache.orc.impl.SchemaEvolution evolution) |
void |
setStripeMetadata(ConsumerStripeMetadata m) |
consumeData, getReadCallable, init, pause, returnData, setDone, setError, stop, unpause
public OrcEncodedDataConsumer(Consumer<ColumnVectorBatch> consumer, int colCount, boolean skipCorrupt, QueryFragmentCounters counters, LlapDaemonIOMetrics ioMetrics)
public void setFileMetadata(ConsumerFileMetadata f)
public void setStripeMetadata(ConsumerStripeMetadata m)
protected void decodeBatch(Reader.OrcEncodedColumnBatch batch, Consumer<ColumnVectorBatch> downstreamConsumer)
decodeBatch
in class EncodedDataConsumer<OrcBatchKey,Reader.OrcEncodedColumnBatch>
public boolean[] getIncludedColumns()
public void setIncludedColumns(boolean[] includedColumns)
public void setSchemaEvolution(org.apache.orc.impl.SchemaEvolution evolution)
public org.apache.orc.impl.SchemaEvolution getSchemaEvolution()
Copyright © 2021 The Apache Software Foundation. All rights reserved.