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

接口概要

接口	说明
PartitionDiscovery	Partition strategy for helping fetch hive partitioned table.
PartitionDiscovery.Context	Context for fetch partitions, partition information is stored in hive meta store.
SplitReader	Split reader to read record from files.

类概要

类	说明
DirectoryMonitorDiscovery	Directory monitor PartitionDiscovery.
HiveContinuousMonitoringFunction	This is the single (non-parallel) monitoring task which takes a HiveTableInputFormat, it is responsible for: Monitoring partitions of hive meta store.
HiveMapredSplitReader	Hive SplitReader to read files using hadoop mapred RecordReader.
HiveTableFileInputFormat	A FileInputFormat that wraps a HiveTableInputFormat.
HiveTableInputFormat	The HiveTableInputFormat are inspired by the HCatInputFormat and HadoopInputFormatBase.
HiveTableInputSplit	An wrapper class that wraps info needed for a hadoop input split.
HiveVectorizedOrcSplitReader	Orc SplitReader to read files using OrcColumnarRowSplitReader.
HiveVectorizedParquetSplitReader	Orc SplitReader to read files using ParquetColumnarRowSplitReader.
TimestampedHiveInputSplit	A HiveTableInputSplit with TimestampedInputSplit.
TimestampedHiveInputSplit.SplitTypeInfoFactory	TypeInfoFactory for TimestampedHiveInputSplit.