org.apache.flink.connector.file.table

Interface ContinuousPartitionFetcher.Context<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.Context<P>, Serializable

All Known Subinterfaces:

HiveContinuousPartitionContext<P,T>

All Known Implementing Classes:

HiveTableSource.HiveContinuousPartitionFetcherContext

Enclosing interface:

ContinuousPartitionFetcher<P,T extends Comparable<T>>

public static interface ContinuousPartitionFetcher.Context<P,T extends Comparable<T>>
extends PartitionFetcher.Context<P>

Context for fetch partitions, partition information is stored in hive meta store.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.connector.file.table.PartitionFetcher.Context

PartitionFetcher.Context.ComparablePartitionValue<P,T extends Comparable<T>>

Method Summary

Modifier and Type	Method and Description
T	getConsumeStartOffset() Get the partition consume start offset.
ObjectPath	getTablePath() The table full path.
TypeSerializer<T>	getTypeSerializer() Get the Serializer of partition order.

Methods inherited from interface org.apache.flink.connector.file.table.PartitionFetcher.Context

close, getComparablePartitionValueList, getPartition, open

Method Detail

getTablePath

ObjectPath getTablePath()

The table full path.

getTypeSerializer

TypeSerializer<T> getTypeSerializer()

Get the Serializer of partition order.

getConsumeStartOffset

T getConsumeStartOffset()

Get the partition consume start offset.