Package org.apache.flink.connector.file.table

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

@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	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	Description
List<org.apache.flink.api.java.tuple.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.connector.file.table.PartitionFetcher

fetch

Method Detail

fetchPartitions

List<org.apache.flink.api.java.tuple.Tuple2<P,T>> fetchPartitions(ContinuousPartitionFetcher.Context<P,T> context,
                                                                        T previousOffset)
                                                                 throws Exception

Fetch partitions by previous partition offset (Including).

Throws:

Exception