Class | Description |
---|---|
HadoopFileSystemFactory |
Hive
FileSystemFactory , hive need use job conf to create file system. |
HiveDynamicTableFactory |
A dynamic table factory implementation for Hive catalog.
|
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.
|
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. |
Enum | Description |
---|---|
ConsumeOrder |
ConsumeOrder defines the orders to continuously consume stream source. |
Exception | Description |
---|---|
FlinkHiveException |
Exception used by flink's hive data connector.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.