org.apache.paimon.privilege

Class PrivilegedFileStoreTable

java.lang.Object

org.apache.paimon.table.DelegatedFileStoreTable

org.apache.paimon.privilege.PrivilegedFileStoreTable

All Implemented Interfaces:

Serializable, DataTable, FileStoreTable, InnerTable, Table

public class PrivilegedFileStoreTable
extends DelegatedFileStoreTable

FileStoreTable with privilege checks.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.paimon.table.DelegatedFileStoreTable

wrapped

Constructor Summary

Constructors

Constructor and Description
PrivilegedFileStoreTable(FileStoreTable wrapped, PrivilegeChecker privilegeChecker, Identifier identifier)

Method Summary

Modifier and Type	Method and Description
BranchManager	branchManager()
FileStoreTable	copy(Map<String,String> dynamicOptions) Copy this table with adding dynamic options.
FileStoreTable	copy(TableSchema newTableSchema)
FileStoreTable	copyWithLatestSchema() TODO: this method is weird, old options will overwrite new options.
FileStoreTable	copyWithoutTimeTravel(Map<String,String> dynamicOptions) Doesn't change table schema even when there exists time travel scan options.
void	createBranch(String branchName) Create an empty branch.
void	createBranch(String branchName, String tagName) Create a branch from given tag.
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.
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	rollbackTo(long snapshotId) Rollback table's state to a specific snapshot.
void	rollbackTo(String tagName) Rollback table's state to a specific tag.
Optional<Statistics>	statistics() Optional statistics of this table.
FileStore<?>	store()
FileStoreTable	switchToBranch(String branchName) Get DataTable with branch identified by branchName.
TagManager	tagManager()

Methods inherited from class org.apache.paimon.table.DelegatedFileStoreTable

catalogEnvironment, coreOptions, createRowKeyExtractor, fileIO, fullName, indexManifestFileReader, latestSnapshotId, location, manifestFileReader, manifestListReader, name, schema, setManifestCache, snapshot, snapshotManager, supportStreamingReadOverwrite

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, getSchemaFieldStats, options, partitionKeys, primaryKeys, rowType

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

newBatchWriteBuilder, newReadBuilder, newStreamWriteBuilder

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

deleteBranches, deleteTags

Constructor Detail

PrivilegedFileStoreTable

public PrivilegedFileStoreTable(FileStoreTable wrapped,
                                PrivilegeChecker privilegeChecker,
                                Identifier identifier)

Method Detail

newSnapshotReader

public SnapshotReader newSnapshotReader()

Specified by:

newSnapshotReader in interface DataTable

Overrides:

newSnapshotReader in class DelegatedFileStoreTable

tagManager

public TagManager tagManager()

Specified by:

tagManager in interface DataTable

Overrides:

tagManager in class DelegatedFileStoreTable

branchManager

public BranchManager branchManager()

Specified by:

branchManager in interface DataTable

Overrides:

branchManager in class DelegatedFileStoreTable

store

public FileStore<?> store()

Specified by:

store in interface FileStoreTable

Overrides:

store in class DelegatedFileStoreTable

statistics

public Optional<Statistics> statistics()

Description copied from interface: Table

Optional statistics of this table.

Specified by:

statistics in interface Table

Overrides:

statistics in class DelegatedFileStoreTable

copy

public FileStoreTable copy(Map<String,String> dynamicOptions)

Description copied from interface: Table

Copy this table with adding dynamic options.

copy

public FileStoreTable copy(TableSchema newTableSchema)

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

Overrides:

rollbackTo in class DelegatedFileStoreTable

createTag

public void createTag(String tagName)

Description copied from interface: Table

Create a tag from latest snapshot.

Specified by:

createTag in interface Table

Overrides:

createTag in class DelegatedFileStoreTable

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

Overrides:

createTag in class DelegatedFileStoreTable

createTag

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

Specified by:

createTag in interface Table

Overrides:

createTag in class DelegatedFileStoreTable

createTag

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

Specified by:

createTag in interface Table

Overrides:

createTag in class DelegatedFileStoreTable

deleteTag

public void deleteTag(String tagName)

Description copied from interface: Table

Delete a tag by name.

Specified by:

deleteTag in interface Table

Overrides:

deleteTag in class DelegatedFileStoreTable

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

Overrides:

rollbackTo in class DelegatedFileStoreTable

createBranch

public void createBranch(String branchName)

Description copied from interface: Table

Create an empty branch.

Specified by:

createBranch in interface Table

Overrides:

createBranch in class DelegatedFileStoreTable

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

Overrides:

createBranch in class DelegatedFileStoreTable

deleteBranch

public void deleteBranch(String branchName)

Description copied from interface: Table

Delete a branch by branchName.

Specified by:

deleteBranch in interface Table

Overrides:

deleteBranch in class DelegatedFileStoreTable

fastForward

public void fastForward(String branchName)

Description copied from interface: Table

Merge a branch to main branch.

Specified by:

fastForward in interface Table

Overrides:

fastForward in class DelegatedFileStoreTable

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

Overrides:

newExpireSnapshots in class DelegatedFileStoreTable

newExpireChangelog

public ExpireSnapshots newExpireChangelog()

Specified by:

newExpireChangelog in interface Table

Overrides:

newExpireChangelog in class DelegatedFileStoreTable

copyWithoutTimeTravel

public FileStoreTable copyWithoutTimeTravel(Map<String,String> dynamicOptions)

Description copied from interface: FileStoreTable

Doesn't change table schema even when there exists time travel scan options.

copyWithLatestSchema

public FileStoreTable copyWithLatestSchema()

Description copied from interface: FileStoreTable

TODO: this method is weird, old options will overwrite new options.

newScan

public DataTableScan newScan()

Specified by:

newScan in interface DataTable

Specified by:

newScan in interface InnerTable

Overrides:

newScan in class DelegatedFileStoreTable

newStreamScan

public StreamDataTableScan newStreamScan()

Specified by:

newStreamScan in interface InnerTable

Overrides:

newStreamScan in class DelegatedFileStoreTable

newRead

public InnerTableRead newRead()

Specified by:

newRead in interface InnerTable

Overrides:

newRead in class DelegatedFileStoreTable

newWriteSelector

public Optional<WriteSelector> newWriteSelector()

Specified by:

newWriteSelector in interface InnerTable

Overrides:

newWriteSelector in class DelegatedFileStoreTable

newWrite

public TableWriteImpl<?> newWrite(String commitUser)

Specified by:

newWrite in interface FileStoreTable

Specified by:

newWrite in interface InnerTable

Overrides:

newWrite in class DelegatedFileStoreTable

newWrite

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

Specified by:

newWrite in interface FileStoreTable

Overrides:

newWrite in class DelegatedFileStoreTable

newCommit

public TableCommitImpl newCommit(String commitUser)

Specified by:

newCommit in interface FileStoreTable

Specified by:

newCommit in interface InnerTable

Overrides:

newCommit in class DelegatedFileStoreTable

newLocalTableQuery

public LocalTableQuery newLocalTableQuery()

Specified by:

newLocalTableQuery in interface FileStoreTable

Overrides:

newLocalTableQuery in class DelegatedFileStoreTable

switchToBranch

public FileStoreTable switchToBranch(String branchName)

Description copied from interface: FileStoreTable

Get DataTable with branch identified by branchName. Note that this method does not keep dynamic options in current table.

equals

public boolean equals(Object o)

Overrides:

equals in class DelegatedFileStoreTable