org.apache.flink.connectors.hive.read

Class HiveVectorizedOrcSplitReader

java.lang.Object

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

All Implemented Interfaces:

Closeable, AutoCloseable, SplitReader

public class HiveVectorizedOrcSplitReader
extends Object
implements SplitReader

Orc SplitReader to read files using OrcColumnarRowSplitReader.

Constructor Summary

Constructors

Constructor and Description
HiveVectorizedOrcSplitReader(String hiveVersion, org.apache.hadoop.mapred.JobConf jobConf, String[] fieldNames, org.apache.flink.table.types.DataType[] fieldTypes, int[] selectedFields, HiveTableInputSplit split)

Method Summary

Modifier and Type	Method and Description
void	close()
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.
void	seekToRow(long rowCount, org.apache.flink.table.data.RowData reuse) Seek to a particular row number.

Methods inherited from class java.lang.Object

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

Constructor Detail

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

Throws:

IOException

Method Detail

seekToRow

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

Description copied from interface: SplitReader

Seek to a particular row number.

Specified by:

seekToRow in interface SplitReader

Throws:

IOException

reachedEnd

public boolean reachedEnd()
                   throws IOException

Description copied from interface: SplitReader

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

Specified by:

reachedEnd in interface SplitReader

Returns:

True if the end is reached, otherwise false.

Throws:

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

nextRecord

public org.apache.flink.table.data.RowData nextRecord(org.apache.flink.table.data.RowData reuse)

Description copied from interface: SplitReader

Reads the next record from the input.

Specified by:

nextRecord in interface SplitReader

Parameters:

reuse - Object that may be reused.

Returns:

Read record.

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException