public class DDLWork extends Object implements Serializable
Modifier and Type | Field and Description |
---|---|
protected HashSet<ReadEntity> |
inputs
ReadEntitites that are passed to the hooks.
|
protected HashSet<WriteEntity> |
outputs
List of WriteEntities that are passed to the hooks.
|
protected HashSet<ReadEntity> inputs
protected HashSet<WriteEntity> outputs
public DDLWork()
public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs)
public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, CreateDatabaseDesc createDatabaseDesc)
createDatabaseDesc
- Create Database descriptorpublic DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, DescDatabaseDesc descDatabaseDesc)
inputs
- outputs
- descDatabaseDesc
- Database descriptorpublic DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, AlterDatabaseDesc alterDbDesc)
public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, TruncateTableDesc truncateTblDesc)
public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, ShowConfDesc showConfDesc)
public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, DropDatabaseDesc dropDatabaseDesc)
dropDatabaseDesc
- Drop Database descriptorpublic DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, SwitchDatabaseDesc switchDatabaseDesc)
switchDatabaseDesc
- Switch Database descriptorpublic DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, AlterTableDesc alterTblDesc)
alterTblDesc
- alter table descriptorpublic DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, AlterMaterializedViewDesc alterMVDesc)
alterMVDesc
- alter materialized view descriptorpublic DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, CreateTableDesc createTblDesc)
createTblDesc
- create table descriptorpublic DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, CreateTableLikeDesc createTblLikeDesc)
createTblLikeDesc
- create table like descriptorpublic DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, CreateViewDesc createVwDesc)
createVwDesc
- create view descriptorpublic DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, DropTableDesc dropTblDesc)
dropTblDesc
- drop table descriptorpublic DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, DescTableDesc descTblDesc)
descTblDesc
- public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, ShowDatabasesDesc showDatabasesDesc)
showDatabasesDesc
- public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, ShowTablesDesc showTblsDesc)
showTblsDesc
- public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, ShowColumnsDesc showColumnsDesc)
showColumnsDesc
- public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, LockTableDesc lockTblDesc)
lockTblDesc
- public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, UnlockTableDesc unlockTblDesc)
unlockTblDesc
- public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, LockDatabaseDesc lockDatabaseDesc)
lockDatabaseDesc
- public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, UnlockDatabaseDesc unlockDatabaseDesc)
unlockDatabaseDesc
- public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, ShowFunctionsDesc showFuncsDesc)
showFuncsDesc
- public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, ShowLocksDesc showLocksDesc)
showLocksDesc
- public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, ShowCompactionsDesc showCompactionsDesc)
public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, ShowTxnsDesc showTxnsDesc)
public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, AbortTxnsDesc abortTxnsDesc)
public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, DescFunctionDesc descFuncDesc)
descFuncDesc
- public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, ShowPartitionsDesc showPartsDesc)
showPartsDesc
- public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, ShowCreateDatabaseDesc showCreateDbDesc)
showCreateDbDesc
- public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, ShowCreateTableDesc showCreateTblDesc)
showCreateTblDesc
- public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, AddPartitionDesc addPartitionDesc)
addPartitionDesc
- information about the partitions we want to add.public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, RenamePartitionDesc renamePartitionDesc)
renamePartitionDesc
- information about the partitions we want to add.public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, AlterTableSimpleDesc simpleDesc)
inputs
- outputs
- simpleDesc
- public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, MsckDesc checkDesc)
public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, ShowTableStatusDesc showTblStatusDesc)
showTblStatusDesc
- show table status descriptorpublic DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, ShowTblPropertiesDesc showTblPropertiesDesc)
showTblPropertiesDesc
- show table properties descriptorpublic DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, RoleDDLDesc roleDDLDesc)
public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, GrantDesc grantDesc)
public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, ShowGrantDesc showGrant)
public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, RevokeDesc revokeDesc)
public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, GrantRevokeRoleDDL grantRevokeRoleDDL)
public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, AlterTablePartMergeFilesDesc mergeDesc)
public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, AlterTableAlterPartDesc alterPartDesc)
public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, AlterTableExchangePartition alterTableExchangePartition)
public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, CacheMetadataDesc cacheMetadataDesc)
public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, InsertCommitHookDesc insertCommitHookDesc)
public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, PreInsertTableDesc preInsertTableDesc)
public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, KillQueryDesc killQueryDesc)
public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, CreateResourcePlanDesc createResourcePlanDesc)
public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, ShowResourcePlanDesc showResourcePlanDesc)
public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, DropResourcePlanDesc dropResourcePlanDesc)
public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, AlterResourcePlanDesc alterResourcePlanDesc)
public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, CreateWMTriggerDesc createWMTriggerDesc)
public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, AlterWMTriggerDesc alterWMTriggerDesc)
public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, DropWMTriggerDesc dropWMTriggerDesc)
public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, CreateOrAlterWMPoolDesc wmPoolDesc)
public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, DropWMPoolDesc dropWMPoolDesc)
public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, CreateOrAlterWMMappingDesc wmMappingDesc)
public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, DropWMMappingDesc dropWMMappingDesc)
public DDLWork(HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, CreateOrDropTriggerToPoolMappingDesc triggerToPoolMappingDesc)
public DescDatabaseDesc getDescDatabaseDesc()
public CreateDatabaseDesc getCreateDatabaseDesc()
public void setCreateDatabaseDesc(CreateDatabaseDesc createDatabaseDesc)
createDatabaseDesc
- public DropDatabaseDesc getDropDatabaseDesc()
public void setDropDatabaseDesc(DropDatabaseDesc dropDatabaseDesc)
dropDatabaseDesc
- public SwitchDatabaseDesc getSwitchDatabaseDesc()
public void setSwitchDatabaseDesc(SwitchDatabaseDesc switchDatabaseDesc)
switchDatabaseDesc
- public LockDatabaseDesc getLockDatabaseDesc()
public void setLockDatabaseDesc(LockDatabaseDesc lockDatabaseDesc)
public UnlockDatabaseDesc getUnlockDatabaseDesc()
public void setUnlockDatabaseDesc(UnlockDatabaseDesc unlockDatabaseDesc)
public CreateTableDesc getCreateTblDesc()
public void setCreateTblDesc(CreateTableDesc createTblDesc)
createTblDesc
- the createTblDesc to setpublic CreateTableLikeDesc getCreateTblLikeDesc()
public void setCreateTblLikeDesc(CreateTableLikeDesc createTblLikeDesc)
createTblLikeDesc
- the createTblDesc to setpublic CreateViewDesc getCreateViewDesc()
public void setCreateViewDesc(CreateViewDesc createVwDesc)
createVwDesc
- the createViewDesc to setpublic DropTableDesc getDropTblDesc()
public void setDropTblDesc(DropTableDesc dropTblDesc)
dropTblDesc
- the dropTblDesc to setpublic AlterTableDesc getAlterTblDesc()
public void setAlterTblDesc(AlterTableDesc alterTblDesc)
alterTblDesc
- the alterTblDesc to setpublic AlterMaterializedViewDesc getAlterMaterializedViewDesc()
public void setAlterMVDesc(AlterMaterializedViewDesc alterMVDesc)
alterMVDesc
- the alterMVDesc to setpublic ShowDatabasesDesc getShowDatabasesDesc()
public void setShowDatabasesDesc(ShowDatabasesDesc showDatabasesDesc)
showDatabasesDesc
- the showDatabasesDesc to setpublic ShowTablesDesc getShowTblsDesc()
public void setShowTblsDesc(ShowTablesDesc showTblsDesc)
showTblsDesc
- the showTblsDesc to setpublic ShowColumnsDesc getShowColumnsDesc()
public void setShowColumnsDesc(ShowColumnsDesc showColumnsDesc)
showColumnsDesc
- the showColumnsDesc to setpublic ShowFunctionsDesc getShowFuncsDesc()
public ShowLocksDesc getShowLocksDesc()
public ShowCompactionsDesc getShowCompactionsDesc()
public ShowTxnsDesc getShowTxnsDesc()
public AbortTxnsDesc getAbortTxnsDesc()
public LockTableDesc getLockTblDesc()
public UnlockTableDesc getUnlockTblDesc()
public DescFunctionDesc getDescFunctionDesc()
public KillQueryDesc getKillQueryDesc()
public void setShowFuncsDesc(ShowFunctionsDesc showFuncsDesc)
showFuncsDesc
- the showFuncsDesc to setpublic void setShowLocksDesc(ShowLocksDesc showLocksDesc)
showLocksDesc
- the showLocksDesc to setpublic void setShowCompactionsDesc(ShowCompactionsDesc showCompactionsDesc)
public void setShowTxnsDesc(ShowTxnsDesc showTxnsDesc)
public void setAbortTxnsDesc(AbortTxnsDesc abortTxnsDesc)
public void setKillQueryDesc(KillQueryDesc killQueryDesc)
public void setLockTblDesc(LockTableDesc lockTblDesc)
lockTblDesc
- the lockTblDesc to setpublic void setUnlockTblDesc(UnlockTableDesc unlockTblDesc)
unlockTblDesc
- the unlockTblDesc to setpublic void setDescFuncDesc(DescFunctionDesc descFuncDesc)
descFuncDesc
- the showFuncsDesc to setpublic ShowPartitionsDesc getShowPartsDesc()
public void setShowPartsDesc(ShowPartitionsDesc showPartsDesc)
showPartsDesc
- the showPartsDesc to setpublic ShowCreateDatabaseDesc getShowCreateDbDesc()
public void setShowCreateDbDesc(ShowCreateDatabaseDesc showCreateDbDesc)
public ShowCreateTableDesc getShowCreateTblDesc()
public void setShowCreateTblDesc(ShowCreateTableDesc showCreateTblDesc)
showCreateTblDesc
- the showCreateTblDesc to setpublic DescTableDesc getDescTblDesc()
public void setDescTblDesc(DescTableDesc descTblDesc)
descTblDesc
- the descTblDesc to setpublic AddPartitionDesc getAddPartitionDesc()
public void setAddPartitionDesc(AddPartitionDesc addPartitionDesc)
addPartitionDesc
- information about the partitions we want to add.public RenamePartitionDesc getRenamePartitionDesc()
public void setRenamePartitionDesc(RenamePartitionDesc renamePartitionDesc)
renamePartitionDesc
- information about the partitions we want to rename.public AlterTableSimpleDesc getAlterTblSimpleDesc()
public void setAlterTblSimpleDesc(AlterTableSimpleDesc desc)
desc
- information about the table/partitions we want to alter.public MsckDesc getMsckDesc()
public void setMsckDesc(MsckDesc msckDesc)
msckDesc
- metastore check descriptionpublic ShowTableStatusDesc getShowTblStatusDesc()
public void setShowTblStatusDesc(ShowTableStatusDesc showTblStatusDesc)
showTblStatusDesc
- show table descriptorpublic ShowTblPropertiesDesc getShowTblPropertiesDesc()
public void setShowTblPropertiesDesc(ShowTblPropertiesDesc showTblPropertiesDesc)
public void setDescFunctionDesc(DescFunctionDesc descFunctionDesc)
public HashSet<ReadEntity> getInputs()
public HashSet<WriteEntity> getOutputs()
public void setInputs(HashSet<ReadEntity> inputs)
public void setOutputs(HashSet<WriteEntity> outputs)
public RoleDDLDesc getRoleDDLDesc()
public void setRoleDDLDesc(RoleDDLDesc roleDDLDesc)
roleDDLDesc
- role ddl descpublic GrantDesc getGrantDesc()
public void setGrantDesc(GrantDesc grantDesc)
grantDesc
- grant descpublic ShowGrantDesc getShowGrantDesc()
public void setShowGrantDesc(ShowGrantDesc showGrantDesc)
showGrantDesc
- public RevokeDesc getRevokeDesc()
public void setRevokeDesc(RevokeDesc revokeDesc)
public GrantRevokeRoleDDL getGrantRevokeRoleDDL()
public void setGrantRevokeRoleDDL(GrantRevokeRoleDDL grantRevokeRoleDDL)
grantRevokeRoleDDL
- public void setAlterDatabaseDesc(AlterDatabaseDesc alterDbDesc)
public AlterDatabaseDesc getAlterDatabaseDesc()
public AlterTablePartMergeFilesDesc getMergeFilesDesc()
public void setMergeFilesDesc(AlterTablePartMergeFilesDesc mergeDesc)
mergeDesc
- descriptor of merging filespublic boolean getNeedLock()
public void setNeedLock(boolean needLock)
public AlterTableAlterPartDesc getAlterTableAlterPartDesc()
public void setAlterTableAlterPartDesc(AlterTableAlterPartDesc alterPartitionDesc)
alterPartitionDesc
- information about the partitions we want to change.public TruncateTableDesc getTruncateTblDesc()
public void setTruncateTblDesc(TruncateTableDesc truncateTblDesc)
public AlterTableExchangePartition getAlterTableExchangePartition()
public CacheMetadataDesc getCacheMetadataDesc()
public void setAlterTableExchangePartition(AlterTableExchangePartition alterTableExchangePartition)
alterTableExchangePartition
- set the value of the table partition to be exchangedpublic ShowConfDesc getShowConfDesc()
public void setShowConfDesc(ShowConfDesc showConfDesc)
public InsertCommitHookDesc getInsertCommitHookDesc()
public void setInsertCommitHookDesc(InsertCommitHookDesc insertCommitHookDesc)
public PreInsertTableDesc getPreInsertTableDesc()
public void setPreInsertTableDesc(PreInsertTableDesc preInsertTableDesc)
public CreateResourcePlanDesc getCreateResourcePlanDesc()
public void setCreateResourcePlanDesc(CreateResourcePlanDesc createResourcePlanDesc)
public ShowResourcePlanDesc getShowResourcePlanDesc()
public void setShowResourcePlanDesc(ShowResourcePlanDesc showResourcePlanDesc)
public DropResourcePlanDesc getDropResourcePlanDesc()
public void setDropResourcePlanDesc(DropResourcePlanDesc dropResourcePlanDesc)
public AlterResourcePlanDesc getAlterResourcePlanDesc()
public void setAlterResourcePlanDesc(AlterResourcePlanDesc alterResourcePlanDesc)
public CreateWMTriggerDesc getCreateWMTriggerDesc()
public void setCreateWMTriggerDesc(CreateWMTriggerDesc createWMTriggerDesc)
public AlterWMTriggerDesc getAlterWMTriggerDesc()
public void setAlterWMTriggerDesc(AlterWMTriggerDesc alterWMTriggerDesc)
public DropWMTriggerDesc getDropWMTriggerDesc()
public void setDropWMTriggerDesc(DropWMTriggerDesc dropWMTriggerDesc)
public CreateOrAlterWMPoolDesc getWmPoolDesc()
public void setWmPoolDesc(CreateOrAlterWMPoolDesc wmPoolDesc)
public DropWMPoolDesc getDropWMPoolDesc()
public void setDropWMPoolDesc(DropWMPoolDesc dropWMPoolDesc)
public CreateOrAlterWMMappingDesc getWmMappingDesc()
public void setWmMappingDesc(CreateOrAlterWMMappingDesc wmMappingDesc)
public DropWMMappingDesc getDropWMMappingDesc()
public void setDropWMMappingDesc(DropWMMappingDesc dropWMMappingDesc)
public CreateOrDropTriggerToPoolMappingDesc getTriggerToPoolMappingDesc()
public void setTriggerToPoolMappingDesc(CreateOrDropTriggerToPoolMappingDesc triggerToPoolMappingDesc)
Copyright © 2022 The Apache Software Foundation. All rights reserved.