org.apache.flink.connectors.hive.read

类 HiveMapredSplitReader

java.lang.Object

org.apache.flink.connectors.hive.read.HiveMapredSplitReader

所有已实现的接口:

Closeable, AutoCloseable, SplitReader

public class HiveMapredSplitReader
extends Object
implements SplitReader

Hive SplitReader to read files using hadoop mapred RecordReader.

字段概要

字段

限定符和类型	字段和说明
protected org.apache.hadoop.io.Writable	key
protected org.apache.hadoop.io.Writable	value

构造器概要

构造器

构造器和说明
HiveMapredSplitReader(org.apache.hadoop.mapred.JobConf jobConf, List<String> partitionKeys, org.apache.flink.table.types.DataType[] fieldTypes, int[] selectedFields, HiveTableInputSplit split, HiveShim hiveShim)

方法概要

限定符和类型	方法和说明
void	close()
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.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

key

protected org.apache.hadoop.io.Writable key

value

protected org.apache.hadoop.io.Writable value

构造器详细资料

HiveMapredSplitReader

public HiveMapredSplitReader(org.apache.hadoop.mapred.JobConf jobConf,
                             List<String> partitionKeys,
                             org.apache.flink.table.types.DataType[] fieldTypes,
                             int[] selectedFields,
                             HiveTableInputSplit split,
                             HiveShim hiveShim)
                      throws IOException

抛出:

IOException

方法详细资料

reachedEnd

public boolean reachedEnd()
                   throws IOException

从接口复制的说明: SplitReader

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

指定者:

reachedEnd 在接口中 SplitReader

返回:

True if the end is reached, otherwise false.

抛出:

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

nextRecord

public org.apache.flink.table.dataformat.BaseRow nextRecord(org.apache.flink.table.dataformat.BaseRow reuse)
                                                     throws IOException

从接口复制的说明: SplitReader

Reads the next record from the input.

指定者:

nextRecord 在接口中 SplitReader

参数:

reuse - Object that may be reused.

返回:

Read record.

抛出:

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

close

public void close()
           throws IOException

指定者:

close 在接口中 Closeable

指定者:

close 在接口中 AutoCloseable

抛出:

IOException