PartitionFetcher (Flink : 2.0-SNAPSHOT API)

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 Description

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

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	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