Package org.apache.flink.connector.file.table

Interface TableMetaStoreFactory.TableMetaStore

All Superinterfaces:

AutoCloseable, Closeable

Enclosing interface:

TableMetaStoreFactory

public static interface TableMetaStoreFactory.TableMetaStore
extends Closeable

Meta store to manage the location paths of this table and its partitions.

Method Summary

Modifier and Type	Method	Description
void	createOrAlterPartition(LinkedHashMap<String,String> partitionSpec, org.apache.flink.core.fs.Path partitionPath)	After data has been inserted into the partition path, the partition may need to be created (if doesn't exists) or updated.
default void	finishWritingTable(org.apache.flink.core.fs.Path tablePath)	After data has been inserted into table, some follow-up works related to metastore may need be done like report statistic to metastore.
org.apache.flink.core.fs.Path	getLocationPath()	Deprecated.
Optional<org.apache.flink.core.fs.Path>	getPartition(LinkedHashMap<String,String> partitionSpec)	Get partition location path for this partition spec.

Methods inherited from interface java.io.Closeable

close

Method Detail

getLocationPath

@Deprecated
org.apache.flink.core.fs.Path getLocationPath()

Deprecated.

Get base location path of this table.

getPartition

Optional<org.apache.flink.core.fs.Path> getPartition(LinkedHashMap<String,String> partitionSpec)
                                              throws Exception

Get partition location path for this partition spec. See Catalog.getPartition(org.apache.flink.table.catalog.ObjectPath, org.apache.flink.table.catalog.CatalogPartitionSpec).

Parameters:

partitionSpec - partition spec should be a full spec, must be in the same order as the partition keys of the table.

Returns:

empty if table has no this partition, some if table already has partition data.

Throws:

Exception

createOrAlterPartition

void createOrAlterPartition(LinkedHashMap<String,String> partitionSpec,
                            org.apache.flink.core.fs.Path partitionPath)
                     throws Exception

After data has been inserted into the partition path, the partition may need to be created (if doesn't exists) or updated.

Parameters:

partitionSpec - the full spec of the target partition

partitionPath - partition location path

Throws:

Exception

finishWritingTable

default void finishWritingTable(org.apache.flink.core.fs.Path tablePath)
                         throws Exception

After data has been inserted into table, some follow-up works related to metastore may need be done like report statistic to metastore.

Throws:

Exception