com.splicemachine.orc.reader

Class LongDictionaryStreamReader

java.lang.Object

com.splicemachine.orc.reader.AbstractStreamReader

com.splicemachine.orc.reader.LongDictionaryStreamReader

All Implemented Interfaces:

StreamReader

public class LongDictionaryStreamReader
extends AbstractStreamReader

Field Summary

Fields inherited from class com.splicemachine.orc.reader.AbstractStreamReader

nextBatchSize, readOffset

Constructor Summary

Constructors

Constructor and Description
LongDictionaryStreamReader(StreamDescriptor streamDescriptor)

Method Summary

Modifier and Type	Method and Description
void	prepareNextRead(int batchSize)
org.apache.spark.sql.execution.vectorized.ColumnVector	readBlock(org.apache.spark.sql.types.DataType type, org.apache.spark.sql.execution.vectorized.ColumnVector vector)
void	startRowGroup(StreamSources dataStreamSources)
void	startStripe(StreamSources dictionaryStreamSources, java.util.List<ColumnEncoding> encoding)
java.lang.String	toString()

Methods inherited from class com.splicemachine.orc.reader.AbstractStreamReader

getBatchSize, readBlock

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

LongDictionaryStreamReader

public LongDictionaryStreamReader(StreamDescriptor streamDescriptor)

Method Detail

prepareNextRead

public void prepareNextRead(int batchSize)

readBlock

public org.apache.spark.sql.execution.vectorized.ColumnVector readBlock(org.apache.spark.sql.types.DataType type,
                                                                        org.apache.spark.sql.execution.vectorized.ColumnVector vector)
                                                                 throws java.io.IOException

Throws:

java.io.IOException

startStripe

public void startStripe(StreamSources dictionaryStreamSources,
                        java.util.List<ColumnEncoding> encoding)
                 throws java.io.IOException

Throws:

java.io.IOException

startRowGroup

public void startRowGroup(StreamSources dataStreamSources)
                   throws java.io.IOException

Throws:

java.io.IOException

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object