Class MetastoreCommitPolicy
- java.lang.Object
-
- org.apache.flink.connector.file.table.MetastoreCommitPolicy
-
- All Implemented Interfaces:
PartitionCommitPolicy
@Internal public class MetastoreCommitPolicy extends Object implements PartitionCommitPolicy
Partition commit policy to update metastore.If this is for file system table, the metastore is a empty implemantation. If this is for hive table, the metastore is for connecting to hive metastore.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.apache.flink.connector.file.table.PartitionCommitPolicy
PartitionCommitPolicy.Context
-
-
Field Summary
-
Fields inherited from interface org.apache.flink.connector.file.table.PartitionCommitPolicy
CUSTOM, METASTORE, SUCCESS_FILE
-
-
Constructor Summary
Constructors Constructor Description MetastoreCommitPolicy()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
commit(PartitionCommitPolicy.Context context)
Commit a partition.void
setMetastore(TableMetaStoreFactory.TableMetaStore metaStore)
-
-
-
Method Detail
-
setMetastore
public void setMetastore(TableMetaStoreFactory.TableMetaStore metaStore)
-
commit
public void commit(PartitionCommitPolicy.Context context) throws Exception
Description copied from interface:PartitionCommitPolicy
Commit a partition.- Specified by:
commit
in interfacePartitionCommitPolicy
- Throws:
Exception
-
-