Interface PartitionCommitPolicy.Context
-
- Enclosing interface:
- PartitionCommitPolicy
public static interface PartitionCommitPolicy.ContextContext of policy, including table information and partition information.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description StringcatalogName()Catalog name of this table.StringdatabaseName()Database name of this table.List<String>partitionKeys()Table partition keys.org.apache.flink.core.fs.PathpartitionPath()Path of this partition.default LinkedHashMap<String,String>partitionSpec()Partition spec in the form of a map from partition keys to values.List<String>partitionValues()Values of this partition.StringtableName()Table name.
-
-
-
Method Detail
-
catalogName
String catalogName()
Catalog name of this table.
-
databaseName
String databaseName()
Database name of this table.
-
tableName
String tableName()
Table name.
-
partitionPath
org.apache.flink.core.fs.Path partitionPath()
Path of this partition.
-
partitionSpec
default LinkedHashMap<String,String> partitionSpec()
Partition spec in the form of a map from partition keys to values.
-
-