org.apache.paimon.privilege

Class PrivilegedObjectTable

java.lang.Object

org.apache.paimon.table.DelegatedFileStoreTable

org.apache.paimon.privilege.PrivilegedFileStoreTable

org.apache.paimon.privilege.PrivilegedObjectTable

All Implemented Interfaces:

Serializable, DataTable, FileStoreTable, InnerTable, ObjectTable, Table

public class PrivilegedObjectTable
extends PrivilegedFileStoreTable
implements ObjectTable

A PrivilegedFileStoreTable for ObjectTable.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.paimon.table.object.ObjectTable

ObjectTable.Builder, ObjectTable.ObjectTableImpl

Field Summary

Fields inherited from class org.apache.paimon.privilege.PrivilegedFileStoreTable

identifier, privilegeChecker

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

wrapped

Fields inherited from interface org.apache.paimon.table.object.ObjectTable

SCHEMA

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	PrivilegedObjectTable(ObjectTable wrapped, PrivilegeChecker privilegeChecker, Identifier identifier)

Method Summary

Modifier and Type	Method and Description
PrivilegedObjectTable	copy(Map<String,String> dynamicOptions) Copy this table with adding dynamic options.
PrivilegedObjectTable	copy(TableSchema newTableSchema)
PrivilegedObjectTable	copyWithLatestSchema() TODO: this method is weird, old options will overwrite new options.
PrivilegedObjectTable	copyWithoutTimeTravel(Map<String,String> dynamicOptions) Doesn't change table schema even when there exists time travel scan options.
FileIO	objectFileIO() File io for object file system.
String	objectLocation() Object location in file system.
long	refresh()
PrivilegedObjectTable	switchToBranch(String branchName) Get DataTable with branch identified by branchName.
FileStoreTable	underlyingTable() Underlying table to store metadata.

Methods inherited from class org.apache.paimon.privilege.PrivilegedFileStoreTable

branchManager, createBranch, createBranch, createTag, createTag, createTag, createTag, deleteBranch, deleteTag, equals, fastForward, latestSnapshotId, newCommit, newExpireChangelog, newExpireSnapshots, newLocalTableQuery, newRead, newScan, newSnapshotReader, newStreamScan, newWrite, newWrite, newWriteSelector, renameTag, rollbackTo, rollbackTo, snapshot, snapshotManager, statistics, store, tagManager, wrap

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

catalogEnvironment, coreOptions, createRowKeyExtractor, fileIO, fullName, indexManifestFileReader, location, manifestFileReader, manifestListReader, name, replaceTag, schema, schemaManager, setManifestCache, setSnapshotCache, setStatsCache, supportStreamingReadOverwrite, uuid, 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.object.ObjectTable

builder

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

bucketMode, bucketSpec, catalogEnvironment, comment, createRowKeyExtractor, newCommit, newLocalTableQuery, newWrite, newWrite, options, partitionKeys, primaryKeys, rowType, schema, setManifestCache, setSnapshotCache, setStatsCache, store, supportStreamingReadOverwrite

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

branchManager, coreOptions, fileIO, location, newScan, newSnapshotReader, schemaManager, snapshotManager, tagManager

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

newBatchWriteBuilder, newRead, newReadBuilder, newStreamScan, newStreamWriteBuilder, newWriteSelector

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

createBranch, createBranch, createTag, createTag, createTag, createTag, deleteBranch, deleteBranches, deleteTag, deleteTags, fastForward, fullName, indexManifestFileReader, latestSnapshotId, manifestFileReader, manifestListReader, name, newExpireChangelog, newExpireSnapshots, renameTag, replaceTag, rollbackTo, rollbackTo, snapshot, statistics, uuid

Constructor Detail

PrivilegedObjectTable

protected PrivilegedObjectTable(ObjectTable wrapped,
                                PrivilegeChecker privilegeChecker,
                                Identifier identifier)

Method Detail

objectLocation

public String objectLocation()

Description copied from interface: ObjectTable

Object location in file system.

Specified by:

objectLocation in interface ObjectTable

underlyingTable

public FileStoreTable underlyingTable()

Description copied from interface: ObjectTable

Underlying table to store metadata.

Specified by:

underlyingTable in interface ObjectTable

objectFileIO

public FileIO objectFileIO()

Description copied from interface: ObjectTable

File io for object file system.

Specified by:

objectFileIO in interface ObjectTable

refresh

public long refresh()

Specified by:

refresh in interface ObjectTable

copy

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

Description copied from interface: Table

Copy this table with adding dynamic options.

Specified by:

copy in interface FileStoreTable

Specified by:

copy in interface ObjectTable

Specified by:

copy in interface Table

Overrides:

copy in class PrivilegedFileStoreTable

copy

public PrivilegedObjectTable copy(TableSchema newTableSchema)

Specified by:

copy in interface FileStoreTable

Specified by:

copy in interface ObjectTable

Overrides:

copy in class PrivilegedFileStoreTable

copyWithoutTimeTravel

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

Description copied from interface: FileStoreTable

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

Specified by:

copyWithoutTimeTravel in interface FileStoreTable

Specified by:

copyWithoutTimeTravel in interface ObjectTable

Overrides:

copyWithoutTimeTravel in class PrivilegedFileStoreTable

copyWithLatestSchema

public PrivilegedObjectTable copyWithLatestSchema()

Description copied from interface: FileStoreTable

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

Specified by:

copyWithLatestSchema in interface FileStoreTable

Specified by:

copyWithLatestSchema in interface ObjectTable

Overrides:

copyWithLatestSchema in class PrivilegedFileStoreTable

switchToBranch

public PrivilegedObjectTable 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.

Specified by:

switchToBranch in interface DataTable

Specified by:

switchToBranch in interface FileStoreTable

Specified by:

switchToBranch in interface ObjectTable

Overrides:

switchToBranch in class PrivilegedFileStoreTable