Uses of Class
org.apache.orc.impl.InStream
-
Uses of InStream in org.apache.orc.impl
Modifier and TypeClassDescriptionstatic class
static class
Implements a stream over an encrypted, but uncompressed stream.static class
Implements a stream over an uncompressed stream.Modifier and TypeFieldDescriptionprotected InStream
TreeReaderFactory.BinaryTreeReader.stream
protected InStream
TreeReaderFactory.DoubleTreeReader.stream
protected InStream
TreeReaderFactory.FloatTreeReader.stream
protected InStream
TreeReaderFactory.StringDirectTreeReader.stream
protected InStream
TreeReaderFactory.DecimalTreeReader.valueStream
Modifier and TypeMethodDescriptionstatic InStream
InStream.create
(Object name, org.apache.hadoop.hive.common.io.DiskRangeList input, long offset, long length) Create an input stream from a list of disk ranges with data.static InStream
InStream.create
(Object name, org.apache.hadoop.hive.common.io.DiskRangeList input, long offset, long length, InStream.StreamOptions options) Create an input stream from a list of disk ranges with data.TreeReaderFactory.StringDirectTreeReader.getStream()
Modifier and TypeMethodDescriptionlong
SerializationUtils.bytesToLongBE
(InStream input, int n) Read n bytes in big endian order and convert to longstatic com.google.protobuf.CodedInputStream
InStream.createCodedInputStream
(InStream inStream) Creates coded input stream (used for protobuf message parsing) with higher message size limit.protected static IntegerReader
TreeReaderFactory.TreeReader.createIntegerReader
(OrcProto.ColumnEncoding.Kind kind, InStream in, boolean signed, TreeReaderFactory.Context context) void
Read bitpacked integers from input streamstatic void
TreeReaderFactory.BytesColumnVectorUtil.readOrcByteArrays
(InStream stream, IntegerReader lengths, org.apache.hadoop.hive.ql.exec.vector.LongColumnVector scratchlcv, org.apache.hadoop.hive.ql.exec.vector.BytesColumnVector result, int batchSize) void
RunLengthByteReader.setInStream
(InStream input) ModifierConstructorDescriptionprotected
BinaryTreeReader
(int columnId, InStream present, InStream data, InStream length, OrcProto.ColumnEncoding encoding, TreeReaderFactory.Context context) BitFieldReader
(InStream input) protected
BooleanTreeReader
(int columnId, InStream present, InStream data, TreeReaderFactory.Context context) protected
ByteTreeReader
(int columnId, InStream present, InStream data, TreeReaderFactory.Context context) protected
CharTreeReader
(int columnId, int maxLength, InStream present, InStream data, InStream length, InStream dictionary, OrcProto.ColumnEncoding encoding, TreeReaderFactory.Context context) protected
DateTreeReader
(int columnId, InStream present, InStream data, OrcProto.ColumnEncoding encoding, TreeReaderFactory.Context context) protected
Decimal64TreeReader
(int columnId, InStream present, InStream valueStream, OrcProto.ColumnEncoding encoding, int precision, int scale, TreeReaderFactory.Context context) protected
DecimalTreeReader
(int columnId, InStream present, InStream valueStream, InStream scaleStream, OrcProto.ColumnEncoding encoding, int precision, int scale, TreeReaderFactory.Context context) protected
DoubleTreeReader
(int columnId, InStream present, InStream data, TreeReaderFactory.Context context) protected
FloatTreeReader
(int columnId, InStream present, InStream data, TreeReaderFactory.Context context) protected
IntTreeReader
(int columnId, InStream present, InStream data, OrcProto.ColumnEncoding encoding, TreeReaderFactory.Context context) protected
ListTreeReader
(int columnId, InStream present, TreeReaderFactory.Context context, InStream data, OrcProto.ColumnEncoding encoding, TypeReader elementReader) protected
LongTreeReader
(int columnId, InStream present, InStream data, OrcProto.ColumnEncoding encoding, TreeReaderFactory.Context context) protected
MapTreeReader
(int columnId, InStream present, TreeReaderFactory.Context context, InStream data, OrcProto.ColumnEncoding encoding, TypeReader keyReader, TypeReader valueReader) RunLengthByteReader
(InStream input) RunLengthIntegerReader
(InStream input, boolean signed) RunLengthIntegerReaderV2
(InStream input, boolean signed, boolean skipCorrupt) protected
ShortTreeReader
(int columnId, InStream present, InStream data, OrcProto.ColumnEncoding encoding, TreeReaderFactory.Context context) protected
StringDictionaryTreeReader
(int columnId, InStream present, InStream data, InStream length, InStream dictionary, OrcProto.ColumnEncoding encoding, TreeReaderFactory.Context context) protected
StringDirectTreeReader
(int columnId, InStream present, InStream data, InStream length, OrcProto.ColumnEncoding.Kind encoding, TreeReaderFactory.Context context) protected
StringTreeReader
(int columnId, InStream present, InStream data, InStream length, InStream dictionary, OrcProto.ColumnEncoding encoding, TreeReaderFactory.Context context) protected
StructTreeReader
(int columnId, InStream present, TreeReaderFactory.Context context, OrcProto.ColumnEncoding encoding, TypeReader[] childReaders) protected
TimestampTreeReader
(int columnId, InStream presentStream, InStream dataStream, InStream nanosStream, OrcProto.ColumnEncoding encoding, TreeReaderFactory.Context context, boolean instantType) protected
TreeReader
(int columnId, InStream in, @NotNull TreeReaderFactory.Context context) protected
UnionTreeReader
(int columnId, InStream present, TreeReaderFactory.Context context, OrcProto.ColumnEncoding encoding, TypeReader[] childReaders) protected
VarcharTreeReader
(int columnId, int maxLength, InStream present, InStream data, InStream length, InStream dictionary, OrcProto.ColumnEncoding encoding, TreeReaderFactory.Context context) -
Uses of InStream in org.apache.orc.impl.reader
Modifier and TypeMethodDescriptionStripePlanner.getStream
(StreamName name) Get the stream for the given name.