Package | Description |
---|---|
org.apache.orc.impl |
Modifier and Type | Class and Description |
---|---|
static class |
InStream.UncompressedStream |
class |
SettableUncompressedStream
An uncompressed stream whose underlying byte buffer can be set.
|
Modifier and Type | Field and Description |
---|---|
protected InStream |
TreeReaderFactory.FloatTreeReader.stream |
protected InStream |
TreeReaderFactory.DoubleTreeReader.stream |
protected InStream |
TreeReaderFactory.BinaryTreeReader.stream |
protected InStream |
TreeReaderFactory.StringDirectTreeReader.stream |
protected InStream |
TreeReaderFactory.DecimalTreeReader.valueStream |
Modifier and Type | Method and Description |
---|---|
static InStream |
InStream.create(String streamName,
ByteBuffer[] buffers,
long[] offsets,
long length,
CompressionCodec codec,
int bufferSize)
Deprecated.
|
static InStream |
InStream.create(String name,
List<DiskRange> input,
long length,
CompressionCodec codec,
int bufferSize)
Create an input stream from a list of disk ranges with data.
|
InStream |
TreeReaderFactory.StringDirectTreeReader.getStream() |
Modifier and Type | Method and Description |
---|---|
long |
SerializationUtils.bytesToLongBE(InStream input,
int n)
Read n bytes in big endian order and convert to long
|
void |
SerializationUtils.readInts(long[] buffer,
int offset,
int len,
int bitSize,
InStream input)
Read bitpacked integers from input stream
|
static void |
TreeReaderFactory.BytesColumnVectorUtil.readOrcByteArrays(InStream stream,
IntegerReader lengths,
LongColumnVector scratchlcv,
BytesColumnVector result,
int batchSize) |
void |
RunLengthByteReader.setInStream(InStream input) |
void |
BitFieldReader.setInStream(InStream inStream) |
Modifier and Type | Method and Description |
---|---|
void |
TreeReaderFactory.NullTreeReader.startStripe(Map<StreamName,InStream> streams,
OrcProto.StripeFooter footer) |
Constructor and Description |
---|
BinaryTreeReader(int columnId,
InStream present,
InStream data,
InStream length,
OrcProto.ColumnEncoding encoding) |
BitFieldReader(InStream input,
int bitSize) |
BooleanTreeReader(int columnId,
InStream present,
InStream data) |
ByteTreeReader(int columnId,
InStream present,
InStream data) |
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) |
DoubleTreeReader(int columnId,
InStream present,
InStream data) |
FloatTreeReader(int columnId,
InStream present,
InStream data) |
IntTreeReader(int columnId,
InStream present,
InStream data,
OrcProto.ColumnEncoding encoding) |
LongTreeReader(int columnId,
InStream present,
InStream data,
OrcProto.ColumnEncoding encoding,
boolean skipCorrupt) |
RunLengthByteReader(InStream input) |
RunLengthIntegerReader(InStream input,
boolean signed) |
RunLengthIntegerReaderV2(InStream input,
boolean signed,
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) |
StringDirectTreeReader(int columnId,
InStream present,
InStream data,
InStream length,
OrcProto.ColumnEncoding.Kind 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) |
TreeReader(int columnId,
InStream in) |
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.