Package org.apache.paimon.spark.procedure

Interface Summary

Interface	Description
Procedure	An interface that defines an executable stored procedure.
ProcedureBuilder	A builder of Procedure that builds a stored procedure.
ProcedureParameter	An input parameter of a stored procedure.

Class Summary

Class	Description
CompactManifestProcedure	Compact manifest procedure.
CompactProcedure	Compact procedure.
CreateBranchProcedure	Spark procedure to create a branch.
CreateOrReplaceTagBaseProcedure	A base procedure to create or replace a tag.
CreateTagFromTimestampProcedure	The procedure supports creating tags from snapshots commit-time or watermark.
CreateTagProcedure	A procedure to create a tag.
DeleteBranchProcedure	Spark procedure to delete a branch.
DeleteTagProcedure	A procedure to delete a tag.
ExpirePartitionsProcedure	A procedure to expire partitions.
ExpireSnapshotsProcedure	A procedure to expire snapshots.
ExpireTagsProcedure	A procedure to expire tags by time.
FastForwardProcedure	Fast-forward branch procedure for given branch.
MarkPartitionDoneProcedure	Partition mark done procedure.
MigrateDatabaseProcedure	Migrate database procedure.
MigrateFileProcedure	Migrate file procedure.
MigrateTableProcedure	Migrate table procedure.
ProcedureParameterImpl	An implementation of ProcedureParameter.
RefreshObjectTableProcedure	Spark procedure to refresh Object Table.
RemoveOrphanFilesProcedure	Remove orphan files procedure.
RenameTagProcedure	Rename Tag Procedure.
RepairProcedure	Repair Procedure.
ReplaceTagProcedure	A procedure to replace a tag.
ResetConsumerProcedure	Reset consumer procedure.
RollbackProcedure	A procedure to rollback to a snapshot or a tag.
RollbackToTimestampProcedure	A procedure to rollback to a timestamp.