Package | Description |
---|---|
org.apache.paimon.spark.procedure |
Modifier and Type | Class and Description |
---|---|
class |
ProcedureParameterImpl
An implementation of
ProcedureParameter . |
Modifier and Type | Method and Description |
---|---|
static ProcedureParameter |
ProcedureParameter.optional(String name,
org.apache.spark.sql.types.DataType dataType)
Creates an optional input parameter.
|
ProcedureParameter[] |
CompactManifestProcedure.parameters() |
ProcedureParameter[] |
MigrateFileProcedure.parameters() |
ProcedureParameter[] |
CreateOrReplaceTagBaseProcedure.parameters() |
ProcedureParameter[] |
DeleteTagProcedure.parameters() |
ProcedureParameter[] |
RollbackProcedure.parameters() |
ProcedureParameter[] |
ExpireSnapshotsProcedure.parameters() |
ProcedureParameter[] |
ResetConsumerProcedure.parameters() |
ProcedureParameter[] |
CreateBranchProcedure.parameters() |
ProcedureParameter[] |
MarkPartitionDoneProcedure.parameters() |
ProcedureParameter[] |
ExpireTagsProcedure.parameters() |
ProcedureParameter[] |
RenameTagProcedure.parameters() |
ProcedureParameter[] |
FastForwardProcedure.parameters() |
ProcedureParameter[] |
DeleteBranchProcedure.parameters() |
ProcedureParameter[] |
RemoveOrphanFilesProcedure.parameters() |
ProcedureParameter[] |
RollbackToTimestampProcedure.parameters() |
ProcedureParameter[] |
ExpirePartitionsProcedure.parameters() |
ProcedureParameter[] |
RepairProcedure.parameters() |
ProcedureParameter[] |
CreateTagFromTimestampProcedure.parameters() |
ProcedureParameter[] |
Procedure.parameters()
Returns the input parameters of stored procedure.
|
ProcedureParameter[] |
MigrateDatabaseProcedure.parameters() |
ProcedureParameter[] |
CompactProcedure.parameters() |
ProcedureParameter[] |
MigrateTableProcedure.parameters() |
static ProcedureParameter |
ProcedureParameter.required(String name,
org.apache.spark.sql.types.DataType dataType)
Creates a required input parameter.
|
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.