org.apache.flink.connectors.hive.read

接口 SplitReader

所有超级接口:

AutoCloseable, Closeable

所有已知实现类:

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.

方法概要

限定符和类型	方法和说明
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.

从接口继承的方法 java.io.Closeable

close

方法详细资料

reachedEnd

boolean reachedEnd()
            throws IOException

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

返回:

True if the end is reached, otherwise false.

抛出:

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.

参数:

reuse - Object that may be reused.

返回:

Read record.

抛出:

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.

抛出:

IOException