public interface EncodedReader
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes the reader.
|
void |
readEncodedColumns(int stripeIx,
StripeInformation stripe,
OrcProto.RowIndex[] index,
List<OrcProto.ColumnEncoding> encodings,
List<OrcProto.Stream> streams,
boolean[] included,
boolean[][] colRgs,
Consumer<Reader.OrcEncodedColumnBatch> consumer)
Reads encoded data from ORC file.
|
void |
setTracing(boolean isEnabled)
Controls the low-level debug tracing.
|
void readEncodedColumns(int stripeIx, StripeInformation stripe, OrcProto.RowIndex[] index, List<OrcProto.ColumnEncoding> encodings, List<OrcProto.Stream> streams, boolean[] included, boolean[][] colRgs, Consumer<Reader.OrcEncodedColumnBatch> consumer) throws IOException
stripeIx
- Index of the stripe to read.stripe
- Externally provided metadata (from metadata reader or external cache).index
- Externally provided metadata (from metadata reader or external cache).encodings
- Externally provided metadata (from metadata reader or external cache).streams
- Externally provided metadata (from metadata reader or external cache).included
- The array of booleans indicating whether each column should be read.colRgs
- Arrays of rgs, per column set to true in included, that are to be read.
null in each respective position means all rgs for this column need to be read.consumer
- The sink for data that has been read.IOException
void close() throws IOException
IOException
void setTracing(boolean isEnabled)
Copyright © 2016 The Apache Software Foundation. All rights reserved.