T
- type of record to read and write.public abstract class AbstractFileStore<T> extends Object implements FileStore<T>
FileStore
implementation.Modifier and Type | Field and Description |
---|---|
protected CoreOptions |
options |
protected org.apache.flink.table.types.logical.RowType |
partitionType |
protected long |
schemaId |
protected SchemaManager |
schemaManager |
Constructor and Description |
---|
AbstractFileStore(SchemaManager schemaManager,
long schemaId,
CoreOptions options,
org.apache.flink.table.types.logical.RowType partitionType) |
Modifier and Type | Method and Description |
---|---|
ManifestFile.Factory |
manifestFileFactory() |
ManifestList.Factory |
manifestListFactory() |
FileStoreCommitImpl |
newCommit(String commitUser) |
FileStoreExpireImpl |
newExpire() |
abstract Comparator<org.apache.flink.table.data.RowData> |
newKeyComparator() |
PartitionExpire |
newPartitionExpire(String commitUser) |
CoreOptions |
options() |
org.apache.flink.table.types.logical.RowType |
partitionType() |
FileStorePathFactory |
pathFactory() |
SnapshotManager |
snapshotManager() |
protected final SchemaManager schemaManager
protected final long schemaId
protected final CoreOptions options
protected final org.apache.flink.table.types.logical.RowType partitionType
public AbstractFileStore(SchemaManager schemaManager, long schemaId, CoreOptions options, org.apache.flink.table.types.logical.RowType partitionType)
public FileStorePathFactory pathFactory()
public SnapshotManager snapshotManager()
snapshotManager
in interface FileStore<T>
@VisibleForTesting public ManifestFile.Factory manifestFileFactory()
@VisibleForTesting public ManifestList.Factory manifestListFactory()
public org.apache.flink.table.types.logical.RowType partitionType()
partitionType
in interface FileStore<T>
public CoreOptions options()
public FileStoreCommitImpl newCommit(String commitUser)
public FileStoreExpireImpl newExpire()
public PartitionExpire newPartitionExpire(String commitUser)
newPartitionExpire
in interface FileStore<T>
public abstract Comparator<org.apache.flink.table.data.RowData> newKeyComparator()
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.