Package | Description |
---|---|
org.apache.flink.connectors.hive | |
org.apache.flink.connectors.hive.read | |
org.apache.flink.connectors.hive.util |
Class and Description |
---|
HiveOptions.PartitionOrder
Partition order used for
HiveOptions.STREAMING_SOURCE_PARTITION_ORDER . |
HiveSource
A unified data source that reads a hive table.
|
HiveSourceBuilder
Builder to build
HiveSource instances. |
HiveSourceSplitSerializer
SerDe for
HiveSourceSplit . |
HiveTablePartition
A class that describes a partition of a Hive table.
|
HiveTablePartitionSplits
Wrap HiveTablePartition, JobConf and the corresponding inputSplits.
|
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 |
---|
HiveOptions.PartitionOrder
Partition order used for
HiveOptions.STREAMING_SOURCE_PARTITION_ORDER . |
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.