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) |
TypeDescription |
getFileSchema() |
boolean[] |
getIncludedColumns() |
void |
setFileMetadata(OrcFileMetadata f) |
void |
setIncludedColumns(boolean[] includedColumns) |
void |
setStripeMetadata(OrcStripeMetadata 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(OrcFileMetadata f)
public void setStripeMetadata(OrcStripeMetadata m)
protected void decodeBatch(Reader.OrcEncodedColumnBatch batch, Consumer<ColumnVectorBatch> downstreamConsumer)
decodeBatch
in class EncodedDataConsumer<OrcBatchKey,Reader.OrcEncodedColumnBatch>
public TypeDescription getFileSchema()
public boolean[] getIncludedColumns()
public void setIncludedColumns(boolean[] includedColumns)
Copyright © 2016 The Apache Software Foundation. All rights reserved.