ParquetDataColumnReader (Flink : 1.20-SNAPSHOT API)

All Known Implementing Classes:

ParquetDataColumnReaderFactory.DefaultParquetDataColumnReader, ParquetDataColumnReaderFactory.TypesFromInt96PageReader
```
public interface ParquetDataColumnReader
```
The interface to wrap the underlying Parquet dictionary and non dictionary encoded page reader.

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method and Description
`org.apache.parquet.column.Dictionary`	`getDictionary()`
`void`	`initFromPage(int valueCount, org.apache.parquet.bytes.ByteBufferInputStream in)` Initialize the reader by page data.
`boolean`	`readBoolean()`
`boolean`	`readBoolean(int id)`
`byte[]`	`readBytes()`
`byte[]`	`readBytes(int id)`
`double`	`readDouble()`
`double`	`readDouble(int id)`
`float`	`readFloat()`
`float`	`readFloat(int id)`
`int`	`readInteger()`
`int`	`readInteger(int id)`
`long`	`readLong()`
`long`	`readLong(int id)`
`int`	`readSmallInt()`
`int`	`readSmallInt(int id)`
`TimestampData`	`readTimestamp()`
`TimestampData`	`readTimestamp(int id)`
`int`	`readTinyInt()`
`int`	`readTinyInt(int id)`
`int`	`readValueDictionaryId()`

- Method Detail
  - initFromPage
```
void initFromPage(int valueCount,
                  org.apache.parquet.bytes.ByteBufferInputStream in)
           throws IOException
```
    Initialize the reader by page data.
    
    Parameters:
    
    valueCount - value count
    
    in - page data
    
    Throws:
    
    IOException
  - readValueDictionaryId
```
int readValueDictionaryId()
```
    Returns:
    
    the next Dictionary ID from the page
  - readBoolean
```
boolean readBoolean()
```
    Returns:
    
    the next Boolean from the page
  - readTinyInt
```
int readTinyInt()
```
    Returns:
    
    the next TinyInt from the page
  - readSmallInt
```
int readSmallInt()
```
    Returns:
    
    the next SmallInt from the page
  - readInteger
```
int readInteger()
```
    Returns:
    
    the next Integer from the page
  - readLong
```
long readLong()
```
    Returns:
    
    the next Long from the page
  - readFloat
```
float readFloat()
```
    Returns:
    
    the next Float from the page
  - readDouble
```
double readDouble()
```
    Returns:
    
    the next Double from the page
  - readBytes
```
byte[] readBytes()
```
    Returns:
    
    the next Bytes from the page
  - readTimestamp
```
TimestampData readTimestamp()
```
    Returns:
    
    the next TimestampData from the page
  - getDictionary
```
org.apache.parquet.column.Dictionary getDictionary()
```
    Returns:
    
    the underlying dictionary if current reader is dictionary encoded
  - readBoolean
```
boolean readBoolean(int id)
```
    Parameters:
    
    id - in dictionary
    
    Returns:
    
    the Boolean from the dictionary by id
  - readTinyInt
```
int readTinyInt(int id)
```
    Parameters:
    
    id - in dictionary
    
    Returns:
    
    the tiny int from the dictionary by id
  - readSmallInt
```
int readSmallInt(int id)
```
    Parameters:
    
    id - in dictionary
    
    Returns:
    
    the Small Int from the dictionary by id
  - readInteger
```
int readInteger(int id)
```
    Parameters:
    
    id - in dictionary
    
    Returns:
    
    the Integer from the dictionary by id
  - readLong
```
long readLong(int id)
```
    Parameters:
    
    id - in dictionary
    
    Returns:
    
    the Long from the dictionary by id
  - readFloat
```
float readFloat(int id)
```
    Parameters:
    
    id - in dictionary
    
    Returns:
    
    the Float from the dictionary by id
  - readDouble
```
double readDouble(int id)
```
    Parameters:
    
    id - in dictionary
    
    Returns:
    
    the Double from the dictionary by id
  - readBytes
```
byte[] readBytes(int id)
```
    Parameters:
    
    id - in dictionary
    
    Returns:
    
    the Bytes from the dictionary by id
  - readTimestamp
```
TimestampData readTimestamp(int id)
```
    Parameters:
    
    id - in dictionary
    
    Returns:
    
    the TimestampData from the dictionary by id

Back to Flink Website

Interface ParquetDataColumnReader

Method Summary

Method Detail

initFromPage

readValueDictionaryId

readBoolean

readTinyInt

readSmallInt

readInteger

readLong

readFloat

readDouble

readBytes

readTimestamp

getDictionary

readBoolean

readTinyInt

readSmallInt

readInteger

readLong

readFloat

readDouble

readBytes

readTimestamp

Back to Flink Website