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
|
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 |
---|---|
void |
TreeReaderFactory.NullTreeReader.startStripe(Map<StreamName,InStream> streams,
OrcProto.StripeFooter footer) |
Copyright © 2013–2018 The Apache Software Foundation. All rights reserved.