public abstract class AbstractFileStoreTable extends Object implements FileStoreTable
FileStoreTable
.Modifier and Type | Field and Description |
---|---|
protected org.apache.flink.core.fs.Path |
path |
protected TableSchema |
tableSchema |
Constructor and Description |
---|
AbstractFileStoreTable(org.apache.flink.core.fs.Path path,
TableSchema tableSchema) |
Modifier and Type | Method and Description |
---|---|
FileStoreTable |
copy(Map<String,String> dynamicOptions) |
protected abstract FileStoreTable |
copy(TableSchema newTableSchema) |
org.apache.flink.core.fs.Path |
location() |
TableCommit |
newCommit(String commitUser) |
CoreOptions |
options() |
TableSchema |
schema() |
protected SchemaManager |
schemaManager() |
SnapshotManager |
snapshotManager() |
abstract FileStore<?> |
store() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
bucketComputer, name, partitionKeys, rowType
deleteWhere, newWrite
protected final org.apache.flink.core.fs.Path path
protected final TableSchema tableSchema
public AbstractFileStoreTable(org.apache.flink.core.fs.Path path, TableSchema tableSchema)
@VisibleForTesting public abstract FileStore<?> store()
protected abstract FileStoreTable copy(TableSchema newTableSchema)
public FileStoreTable copy(Map<String,String> dynamicOptions)
copy
in interface FileStoreTable
copy
in interface Table
protected SchemaManager schemaManager()
public CoreOptions options()
public TableSchema schema()
schema
in interface FileStoreTable
public SnapshotManager snapshotManager()
snapshotManager
in interface DataTable
public TableCommit newCommit(String commitUser)
newCommit
in interface SupportsWrite
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.