Class | Description |
---|---|
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. |
Exception | Description |
---|---|
FlinkHiveException |
Exception used by flink's hive data connector.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.