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
AlterViewDialectProcedure	alter view dialect procedure.
ClearConsumersProcedure	Clear consumers procedure.
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.
MigrateTableProcedure	Migrate table procedure.
ProcedureParameterImpl	An implementation of ProcedureParameter.
PurgeFilesProcedure	A procedure to purge files for a table.
RefreshObjectTableProcedure	Spark procedure to refresh Object Table.
RemoveOrphanFilesProcedure	Remove orphan files procedure.
RemoveUnexistingFilesProcedure	Procedure to remove unexisting data files from manifest entries.
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.
RollbackToWatermarkProcedure	A procedure to rollback to a watermark.