Class PlainValuesReader
- java.lang.Object
-
- org.apache.parquet.column.values.ValuesReader
-
- org.apache.parquet.column.values.plain.PlainValuesReader
-
- Direct Known Subclasses:
PlainValuesReader.DoublePlainValuesReader
,PlainValuesReader.FloatPlainValuesReader
,PlainValuesReader.IntegerPlainValuesReader
,PlainValuesReader.LongPlainValuesReader
public abstract class PlainValuesReader extends ValuesReader
Plain encoding for float, double, int, long
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
PlainValuesReader.DoublePlainValuesReader
static class
PlainValuesReader.FloatPlainValuesReader
static class
PlainValuesReader.IntegerPlainValuesReader
static class
PlainValuesReader.LongPlainValuesReader
-
Field Summary
Fields Modifier and Type Field Description protected org.apache.parquet.bytes.LittleEndianDataInputStream
in
-
Constructor Summary
Constructors Constructor Description PlainValuesReader()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
initFromPage(int valueCount, org.apache.parquet.bytes.ByteBufferInputStream stream)
Called to initialize the column reader from a part of a page.void
skip()
Skips the next value in the page-
Methods inherited from class org.apache.parquet.column.values.ValuesReader
getNextOffset, initFromPage, initFromPage, readBoolean, readBytes, readDouble, readFloat, readInteger, readLong, readValueDictionaryId, skip, updateNextOffset
-
-
-
-
Method Detail
-
initFromPage
public void initFromPage(int valueCount, org.apache.parquet.bytes.ByteBufferInputStream stream) throws IOException
Description copied from class:ValuesReader
Called to initialize the column reader from a part of a page. Implementations must consume all bytes from the input stream, leaving the stream ready to read the next section of data. The underlying implementation knows how much data to read, so a length is not provided. Each page may contain several sections:- repetition levels column
- definition levels column
- data column
- Overrides:
initFromPage
in classValuesReader
- Parameters:
valueCount
- count of values in this pagestream
- an input stream containing the page data at the correct offset- Throws:
IOException
- if there is an exception while reading from the input stream
-
skip
public void skip()
Description copied from class:ValuesReader
Skips the next value in the page- Specified by:
skip
in classValuesReader
-
-