Package | Description |
---|---|
org.apache.orc.impl | |
org.apache.orc.impl.reader |
Modifier and Type | Class and Description |
---|---|
static class |
InStream.CompressedStream |
static class |
InStream.EncryptedStream
Implements a stream over an encrypted, but uncompressed stream.
|
static class |
InStream.UncompressedStream
Implements a stream over an uncompressed stream.
|
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(Object name,
DiskRangeList input,
long offset,
long length)
Create an input stream from a list of disk ranges with data.
|
static InStream |
InStream.create(Object name,
DiskRangeList input,
long offset,
long length,
InStream.StreamOptions options)
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
|
static 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 |
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) |
Modifier and Type | Method and Description |
---|---|
InStream |
StripePlanner.getStream(StreamName name)
Get the stream for the given name.
|
Copyright © 2013–2023 The Apache Software Foundation. All rights reserved.