| Package | Description |
|---|---|
| org.apache.flink.connectors.hive | |
| org.apache.flink.connectors.hive.read | |
| org.apache.flink.connectors.hive.util |
| Class and Description |
|---|
ConsumeOrder
ConsumeOrder defines the orders to continuously consume stream source. |
| HiveSource
A unified data source that reads a hive table.
|
| HiveSource.HiveSourceBuilder
Builder to build HiveSource instances.
|
| HiveSourceSplitSerializer
SerDe for
HiveSourceSplit. |
| HiveTablePartition
A class that describes a partition of a Hive table.
|
| HiveTableSource
A TableSource implementation to read data from Hive tables.
|
| HiveTableSource.HiveContinuousPartitionFetcherContext
PartitionFetcher.Context for
ContinuousPartitionFetcher. |
| JobConfWrapper
Wrap
JobConf to a serializable class. |
| Class and Description |
|---|
ConsumeOrder
ConsumeOrder defines the orders to continuously consume stream source. |
| HiveTablePartition
A class that describes a partition of a Hive table.
|
| JobConfWrapper
Wrap
JobConf to a serializable class. |
| Class and Description |
|---|
| HiveTablePartition
A class that describes a partition of a Hive table.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.