org.apache.flink.connectors.hive.read

Class HiveCompactReaderFactory

java.lang.Object

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

All Implemented Interfaces:

Serializable, CompactReader.Factory<RowData>

public class HiveCompactReaderFactory
extends Object
implements CompactReader.Factory<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, CatalogTable catalogTable, String hiveVersion, RowType producedRowType, boolean useMapRedReader)

Method Summary

Modifier and Type	Method and Description
CompactReader<RowData>	create(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,
                                CatalogTable catalogTable,
                                String hiveVersion,
                                RowType producedRowType,
                                boolean useMapRedReader)

Method Detail

create

public CompactReader<RowData> create(CompactContext context)
                              throws IOException

Specified by:

create in interface CompactReader.Factory<RowData>

Throws:

IOException