org.apache.flink.connectors.hive.read

类 HiveVectorizedOrcSplitReader

java.lang.Object

org.apache.flink.connectors.hive.read.HiveVectorizedOrcSplitReader

所有已实现的接口:

Closeable, AutoCloseable, SplitReader

public class HiveVectorizedOrcSplitReader
extends Object
implements SplitReader

Orc SplitReader to read files using OrcColumnarRowSplitReader.

构造器概要

构造器

构造器和说明
HiveVectorizedOrcSplitReader(String hiveVersion, org.apache.hadoop.mapred.JobConf jobConf, String[] fieldNames, org.apache.flink.table.types.DataType[] fieldTypes, int[] selectedFields, HiveTableInputSplit split)

方法概要

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

构造器详细资料

HiveVectorizedOrcSplitReader

public HiveVectorizedOrcSplitReader(String hiveVersion,
                                    org.apache.hadoop.mapred.JobConf jobConf,
                                    String[] fieldNames,
                                    org.apache.flink.table.types.DataType[] fieldTypes,
                                    int[] selectedFields,
                                    HiveTableInputSplit split)
                             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)

从接口复制的说明: SplitReader

Reads the next record from the input.

指定者:

nextRecord 在接口中 SplitReader

参数:

reuse - Object that may be reused.

返回:

Read record.

close

public void close()
           throws IOException

指定者:

close 在接口中 Closeable

指定者:

close 在接口中 AutoCloseable

抛出:

IOException