org.apache.flink.connectors.hive.read

Interface HivePartitionContext<P>

Type Parameters:

P - The type of partition.

All Superinterfaces:

PartitionFetcher.Context<P>, Serializable

All Known Subinterfaces:

HiveContinuousPartitionContext<P,T>

All Known Implementing Classes:

HivePartitionFetcherContextBase, HiveTableSource.HiveContinuousPartitionFetcherContext

@Internal
public interface HivePartitionContext<P>
extends PartitionFetcher.Context<P>

Context for Hive 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

Modifier and Type	Method and Description
HiveTablePartition	toHiveTablePartition(P partition) Convert partition to HiveTablePartition.

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

close, getComparablePartitionValueList, getPartition, open

Method Detail

toHiveTablePartition

HiveTablePartition toHiveTablePartition(P partition)

Convert partition to HiveTablePartition.