| 程序包 | 说明 |
|---|---|
| org.apache.flink.connectors.hive.read |
| 限定符和类型 | 方法和说明 |
|---|---|
List<org.apache.flink.api.java.tuple.Tuple2<org.apache.hadoop.hive.metastore.api.Partition,Long>> |
DirectoryMonitorDiscovery.fetchPartitions(PartitionDiscovery.Context context,
long previousTimestamp) |
List<org.apache.flink.api.java.tuple.Tuple2<org.apache.hadoop.hive.metastore.api.Partition,Long>> |
PartitionDiscovery.fetchPartitions(PartitionDiscovery.Context context,
long previousTimestamp)
Fetch partitions by previous timestamp (Including).
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.