public interface FileStoreTable extends DataTable, SupportsPartition, SupportsWrite
FileStore
to provide reading
and writing of RowData
.Modifier and Type | Method and Description |
---|---|
default BucketComputer |
bucketComputer() |
FileStoreTable |
copy(Map<String,String> dynamicOptions) |
default String |
name() |
default List<String> |
partitionKeys() |
default org.apache.flink.table.types.logical.RowType |
rowType() |
TableSchema |
schema() |
newScan, options, snapshotManager
deleteWhere, newCommit, newWrite
default org.apache.flink.table.types.logical.RowType rowType()
default List<String> partitionKeys()
partitionKeys
in interface SupportsPartition
TableSchema schema()
default BucketComputer bucketComputer()
bucketComputer
in interface SupportsWrite
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.