org.apache.paimon.table

Class DelegatedFileStoreTable

java.lang.Object

org.apache.paimon.table.DelegatedFileStoreTable

All Implemented Interfaces:

Serializable, DataTable, FileStoreTable, InnerTable, Table

Direct Known Subclasses:

FallbackReadFileStoreTable, LookupFileStoreTable, PrivilegedFileStoreTable

public abstract class DelegatedFileStoreTable
extends Object
implements FileStoreTable

Delegated FileStoreTable.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected FileStoreTable	wrapped

Constructor Summary

Constructors

Constructor and Description
DelegatedFileStoreTable(FileStoreTable wrapped)

Method Summary

Modifier and Type	Method and Description
BranchManager	branchManager()
CatalogEnvironment	catalogEnvironment()
CoreOptions	coreOptions()
void	createBranch(String branchName) Create an empty branch.
void	createBranch(String branchName, String tagName) Create a branch from given tag.
RowKeyExtractor	createRowKeyExtractor()
void	createTag(String tagName) Create a tag from latest snapshot.
void	createTag(String tagName, java.time.Duration timeRetained)
void	createTag(String tagName, long fromSnapshotId) Create a tag from given snapshot.
void	createTag(String tagName, long fromSnapshotId, java.time.Duration timeRetained)
void	deleteBranch(String branchName) Delete a branch by branchName.
void	deleteTag(String tagName) Delete a tag by name.
boolean	equals(Object o)
void	fastForward(String branchName) Merge a branch to main branch.
FileIO	fileIO()
String	fullName()
SimpleFileReader<IndexManifestEntry>	indexManifestFileReader() Reader to read index manifest entry from index manifest file.
OptionalLong	latestSnapshotId() Get the latest snapshot id for this table, or empty if there are no snapshots.
Path	location()
SimpleFileReader<ManifestEntry>	manifestFileReader() Reader to read manifest entry from manifest file.
SimpleFileReader<ManifestFileMeta>	manifestListReader() Reader to read manifest file meta from manifest list file.
String	name() A name to identify this table.
TableCommitImpl	newCommit(String commitUser)
ExpireSnapshots	newExpireChangelog()
ExpireSnapshots	newExpireSnapshots() Manually expire snapshots, parameters can be controlled independently of table options.
LocalTableQuery	newLocalTableQuery()
InnerTableRead	newRead()
DataTableScan	newScan()
SnapshotReader	newSnapshotReader()
StreamDataTableScan	newStreamScan()
TableWriteImpl<?>	newWrite(String commitUser)
TableWriteImpl<?>	newWrite(String commitUser, ManifestCacheFilter manifestFilter)
Optional<WriteSelector>	newWriteSelector()
void	renameTag(String tagName, String targetTagName)
void	replaceTag(String tagName, Long fromSnapshotId, java.time.Duration timeRetained) Replace a tag with new snapshot id and new time retained.
void	rollbackTo(long snapshotId) Rollback table's state to a specific snapshot.
void	rollbackTo(String tagName) Rollback table's state to a specific tag.
TableSchema	schema()
void	setManifestCache(SegmentsCache<Path> manifestCache)
Snapshot	snapshot(long snapshotId) Get the Snapshot from snapshot id.
SnapshotManager	snapshotManager()
Optional<Statistics>	statistics() Optional statistics of this table.
FileStore<?>	store()
boolean	supportStreamingReadOverwrite()
TagManager	tagManager()
FileStoreTable	wrapped()

Methods inherited from class java.lang.Object

clone, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.paimon.table.FileStoreTable

bucketMode, bucketSpec, comment, copy, copy, copyWithLatestSchema, copyWithoutTimeTravel, options, partitionKeys, primaryKeys, rowType, switchToBranch

Methods inherited from interface org.apache.paimon.table.InnerTable

newBatchWriteBuilder, newReadBuilder, newStreamWriteBuilder

Methods inherited from interface org.apache.paimon.table.Table

deleteBranches, deleteTags

Field Detail

wrapped

protected final FileStoreTable wrapped

Constructor Detail

DelegatedFileStoreTable

public DelegatedFileStoreTable(FileStoreTable wrapped)

Method Detail

wrapped

public FileStoreTable wrapped()

name

public String name()

Description copied from interface: Table

A name to identify this table.

Specified by:

name in interface Table

fullName

public String fullName()

Specified by:

fullName in interface Table

newSnapshotReader

public SnapshotReader newSnapshotReader()

Specified by:

newSnapshotReader in interface DataTable

coreOptions

public CoreOptions coreOptions()

Specified by:

coreOptions in interface DataTable

snapshotManager

public SnapshotManager snapshotManager()

Specified by:

snapshotManager in interface DataTable

tagManager

public TagManager tagManager()

Specified by:

tagManager in interface DataTable

branchManager

public BranchManager branchManager()

Specified by:

branchManager in interface DataTable

location

public Path location()

Specified by:

location in interface DataTable

fileIO

public FileIO fileIO()

Specified by:

fileIO in interface DataTable

setManifestCache

public void setManifestCache(SegmentsCache<Path> manifestCache)

Specified by:

setManifestCache in interface FileStoreTable

schema

public TableSchema schema()

Specified by:

schema in interface FileStoreTable

