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 |
---|---|
List<OrcProto.ColumnEncoding> |
OrcStripeMetadata.getEncodings() |
Modifier and Type | Method and Description |
---|---|
static TreeReaderFactory.TreeReader[] |
EncodedTreeReaderFactory.createEncodedTreeReader(int numCols,
List<OrcProto.Type> types,
List<OrcProto.ColumnEncoding> encodings,
EncodedColumnBatch<OrcBatchKey> batch,
CompressionCodec codec,
boolean skipCorrupt,
String writerTimezone) |
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.ColumnEncoding> |
OrcProto.ColumnEncoding.PARSER |
Modifier and Type | Method and Description |
---|---|
OrcProto.ColumnEncoding |
OrcProto.ColumnEncoding.Builder.build() |
OrcProto.ColumnEncoding |
OrcProto.ColumnEncoding.Builder.buildPartial() |
OrcProto.ColumnEncoding |
OrcProto.StripeFooterOrBuilder.getColumns(int index)
repeated .orc.proto.ColumnEncoding columns = 2; |
OrcProto.ColumnEncoding |
OrcProto.StripeFooter.getColumns(int index)
repeated .orc.proto.ColumnEncoding columns = 2; |
OrcProto.ColumnEncoding |
OrcProto.StripeFooter.Builder.getColumns(int index)
repeated .orc.proto.ColumnEncoding columns = 2; |
static OrcProto.ColumnEncoding |
OrcProto.ColumnEncoding.getDefaultInstance() |
OrcProto.ColumnEncoding |
OrcProto.ColumnEncoding.getDefaultInstanceForType() |
OrcProto.ColumnEncoding |
OrcProto.ColumnEncoding.Builder.getDefaultInstanceForType() |
static OrcProto.ColumnEncoding |
OrcProto.ColumnEncoding.parseDelimitedFrom(InputStream input) |
static OrcProto.ColumnEncoding |
OrcProto.ColumnEncoding.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static OrcProto.ColumnEncoding |
OrcProto.ColumnEncoding.parseFrom(byte[] data) |
static OrcProto.ColumnEncoding |
OrcProto.ColumnEncoding.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static OrcProto.ColumnEncoding |
OrcProto.ColumnEncoding.parseFrom(com.google.protobuf.ByteString data) |
static OrcProto.ColumnEncoding |
OrcProto.ColumnEncoding.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static OrcProto.ColumnEncoding |
OrcProto.ColumnEncoding.parseFrom(com.google.protobuf.CodedInputStream input) |
static OrcProto.ColumnEncoding |
OrcProto.ColumnEncoding.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static OrcProto.ColumnEncoding |
OrcProto.ColumnEncoding.parseFrom(InputStream input) |
static OrcProto.ColumnEncoding |
OrcProto.ColumnEncoding.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
List<OrcProto.ColumnEncoding> |
OrcProto.StripeFooterOrBuilder.getColumnsList()
repeated .orc.proto.ColumnEncoding columns = 2; |
List<OrcProto.ColumnEncoding> |
OrcProto.StripeFooter.getColumnsList()
repeated .orc.proto.ColumnEncoding columns = 2; |
List<OrcProto.ColumnEncoding> |
OrcProto.StripeFooter.Builder.getColumnsList()
repeated .orc.proto.ColumnEncoding columns = 2; |
com.google.protobuf.Parser<OrcProto.ColumnEncoding> |
OrcProto.ColumnEncoding.getParserForType() |
Modifier and Type | Method and Description |
---|---|
OrcProto.StripeFooter.Builder |
OrcProto.StripeFooter.Builder.addColumns(int index,
OrcProto.ColumnEncoding value)
repeated .orc.proto.ColumnEncoding columns = 2; |
OrcProto.StripeFooter.Builder |
OrcProto.StripeFooter.Builder.addColumns(OrcProto.ColumnEncoding value)
repeated .orc.proto.ColumnEncoding columns = 2; |
OrcProto.ColumnEncoding.Builder |
OrcProto.ColumnEncoding.Builder.mergeFrom(OrcProto.ColumnEncoding other) |
static OrcProto.ColumnEncoding.Builder |
OrcProto.ColumnEncoding.newBuilder(OrcProto.ColumnEncoding prototype) |
OrcProto.StripeFooter.Builder |
OrcProto.StripeFooter.Builder.setColumns(int index,
OrcProto.ColumnEncoding value)
repeated .orc.proto.ColumnEncoding columns = 2; |
Modifier and Type | Method and Description |
---|---|
OrcProto.StripeFooter.Builder |
OrcProto.StripeFooter.Builder.addAllColumns(Iterable<? extends OrcProto.ColumnEncoding> values)
repeated .orc.proto.ColumnEncoding columns = 2; |
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) |
static boolean |
RecordReaderUtils.isDictionary(OrcProto.Stream.Kind kind,
OrcProto.ColumnEncoding encoding)
Is this stream part of a dictionary?
|
Constructor and Description |
---|
BinaryTreeReader(int columnId,
InStream present,
InStream data,
InStream length,
OrcProto.ColumnEncoding encoding) |
CharTreeReader(int columnId,
int maxLength,
InStream present,
InStream data,
InStream length,
InStream dictionary,
OrcProto.ColumnEncoding encoding) |
DateTreeReader(int columnId,
InStream present,
InStream data,
OrcProto.ColumnEncoding encoding) |
DecimalTreeReader(int columnId,
int precision,
int scale,
InStream present,
InStream valueStream,
InStream scaleStream,
OrcProto.ColumnEncoding encoding) |
IntTreeReader(int columnId,
InStream present,
InStream data,
OrcProto.ColumnEncoding encoding) |
LongTreeReader(int columnId,
InStream present,
InStream data,
OrcProto.ColumnEncoding encoding,
boolean skipCorrupt) |
ShortTreeReader(int columnId,
InStream present,
InStream data,
OrcProto.ColumnEncoding encoding) |
StringDictionaryTreeReader(int columnId,
InStream present,
InStream data,
InStream length,
InStream dictionary,
OrcProto.ColumnEncoding encoding) |
StringTreeReader(int columnId,
InStream present,
InStream data,
InStream length,
InStream dictionary,
OrcProto.ColumnEncoding encoding) |
TimestampTreeReader(int columnId,
InStream presentStream,
InStream dataStream,
InStream nanosStream,
OrcProto.ColumnEncoding encoding,
boolean skipCorrupt,
String writerTimezone) |
VarcharTreeReader(int columnId,
int maxLength,
InStream present,
InStream data,
InStream length,
InStream dictionary,
OrcProto.ColumnEncoding encoding) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.