public class AppendOnlyFileStore extends Object
FileStore
for reading and writing InternalRow
.Modifier and Type | Field and Description |
---|---|
protected FileIO |
fileIO |
protected CoreOptions |
options |
protected RowType |
partitionType |
protected TableSchema |
schema |
protected SchemaManager |
schemaManager |
protected String |
tableName |
Constructor and Description |
---|
AppendOnlyFileStore(FileIO fileIO,
SchemaManager schemaManager,
TableSchema schema,
CoreOptions options,
RowType partitionType,
RowType bucketKeyType,
RowType rowType,
String tableName,
CatalogEnvironment catalogEnvironment) |
protected final FileIO fileIO
protected final SchemaManager schemaManager
protected final TableSchema schema
protected final String tableName
protected final CoreOptions options
protected final RowType partitionType
public AppendOnlyFileStore(FileIO fileIO, SchemaManager schemaManager, TableSchema schema, CoreOptions options, RowType partitionType, RowType bucketKeyType, RowType rowType, String tableName, CatalogEnvironment catalogEnvironment)
public BucketMode bucketMode()
public AppendOnlyFileStoreScan newScan()
public RawFileSplitRead newRead()
public AppendOnlyFileStoreWrite newWrite(String commitUser)
public AppendOnlyFileStoreWrite newWrite(String commitUser, ManifestCacheFilter manifestFilter)
public Comparator<InternalRow> newKeyComparator()
public FileStorePathFactory pathFactory()
pathFactory
in interface FileStore<T>
public SnapshotManager snapshotManager()
snapshotManager
in interface FileStore<T>
public ManifestFile.Factory manifestFileFactory()
manifestFileFactory
in interface FileStore<T>
protected ManifestFile.Factory manifestFileFactory(boolean forWrite)
public ManifestList.Factory manifestListFactory()
manifestListFactory
in interface FileStore<T>
protected ManifestList.Factory manifestListFactory(boolean forWrite)
public IndexManifestFile.Factory indexManifestFileFactory()
indexManifestFileFactory
in interface FileStore<T>
public IndexFileHandler newIndexFileHandler()
newIndexFileHandler
in interface FileStore<T>
public StatsFileHandler newStatsFileHandler()
newStatsFileHandler
in interface FileStore<T>
protected ManifestsReader newManifestsReader(boolean forWrite)
public RowType partitionType()
partitionType
in interface FileStore<T>
public CoreOptions options()
public boolean mergeSchema(RowType rowType, boolean allowExplicitCast)
mergeSchema
in interface FileStore<T>
public FileStoreCommitImpl newCommit(String commitUser)
public FileStoreCommitImpl newCommit(String commitUser, List<CommitCallback> callbacks)
public SnapshotDeletion newSnapshotDeletion()
newSnapshotDeletion
in interface FileStore<T>
public ChangelogDeletion newChangelogDeletion()
newChangelogDeletion
in interface FileStore<T>
public TagManager newTagManager()
newTagManager
in interface FileStore<T>
public TagDeletion newTagDeletion()
newTagDeletion
in interface FileStore<T>
@Nullable public PartitionExpire newPartitionExpire(String commitUser)
newPartitionExpire
in interface FileStore<T>
public TagAutoManager newTagCreationManager()
newTagCreationManager
in interface FileStore<T>
public List<TagCallback> createTagCallbacks()
createTagCallbacks
in interface FileStore<T>
public ServiceManager newServiceManager()
newServiceManager
in interface FileStore<T>
public void setManifestCache(SegmentsCache<Path> manifestCache)
setManifestCache
in interface FileStore<T>
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.