Uses of Interface
org.apache.flink.table.filesystem.PartitionFetcher

Packages that use PartitionFetcher

Package	Description
org.apache.flink.connectors.hive.read
org.apache.flink.table.filesystem

Uses of PartitionFetcher in org.apache.flink.connectors.hive.read

Classes in org.apache.flink.connectors.hive.read that implement PartitionFetcher

Modifier and Type	Class and Description
class	HiveContinuousPartitionFetcher<T extends Comparable<T>> A ContinuousPartitionFetcher for hive table.

Uses of PartitionFetcher in org.apache.flink.table.filesystem

Subinterfaces of PartitionFetcher in org.apache.flink.table.filesystem

Modifier and Type	Interface and Description
interface	ContinuousPartitionFetcher<P,T extends Comparable<T>> Partition fetcher for helping continuously fetch partitioned table.

Methods in org.apache.flink.table.filesystem that return PartitionFetcher

Modifier and Type	Method and Description
PartitionFetcher<P>	FileSystemLookupFunction.getPartitionFetcher()

Constructors in org.apache.flink.table.filesystem with parameters of type PartitionFetcher

Constructor and Description
FileSystemLookupFunction(PartitionFetcher<P> partitionFetcher, PartitionFetcher.Context<P> fetcherContext, PartitionReader<P,RowData> partitionReader, RowType rowType, int[] lookupKeys, java.time.Duration reloadInterval)