Package | Description |
---|---|
org.apache.paimon.flink.procedure | |
org.apache.paimon.flink.procedure.privilege |
Modifier and Type | Class and Description |
---|---|
class |
CloneProcedure
Clone Procedure.
|
class |
CompactDatabaseProcedure
Compact database procedure.
|
class |
CompactManifestProcedure
Compact manifest file to reduce deleted manifest entries.
|
class |
CompactProcedure
Compact procedure.
|
class |
CreateBranchProcedure
Create branch procedure for given tag.
|
class |
CreateOrReplaceTagBaseProcedure
A base procedure to create or replace a tag.
|
class |
CreateTagFromTimestampProcedure
The procedure supports creating tags from snapshots commit-time.
|
class |
CreateTagFromWatermarkProcedure
The procedure supports creating tags from snapshots watermark.
|
class |
CreateTagProcedure
Create tag procedure.
|
class |
DeleteBranchProcedure
Delete branch procedure.
|
class |
DeleteTagProcedure
Delete tag procedure.
|
class |
DropPartitionProcedure
Deprecated.
use ALTER TABLE DROP PARTITION
|
class |
ExpirePartitionsProcedure
A procedure to expire partitions.
|
class |
ExpireSnapshotsProcedure
A procedure to expire snapshots.
|
class |
ExpireTagsProcedure
A procedure to expire tags by time.
|
class |
FastForwardProcedure
Fast Forward procedure for given branch.
|
class |
MarkPartitionDoneProcedure
Partition mark done procedure.
|
class |
MergeIntoProcedure
Merge Into procedure.
|
class |
MigrateDatabaseProcedure
Migrate procedure to migrate all hive tables in database to paimon table.
|
class |
MigrateFileProcedure
Add file procedure to add file from hive to paimon.
|
class |
MigrateTableProcedure
Migrate procedure to migrate hive table to paimon table.
|
class |
QueryServiceProcedure
Query Service procedure.
|
class |
RemoveOrphanFilesProcedure
Remove orphan files procedure.
|
class |
RenameTagProcedure
Create tag procedure.
|
class |
RepairProcedure
Repair procedure.
|
class |
ReplaceTagProcedure
A procedure to replace a tag.
|
class |
ResetConsumerProcedure
Reset consumer procedure.
|
class |
RewriteFileIndexProcedure
Rewrite file index procedure to re-generated all file index.
|
class |
RollbackToProcedure
Rollback procedure.
|
class |
RollbackToTimestampProcedure
Rollback to timestamp procedure.
|
Modifier and Type | Method and Description |
---|---|
ProcedureBase |
ProcedureBase.withCatalog(Catalog catalog) |
Modifier and Type | Class and Description |
---|---|
class |
CreatePrivilegedUserProcedure
Procedure to create a user for the privilege system.
|
class |
DropPrivilegedUserProcedure
Procedure to drop a user from the privilege system.
|
class |
GrantPrivilegeToUserProcedure
Procedure to grant privilege to a user.
|
class |
InitFileBasedPrivilegeProcedure
Procedure to initialize file-based privilege system in warehouse.
|
class |
PrivilegeProcedureBase
Base class for privilege-related procedures.
|
class |
RevokePrivilegeFromUserProcedure
Procedure to revoke privilege from a user.
|
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.