org.apache.flink.connectors.hive.read

接口 PartitionDiscovery

所有已知实现类:

DirectoryMonitorDiscovery

@Internal
public interface PartitionDiscovery

Partition strategy for helping fetch hive partitioned table.

嵌套类概要

嵌套类

限定符和类型	接口和说明
static interface	PartitionDiscovery.Context Context for fetch partitions, partition information is stored in hive meta store.

方法概要

限定符和类型	方法和说明
List<org.apache.flink.api.java.tuple.Tuple2<org.apache.hadoop.hive.metastore.api.Partition,Long>>	fetchPartitions(PartitionDiscovery.Context context, long previousTimestamp) Fetch partitions by previous timestamp (Including).

方法详细资料

fetchPartitions

List<org.apache.flink.api.java.tuple.Tuple2<org.apache.hadoop.hive.metastore.api.Partition,Long>> fetchPartitions(PartitionDiscovery.Context context,
                                                                                                                  long previousTimestamp)
                                                                                                           throws Exception

Fetch partitions by previous timestamp (Including).

抛出:

Exception