store

public FileStore<?> store()

Specified by:

store in interface FileStoreTable

catalogEnvironment

public CatalogEnvironment catalogEnvironment()

Specified by:

catalogEnvironment in interface FileStoreTable

statistics

public Optional<Statistics> statistics()

Description copied from interface: Table

Optional statistics of this table.

Specified by:

statistics in interface Table

latestSnapshotId

public OptionalLong latestSnapshotId()

Description copied from interface: Table

Get the latest snapshot id for this table, or empty if there are no snapshots.

Specified by:

latestSnapshotId in interface Table

snapshot

public Snapshot snapshot(long snapshotId)

Description copied from interface: Table

Get the Snapshot from snapshot id.

Specified by:

snapshot in interface Table

manifestListReader

public SimpleFileReader<ManifestFileMeta> manifestListReader()

Description copied from interface: Table

Reader to read manifest file meta from manifest list file.

Specified by:

manifestListReader in interface Table

manifestFileReader

public SimpleFileReader<ManifestEntry> manifestFileReader()

Description copied from interface: Table

Reader to read manifest entry from manifest file.

Specified by:

manifestFileReader in interface Table

indexManifestFileReader

public SimpleFileReader<IndexManifestEntry> indexManifestFileReader()

Description copied from interface: Table

Reader to read index manifest entry from index manifest file.

Specified by:

indexManifestFileReader in interface Table

rollbackTo

public void rollbackTo(long snapshotId)

Description copied from interface: Table

Rollback table's state to a specific snapshot.

Specified by:

rollbackTo in interface Table

createTag

public void createTag(String tagName)

Description copied from interface: Table

Create a tag from latest snapshot.

Specified by:

createTag in interface Table

createTag

public void createTag(String tagName,
                      long fromSnapshotId)

Description copied from interface: Table

Create a tag from given snapshot.

Specified by:

createTag in interface Table

createTag

public void createTag(String tagName,
                      java.time.Duration timeRetained)

Specified by:

createTag in interface Table

createTag

public void createTag(String tagName,
                      long fromSnapshotId,
                      java.time.Duration timeRetained)

Specified by:

createTag in interface Table

renameTag

public void renameTag(String tagName,
                      String targetTagName)

Specified by:

renameTag in interface Table

replaceTag

public void replaceTag(String tagName,
                       Long fromSnapshotId,
                       java.time.Duration timeRetained)

Description copied from interface: Table

Replace a tag with new snapshot id and new time retained.

Specified by:

replaceTag in interface Table

deleteTag

public void deleteTag(String tagName)

Description copied from interface: Table

Delete a tag by name.

Specified by:

deleteTag in interface Table

rollbackTo

public void rollbackTo(String tagName)

Description copied from interface: Table

Rollback table's state to a specific tag.

Specified by:

rollbackTo in interface Table

createBranch

public void createBranch(String branchName)

Description copied from interface: Table

Create an empty branch.

Specified by:

createBranch in interface Table

createBranch

public void createBranch(String branchName,
                         String tagName)

Description copied from interface: Table

Create a branch from given tag.

Specified by:

createBranch in interface Table

deleteBranch

public void deleteBranch(String branchName)

Description copied from interface: Table

Delete a branch by branchName.

Specified by:

deleteBranch in interface Table

fastForward

public void fastForward(String branchName)

Description copied from interface: Table

Merge a branch to main branch.

Specified by:

fastForward in interface Table

newExpireSnapshots

public ExpireSnapshots newExpireSnapshots()

Description copied from interface: Table

Manually expire snapshots, parameters can be controlled independently of table options.

Specified by:

newExpireSnapshots in interface Table

newExpireChangelog

public ExpireSnapshots newExpireChangelog()

Specified by:

newExpireChangelog in interface Table

newScan

public DataTableScan newScan()

Specified by:

newScan in interface DataTable

Specified by:

newScan in interface InnerTable

newStreamScan

public StreamDataTableScan newStreamScan()

Specified by:

newStreamScan in interface InnerTable

newRead

public InnerTableRead newRead()

Specified by:

newRead in interface InnerTable

newWriteSelector

public Optional<WriteSelector> newWriteSelector()

Specified by:

newWriteSelector in interface InnerTable

newWrite

public TableWriteImpl<?> newWrite(String commitUser)

Specified by:

newWrite in interface FileStoreTable

Specified by:

newWrite in interface InnerTable

newWrite

public TableWriteImpl<?> newWrite(String commitUser,
                                  ManifestCacheFilter manifestFilter)

Specified by:

newWrite in interface FileStoreTable

newCommit

public TableCommitImpl newCommit(String commitUser)

Specified by:

newCommit in interface FileStoreTable

Specified by:

newCommit in interface InnerTable

newLocalTableQuery

public LocalTableQuery newLocalTableQuery()

Specified by:

newLocalTableQuery in interface FileStoreTable

supportStreamingReadOverwrite

public boolean supportStreamingReadOverwrite()

Specified by:

supportStreamingReadOverwrite in interface FileStoreTable

createRowKeyExtractor

public RowKeyExtractor createRowKeyExtractor()

Specified by:

createRowKeyExtractor in interface FileStoreTable

equals

public boolean equals(Object o)

Overrides:

equals in class Object