org.apache.flink.connectors.hive.read

接口 SplitReader

所有超级接口:

AutoCloseable, Closeable

所有已知实现类:

HiveMapredSplitReader, HiveVectorizedOrcSplitReader

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.dataformat.BaseRow	nextRecord(org.apache.flink.table.dataformat.BaseRow reuse) Reads the next record from the input.
boolean	reachedEnd() Method used to check if the end of the input is reached.

从接口继承的方法 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.dataformat.BaseRow nextRecord(org.apache.flink.table.dataformat.BaseRow 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.