org.apache.flink.connector.file.table

Interface PartitionFetcher<P>

Type Parameters:

P - The type to describe a partition.

All Superinterfaces:

Serializable

All Known Subinterfaces:

ContinuousPartitionFetcher<P,T>

All Known Implementing Classes:

HiveContinuousPartitionFetcher

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@Internal
 @FunctionalInterface
public interface PartitionFetcher<P>
extends Serializable

Fetcher to fetch the suitable partitions of a filesystem table.

Nested Class Summary

Nested Classes

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

Method Summary

Modifier and Type	Method and Description
List<P>	fetch(PartitionFetcher.Context<P> context) Fetch the suitable partitions, call this method should guarantee the fetcher has opened.

Method Detail

fetch

List<P> fetch(PartitionFetcher.Context<P> context)
       throws Exception

Fetch the suitable partitions, call this method should guarantee the fetcher has opened.

Throws:

Exception