org.apache.flink.connectors.hive.read

Class HiveInputFormatPartitionReader

java.lang.Object

org.apache.flink.connectors.hive.read.HiveInputFormatPartitionReader

All Implemented Interfaces:

Closeable, Serializable, AutoCloseable, org.apache.flink.table.filesystem.PartitionReader<HiveTablePartition,org.apache.flink.table.data.RowData>

public class HiveInputFormatPartitionReader
extends Object
implements org.apache.flink.table.filesystem.PartitionReader<HiveTablePartition,org.apache.flink.table.data.RowData>

Partition reader that read records from InputFormat using given partitions.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.flink.table.catalog.ObjectPath	tablePath

Constructor Summary

Constructors

Constructor and Description
HiveInputFormatPartitionReader(org.apache.hadoop.mapred.JobConf jobConf, String hiveVersion, org.apache.flink.table.catalog.ObjectPath tablePath, org.apache.flink.table.types.DataType[] fieldTypes, String[] fieldNames, List<String> partitionKeys, int[] selectedFields, boolean useMapRedReader)

Method Summary

Modifier and Type	Method and Description
void	close()
void	open(List<HiveTablePartition> partitions)
org.apache.flink.table.data.RowData	read(org.apache.flink.table.data.RowData reuse)

Methods inherited from class java.lang.Object

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

Field Detail

tablePath

protected final org.apache.flink.table.catalog.ObjectPath tablePath

Constructor Detail

HiveInputFormatPartitionReader

public HiveInputFormatPartitionReader(org.apache.hadoop.mapred.JobConf jobConf,
                                      String hiveVersion,
                                      org.apache.flink.table.catalog.ObjectPath tablePath,
                                      org.apache.flink.table.types.DataType[] fieldTypes,
                                      String[] fieldNames,
                                      List<String> partitionKeys,
                                      int[] selectedFields,
                                      boolean useMapRedReader)

Method Detail

open

public void open(List<HiveTablePartition> partitions)
          throws IOException

Specified by:

open in interface org.apache.flink.table.filesystem.PartitionReader<HiveTablePartition,org.apache.flink.table.data.RowData>

Throws:

IOException

read

public org.apache.flink.table.data.RowData read(org.apache.flink.table.data.RowData reuse)
                                         throws IOException

Specified by:

read in interface org.apache.flink.table.filesystem.PartitionReader<HiveTablePartition,org.apache.flink.table.data.RowData>

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface org.apache.flink.table.filesystem.PartitionReader<HiveTablePartition,org.apache.flink.table.data.RowData>

Throws:

IOException