Package | Description |
---|---|
org.apache.paimon.spark.catalog | |
org.apache.paimon.spark.procedure |
Modifier and Type | Method and Description |
---|---|
Procedure |
SparkBaseCatalog.loadProcedure(org.apache.spark.sql.connector.catalog.Identifier identifier) |
Procedure |
ProcedureCatalog.loadProcedure(org.apache.spark.sql.connector.catalog.Identifier identifier)
Loads a
stored procedure by identifier . |
Modifier and Type | Class and Description |
---|---|
class |
CompactProcedure
Compact procedure.
|
class |
CreateBranchProcedure
Spark procedure to create a branch.
|
class |
CreateTagFromTimestampProcedure
The procedure supports creating tags from snapshots commit-time or watermark.
|
class |
CreateTagProcedure
A procedure to create a tag.
|
class |
DeleteBranchProcedure
Spark procedure to delete a branch.
|
class |
DeleteTagProcedure
A procedure to delete a tag.
|
class |
ExpirePartitionsProcedure
A procedure to expire partitions.
|
class |
ExpireSnapshotsProcedure
A procedure to expire snapshots.
|
class |
FastForwardProcedure
Fast-forward branch procedure for given branch.
|
class |
MarkPartitionDoneProcedure
Partition mark done procedure.
|
class |
MigrateFileProcedure
Migrate file procedure.
|
class |
MigrateTableProcedure
Migrate table procedure.
|
class |
RemoveOrphanFilesProcedure
Remove orphan files procedure.
|
class |
RepairProcedure
Repair Procedure.
|
class |
ResetConsumerProcedure
Reset consumer procedure.
|
class |
RollbackProcedure
A procedure to rollback to a snapshot or a tag.
|
Modifier and Type | Method and Description |
---|---|
Procedure |
ProcedureBuilder.build()
Builds a
stored procedure via given identifier . |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.