org.apache.flink.table.filesystem

Interface ContinuousPartitionFetcher<P,T extends Comparable<T>>

Type Parameters:

P - The type of partition.

T - The type of partition offset, the type could be Long when fetches in partition-time or create-time order, be String when fetches in partition-name order.

All Superinterfaces:

PartitionFetcher<P>, Serializable

All Known Implementing Classes:

HiveContinuousPartitionFetcher

@Internal
public interface ContinuousPartitionFetcher<P,T extends Comparable<T>>
extends PartitionFetcher<P>

Partition fetcher for helping continuously fetch partitioned table.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	ContinuousPartitionFetcher.Context<P,T extends Comparable<T>> Context for fetch partitions, partition information is stored in hive meta store.

Method Summary

Modifier and Type	Method and Description
List<Tuple2<P,T>>	fetchPartitions(ContinuousPartitionFetcher.Context<P,T> context, T previousOffset) Fetch partitions by previous partition offset (Including).

Methods inherited from interface org.apache.flink.table.filesystem.PartitionFetcher

fetch

Method Detail

fetchPartitions

List<Tuple2<P,T>> fetchPartitions(ContinuousPartitionFetcher.Context<P,T> context,
                                  T previousOffset)
                           throws Exception

Fetch partitions by previous partition offset (Including).

Throws:

Exception