org.apache.flink.connectors.hive.read

Class HiveCompactReaderFactory

java.lang.Object

org.apache.flink.connectors.hive.read.HiveCompactReaderFactory

All Implemented Interfaces:

Serializable, org.apache.flink.table.filesystem.stream.compact.CompactReader.Factory<org.apache.flink.table.data.RowData>

public class HiveCompactReaderFactory
extends Object
implements org.apache.flink.table.filesystem.stream.compact.CompactReader.Factory<org.apache.flink.table.data.RowData>

The CompactReader.Factory to delegate hive bulk format.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
HiveCompactReaderFactory(org.apache.hadoop.hive.metastore.api.StorageDescriptor sd, Properties properties, org.apache.hadoop.mapred.JobConf jobConf, org.apache.flink.table.catalog.CatalogTable catalogTable, String hiveVersion, org.apache.flink.table.types.logical.RowType producedRowType, boolean useMapRedReader)

Method Summary

Modifier and Type	Method and Description
org.apache.flink.table.filesystem.stream.compact.CompactReader<org.apache.flink.table.data.RowData>	create(org.apache.flink.table.filesystem.stream.compact.CompactContext context)

Methods inherited from class java.lang.Object

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

Constructor Detail

HiveCompactReaderFactory

public HiveCompactReaderFactory(org.apache.hadoop.hive.metastore.api.StorageDescriptor sd,
                                Properties properties,
                                org.apache.hadoop.mapred.JobConf jobConf,
                                org.apache.flink.table.catalog.CatalogTable catalogTable,
                                String hiveVersion,
                                org.apache.flink.table.types.logical.RowType producedRowType,
                                boolean useMapRedReader)

Method Detail

create

public org.apache.flink.table.filesystem.stream.compact.CompactReader<org.apache.flink.table.data.RowData> create(org.apache.flink.table.filesystem.stream.compact.CompactContext context)
                                                                                                           throws IOException

Specified by:

create in interface org.apache.flink.table.filesystem.stream.compact.CompactReader.Factory<org.apache.flink.table.data.RowData>

Throws:

IOException