程序包 org.apache.flink.connectors.hive

类概要

类	说明
HadoopFileSystemFactory	Hive FileSystemFactory, hive need use job conf to create file system.
HiveOptions	This class holds configuration constants used by hive connector.
HiveOutputFormatFactory	Hive OutputFormatFactory, use FileSinkOperator.RecordWriter to write record.
HivePartitionComputer	A RowPartitionComputer that converts Flink objects to Hive objects before computing the partition value strings.
HiveTableFactory	A table factory implementation for Hive catalog.
HiveTableMetaStoreFactory	Hive TableMetaStoreFactory, use HiveMetastoreClientWrapper to communicate with hive meta store.
HiveTablePartition	A class that describes a partition of a Hive table.
HiveTableSink	Table sink to write to Hive tables.
HiveTableSource	A TableSource implementation to read data from Hive tables.
JobConfWrapper	Wrap JobConf to a serializable class.

异常错误概要

异常错误	说明
FlinkHiveException	Exception used by flink's hive data connector.