org.apache.flink.connectors.hive.read

接口 PartitionDiscovery.Context

封闭接口:

PartitionDiscovery

public static interface PartitionDiscovery.Context

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

方法概要

限定符和类型	方法和说明
long	extractTimestamp(List<String> partKeys, List<String> partValues, java.util.function.Supplier<Long> fileTime) Extract timestamp from partition.
org.apache.hadoop.fs.FileSystem	fileSystem() Hadoop filesystem.
Optional<org.apache.hadoop.hive.metastore.api.Partition>	getPartition(List<String> partValues) See IMetaStoreClient.getPartition(java.lang.String, java.lang.String, java.util.List<java.lang.String>).
List<String>	partitionKeys() Partition keys of this table.
org.apache.hadoop.fs.Path	tableLocation() Root location of table.

方法详细资料

partitionKeys

List<String> partitionKeys()

Partition keys of this table.

getPartition

Optional<org.apache.hadoop.hive.metastore.api.Partition> getPartition(List<String> partValues)
                                                               throws org.apache.thrift.TException

See IMetaStoreClient.getPartition(java.lang.String, java.lang.String, java.util.List<java.lang.String>).

抛出:

org.apache.thrift.TException

fileSystem

org.apache.hadoop.fs.FileSystem fileSystem()

Hadoop filesystem.

tableLocation

org.apache.hadoop.fs.Path tableLocation()

Root location of table.

extractTimestamp

long extractTimestamp(List<String> partKeys,
                      List<String> partValues,
                      java.util.function.Supplier<Long> fileTime)

Extract timestamp from partition.