Uses of Class
org.apache.flink.connectors.hive.HiveTableSource.HiveContinuousPartitionFetcherContext

Packages that use HiveTableSource.HiveContinuousPartitionFetcherContext

Package	Description
org.apache.flink.connectors.hive

Uses of HiveTableSource.HiveContinuousPartitionFetcherContext in org.apache.flink.connectors.hive

Methods in org.apache.flink.connectors.hive with parameters of type HiveTableSource.HiveContinuousPartitionFetcherContext

Modifier and Type	Method and Description
HiveSource.HiveSourceBuilder	HiveSource.HiveSourceBuilder.setFetcherContext(HiveTableSource.HiveContinuousPartitionFetcherContext<?> fetcherContext)

Constructors in org.apache.flink.connectors.hive with parameters of type HiveTableSource.HiveContinuousPartitionFetcherContext

Constructor and Description

ContinuousHiveSplitEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<HiveSourceSplit> enumeratorContext, T currentReadOffset, Collection<List<String>> seenPartitionsSinceOffset, org.apache.flink.connector.file.src.assigners.FileSplitAssigner splitAssigner, long discoveryInterval, org.apache.hadoop.mapred.JobConf jobConf, org.apache.flink.table.catalog.ObjectPath tablePath, org.apache.flink.table.filesystem.ContinuousPartitionFetcher<org.apache.hadoop.hive.metastore.api.Partition,T> fetcher, HiveTableSource.HiveContinuousPartitionFetcherContext<T> fetcherContext)