org.apache.paimon.privilege

Class PrivilegedFileStore<T>

java.lang.Object

org.apache.paimon.privilege.PrivilegedFileStore<T>

All Implemented Interfaces:

FileStore<T>

public class PrivilegedFileStore<T>
extends Object
implements FileStore<T>

FileStore with privilege checks.

Constructor Summary

Constructors

Constructor and Description
PrivilegedFileStore(FileStore<T> wrapped, PrivilegeChecker privilegeChecker, Identifier identifier)

Method Summary

Modifier and Type	Method and Description
BucketMode	bucketMode()
List<TagCallback>	createTagCallbacks()
IndexManifestFile.Factory	indexManifestFileFactory()
ManifestFile.Factory	manifestFileFactory()
ManifestList.Factory	manifestListFactory()
boolean	mergeSchema(RowType rowType, boolean allowExplicitCast)
ChangelogDeletion	newChangelogDeletion()
FileStoreCommit	newCommit(String commitUser)
FileStoreCommit	newCommit(String commitUser, List<CommitCallback> callbacks)
IndexFileHandler	newIndexFileHandler()
PartitionExpire	newPartitionExpire(String commitUser)
SplitRead<T>	newRead()
FileStoreScan	newScan()
ServiceManager	newServiceManager()
SnapshotDeletion	newSnapshotDeletion()
StatsFileHandler	newStatsFileHandler()
TagAutoManager	newTagCreationManager()
TagDeletion	newTagDeletion()
TagManager	newTagManager()
FileStoreWrite<T>	newWrite(String commitUser)
FileStoreWrite<T>	newWrite(String commitUser, ManifestCacheFilter manifestFilter)
CoreOptions	options()
RowType	partitionType()
FileStorePathFactory	pathFactory()
void	setManifestCache(SegmentsCache<Path> manifestCache)
void	setSnapshotCache(org.apache.paimon.shade.caffeine2.com.github.benmanes.caffeine.cache.Cache<Path,Snapshot> cache)
SnapshotManager	snapshotManager()

Methods inherited from class java.lang.Object

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

Constructor Detail

PrivilegedFileStore

public PrivilegedFileStore(FileStore<T> wrapped,
                           PrivilegeChecker privilegeChecker,
                           Identifier identifier)

Method Detail

pathFactory

public FileStorePathFactory pathFactory()

Specified by:

pathFactory in interface FileStore<T>

snapshotManager

public SnapshotManager snapshotManager()

Specified by:

snapshotManager in interface FileStore<T>

partitionType

public RowType partitionType()

Specified by:

partitionType in interface FileStore<T>

options

public CoreOptions options()

Specified by:

options in interface FileStore<T>

bucketMode

public BucketMode bucketMode()

Specified by:

bucketMode in interface FileStore<T>

newScan

public FileStoreScan newScan()

Specified by:

newScan in interface FileStore<T>

manifestListFactory

public ManifestList.Factory manifestListFactory()

Specified by:

manifestListFactory in interface FileStore<T>

manifestFileFactory

public ManifestFile.Factory manifestFileFactory()

Specified by:

manifestFileFactory in interface FileStore<T>

indexManifestFileFactory

public IndexManifestFile.Factory indexManifestFileFactory()

Specified by:

indexManifestFileFactory in interface FileStore<T>

newIndexFileHandler

public IndexFileHandler newIndexFileHandler()

Specified by:

newIndexFileHandler in interface FileStore<T>

newStatsFileHandler

public StatsFileHandler newStatsFileHandler()

Specified by:

newStatsFileHandler in interface FileStore<T>

newRead

public SplitRead<T> newRead()

Specified by:

newRead in interface FileStore<T>

newWrite

public FileStoreWrite<T> newWrite(String commitUser)

Specified by:

newWrite in interface FileStore<T>

newWrite

public FileStoreWrite<T> newWrite(String commitUser,
                                  ManifestCacheFilter manifestFilter)

Specified by:

newWrite in interface FileStore<T>

newCommit

public FileStoreCommit newCommit(String commitUser)

Specified by:

newCommit in interface FileStore<T>

newCommit

public FileStoreCommit newCommit(String commitUser,
                                 List<CommitCallback> callbacks)

Specified by:

newCommit in interface FileStore<T>

newSnapshotDeletion

public SnapshotDeletion newSnapshotDeletion()

Specified by:

newSnapshotDeletion in interface FileStore<T>

newChangelogDeletion

public ChangelogDeletion newChangelogDeletion()

Specified by:

newChangelogDeletion in interface FileStore<T>

newTagManager

public TagManager newTagManager()

Specified by:

newTagManager in interface FileStore<T>

newTagDeletion

public TagDeletion newTagDeletion()

Specified by:

newTagDeletion in interface FileStore<T>

newPartitionExpire

@Nullable
public PartitionExpire newPartitionExpire(String commitUser)

Specified by:

newPartitionExpire in interface FileStore<T>

newTagCreationManager

public TagAutoManager newTagCreationManager()

Specified by:

newTagCreationManager in interface FileStore<T>

newServiceManager

public ServiceManager newServiceManager()

Specified by:

newServiceManager in interface FileStore<T>

mergeSchema

public boolean mergeSchema(RowType rowType,
                           boolean allowExplicitCast)

Specified by:

mergeSchema in interface FileStore<T>

createTagCallbacks

public List<TagCallback> createTagCallbacks()

Specified by:

createTagCallbacks in interface FileStore<T>

setManifestCache

public void setManifestCache(SegmentsCache<Path> manifestCache)

Specified by:

setManifestCache in interface FileStore<T>

setSnapshotCache

public void setSnapshotCache(org.apache.paimon.shade.caffeine2.com.github.benmanes.caffeine.cache.Cache<Path,Snapshot> cache)

Specified by:

setSnapshotCache in interface FileStore<T>