org.apache.flink.connectors.hive.read

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

Type Parameters:

P - The type of partition.

All Superinterfaces:

ContinuousPartitionFetcher.Context<P,T>, HivePartitionContext<P>, PartitionFetcher.Context<P>, Serializable

All Known Implementing Classes:

HiveTableSource.HiveContinuousPartitionFetcherContext

@Internal
public interface HiveContinuousPartitionContext<P,T extends Comparable<T>>
extends HivePartitionContext<P>, ContinuousPartitionFetcher.Context<P,T>

Context for Hive continuous partition fetcher.

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

Methods inherited from interface org.apache.flink.connectors.hive.read.HivePartitionContext

toHiveTablePartition

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

getConsumeStartOffset, getTablePath, getTypeSerializer

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

close, getComparablePartitionValueList, getPartition, open