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.
|
JobConfWrapper
Wrap
JobConf to a serializable class. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.