org.apache.flink.connectors.hive.read

Interface SplitReader

All Superinterfaces:

AutoCloseable, Closeable

All Known Implementing Classes:

HiveMapredSplitReader, HiveVectorizedOrcSplitReader, HiveVectorizedParquetSplitReader

public interface SplitReader
extends Closeable

Split reader to read record from files. The reader is only responsible for reading the data of a single split.

Method Summary

Modifier and Type	Method and Description
org.apache.flink.table.data.RowData	nextRecord(org.apache.flink.table.data.RowData reuse) Reads the next record from the input.
boolean	reachedEnd() Method used to check if the end of the input is reached.
default void	seekToRow(long rowCount, org.apache.flink.table.data.RowData reuse) Seek to a particular row number.

Methods inherited from interface java.io.Closeable

close

Method Detail

reachedEnd

boolean reachedEnd()
            throws IOException

Method used to check if the end of the input is reached.

Returns:

True if the end is reached, otherwise false.

Throws:

IOException - Thrown, if an I/O error occurred.

nextRecord

org.apache.flink.table.data.RowData nextRecord(org.apache.flink.table.data.RowData reuse)
                                        throws IOException

Reads the next record from the input.

Parameters:

reuse - Object that may be reused.

Returns:

Read record.

Throws:

IOException - Thrown, if an I/O error occurred.

seekToRow

default void seekToRow(long rowCount,
                       org.apache.flink.table.data.RowData reuse)
                throws IOException

Seek to a particular row number.

Throws:

IOException