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(SplitEnumeratorContext<HiveSourceSplit> enumeratorContext, T currentReadOffset, Collection<List<String>> seenPartitionsSinceOffset, FileSplitAssigner splitAssigner, long discoveryInterval, org.apache.hadoop.mapred.JobConf jobConf, ObjectPath tablePath, ContinuousPartitionFetcher<org.apache.hadoop.hive.metastore.api.Partition,T> fetcher, HiveTableSource.HiveContinuousPartitionFetcherContext<T> fetcherContext)