Package | Description |
---|---|
org.apache.hadoop.hive.llap.io.metadata | |
org.apache.hadoop.hive.ql.io.orc.encoded | |
org.apache.orc | |
org.apache.orc.impl |
Modifier and Type | Method and Description |
---|---|
OrcProto.RowIndex[] |
OrcStripeMetadata.getRowIndexes() |
Modifier and Type | Method and Description |
---|---|
void |
EncodedReader.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.
|
Modifier and Type | Field and Description |
---|---|
static com.google.protobuf.Parser<OrcProto.RowIndex> |
OrcProto.RowIndex.PARSER |
Modifier and Type | Method and Description |
---|---|
OrcProto.RowIndex |
OrcProto.RowIndex.Builder.build() |
OrcProto.RowIndex |
OrcProto.RowIndex.Builder.buildPartial() |
static OrcProto.RowIndex |
OrcProto.RowIndex.getDefaultInstance() |
OrcProto.RowIndex |
OrcProto.RowIndex.getDefaultInstanceForType() |
OrcProto.RowIndex |
OrcProto.RowIndex.Builder.getDefaultInstanceForType() |
static OrcProto.RowIndex |
OrcProto.RowIndex.parseDelimitedFrom(InputStream input) |
static OrcProto.RowIndex |
OrcProto.RowIndex.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static OrcProto.RowIndex |
OrcProto.RowIndex.parseFrom(byte[] data) |
static OrcProto.RowIndex |
OrcProto.RowIndex.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static OrcProto.RowIndex |
OrcProto.RowIndex.parseFrom(com.google.protobuf.ByteString data) |
static OrcProto.RowIndex |
OrcProto.RowIndex.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static OrcProto.RowIndex |
OrcProto.RowIndex.parseFrom(com.google.protobuf.CodedInputStream input) |
static OrcProto.RowIndex |
OrcProto.RowIndex.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static OrcProto.RowIndex |
OrcProto.RowIndex.parseFrom(InputStream input) |
static OrcProto.RowIndex |
OrcProto.RowIndex.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
com.google.protobuf.Parser<OrcProto.RowIndex> |
OrcProto.RowIndex.getParserForType() |
Modifier and Type | Method and Description |
---|---|
OrcProto.RowIndex.Builder |
OrcProto.RowIndex.Builder.mergeFrom(OrcProto.RowIndex other) |
static OrcProto.RowIndex.Builder |
OrcProto.RowIndex.newBuilder(OrcProto.RowIndex prototype) |
OrcIndex |
DataReader.readRowIndex(StripeInformation stripe,
OrcProto.StripeFooter footer,
boolean[] included,
OrcProto.RowIndex[] indexes,
boolean[] sargColumns,
OrcProto.BloomFilterIndex[] bloomFilterIndices) |
Modifier and Type | Method and Description |
---|---|
OrcProto.RowIndex[] |
OrcIndex.getRowGroupIndex() |
Modifier and Type | Method and Description |
---|---|
static void |
RecordReaderUtils.addRgFilteredStreamToRanges(OrcProto.Stream stream,
boolean[] includedRowGroups,
boolean isCompressed,
OrcProto.RowIndex index,
OrcProto.ColumnEncoding encoding,
OrcProto.Type type,
int compressionSize,
boolean hasNull,
long offset,
long length,
DiskRangeList.CreateHelper list,
boolean doMergeBuffers) |
boolean[] |
RecordReaderImpl.SargApplier.pickRowGroups(StripeInformation stripe,
OrcProto.RowIndex[] indexes,
OrcProto.BloomFilterIndex[] bloomFilterIndices,
boolean returnNone)
Pick the row groups that we need to load from the current stripe.
|
OrcIndex |
RecordReaderImpl.readRowIndex(int stripeIndex,
boolean[] included,
OrcProto.RowIndex[] indexes,
OrcProto.BloomFilterIndex[] bloomFilterIndex,
boolean[] sargColumns) |
void |
OrcIndex.setRowGroupIndex(OrcProto.RowIndex[] rowGroupIndex) |
Constructor and Description |
---|
OrcIndex(OrcProto.RowIndex[] rgIndex,
OrcProto.BloomFilterIndex[] bfIndex) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.