T
- type of record to read and write.public interface FileStore<T> extends Serializable
Modifier and Type | Method and Description |
---|---|
FileStoreCommit |
newCommit(String commitUser) |
FileStoreExpire |
newExpire() |
PartitionExpire |
newPartitionExpire(String commitUser) |
FileStoreRead<T> |
newRead() |
FileStoreScan |
newScan() |
FileStoreWrite<T> |
newWrite(String commitUser) |
CoreOptions |
options() |
org.apache.flink.table.types.logical.RowType |
partitionType() |
SnapshotManager |
snapshotManager() |
SnapshotManager snapshotManager()
org.apache.flink.table.types.logical.RowType partitionType()
CoreOptions options()
FileStoreScan newScan()
FileStoreRead<T> newRead()
FileStoreWrite<T> newWrite(String commitUser)
FileStoreCommit newCommit(String commitUser)
FileStoreExpire newExpire()
@Nullable PartitionExpire newPartitionExpire(String commitUser)
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.