Package org.apache.flink.connectors.hive

Class Summary

Class	Description
CachedSerializedValue<T>	An extension of SerializedValue which caches the deserialized data.
ContinuousHivePendingSplitsCheckpoint	The checkpoint of current state of continuous hive source reading.
ContinuousHivePendingSplitsCheckpointSerializer	SerDe for ContinuousHivePendingSplitsCheckpoint.
ContinuousHiveSplitEnumerator<T extends Comparable<T>>	A continuously monitoring SplitEnumerator for hive source.
HadoopFileSystemFactory	Hive FileSystemFactory, hive need use job conf to create file system.
HiveDynamicTableFactory	A dynamic table factory implementation for Hive catalog.
HiveLookupTableSource	Hive Table Source that has lookup ability.
HiveOptions	This class holds configuration constants used by hive connector.
HiveRowDataPartitionComputer	A RowDataPartitionComputer that converts Flink objects to Hive objects before computing the partition value strings.
HiveRowPartitionComputer	A RowPartitionComputer that converts Flink objects to Hive objects before computing the partition value strings.
HiveSource	A unified data source that reads a hive table.
HiveSource.HiveSourceBuilder	Builder to build HiveSource instances.
HiveSourceFileEnumerator	A FileEnumerator implementation for hive source, which generates splits based on HiveTablePartitions.
HiveSourceFileEnumerator.Provider	A factory to create HiveSourceFileEnumerator.
HiveSourceSplitSerializer	SerDe for HiveSourceSplit.
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.
HiveTableSource.HiveContinuousPartitionFetcherContext<T extends Comparable<T>>	PartitionFetcher.Context for ContinuousPartitionFetcher.
JobConfWrapper	Wrap JobConf to a serializable class.

Enum Summary

Enum	Description
ConsumeOrder	ConsumeOrder defines the orders to continuously consume stream source.

Exception Summary

Exception	Description
FlinkHiveException	Exception used by flink's hive data connector.