aliyun-python-sdk-emr/aliyunsdkemr/request/v20160408/ModifyClusterTemplateRequest.py (236 lines of code) (raw):
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements. See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership. The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License. You may obtain a copy of the License at
#
#
# http://www.apache.org/licenses/LICENSE-2.0
#
#
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
# KIND, either express or implied. See the License for the
# specific language governing permissions and limitations
# under the License.
from aliyunsdkcore.request import RpcRequest
from aliyunsdkemr.endpoint import endpoint_data
class ModifyClusterTemplateRequest(RpcRequest):
def __init__(self):
RpcRequest.__init__(self, 'Emr', '2016-04-08', 'ModifyClusterTemplate')
self.set_method('POST')
if hasattr(self, "endpoint_map"):
setattr(self, "endpoint_map", endpoint_data.getEndpointMap())
if hasattr(self, "endpoint_regional"):
setattr(self, "endpoint_regional", endpoint_data.getEndpointRegional())
def get_ResourceOwnerId(self):
return self.get_query_params().get('ResourceOwnerId')
def set_ResourceOwnerId(self,ResourceOwnerId):
self.add_query_param('ResourceOwnerId',ResourceOwnerId)
def get_LogPath(self):
return self.get_query_params().get('LogPath')
def set_LogPath(self,LogPath):
self.add_query_param('LogPath',LogPath)
def get_MasterPwd(self):
return self.get_query_params().get('MasterPwd')
def set_MasterPwd(self,MasterPwd):
self.add_query_param('MasterPwd',MasterPwd)
def get_Configurations(self):
return self.get_query_params().get('Configurations')
def set_Configurations(self,Configurations):
self.add_query_param('Configurations',Configurations)
def get_SshEnable(self):
return self.get_query_params().get('SshEnable')
def set_SshEnable(self,SshEnable):
self.add_query_param('SshEnable',SshEnable)
def get_KeyPairName(self):
return self.get_query_params().get('KeyPairName')
def set_KeyPairName(self,KeyPairName):
self.add_query_param('KeyPairName',KeyPairName)
def get_MetaStoreType(self):
return self.get_query_params().get('MetaStoreType')
def set_MetaStoreType(self,MetaStoreType):
self.add_query_param('MetaStoreType',MetaStoreType)
def get_SecurityGroupName(self):
return self.get_query_params().get('SecurityGroupName')
def set_SecurityGroupName(self,SecurityGroupName):
self.add_query_param('SecurityGroupName',SecurityGroupName)
def get_MachineType(self):
return self.get_query_params().get('MachineType')
def set_MachineType(self,MachineType):
self.add_query_param('MachineType',MachineType)
def get_ResourceGroupId(self):
return self.get_query_params().get('ResourceGroupId')
def set_ResourceGroupId(self,ResourceGroupId):
self.add_query_param('ResourceGroupId',ResourceGroupId)
def get_BootstrapActions(self):
return self.get_query_params().get('BootstrapAction')
def set_BootstrapActions(self, BootstrapActions):
for depth1 in range(len(BootstrapActions)):
if BootstrapActions[depth1].get('Path') is not None:
self.add_query_param('BootstrapAction.' + str(depth1 + 1) + '.Path', BootstrapActions[depth1].get('Path'))
if BootstrapActions[depth1].get('ExecutionTarget') is not None:
self.add_query_param('BootstrapAction.' + str(depth1 + 1) + '.ExecutionTarget', BootstrapActions[depth1].get('ExecutionTarget'))
if BootstrapActions[depth1].get('ExecutionMoment') is not None:
self.add_query_param('BootstrapAction.' + str(depth1 + 1) + '.ExecutionMoment', BootstrapActions[depth1].get('ExecutionMoment'))
if BootstrapActions[depth1].get('Arg') is not None:
self.add_query_param('BootstrapAction.' + str(depth1 + 1) + '.Arg', BootstrapActions[depth1].get('Arg'))
if BootstrapActions[depth1].get('Name') is not None:
self.add_query_param('BootstrapAction.' + str(depth1 + 1) + '.Name', BootstrapActions[depth1].get('Name'))
if BootstrapActions[depth1].get('ExecutionFailStrategy') is not None:
self.add_query_param('BootstrapAction.' + str(depth1 + 1) + '.ExecutionFailStrategy', BootstrapActions[depth1].get('ExecutionFailStrategy'))
def get_MetaStoreConf(self):
return self.get_query_params().get('MetaStoreConf')
def set_MetaStoreConf(self,MetaStoreConf):
self.add_query_param('MetaStoreConf',MetaStoreConf)
def get_EmrVer(self):
return self.get_query_params().get('EmrVer')
def set_EmrVer(self,EmrVer):
self.add_query_param('EmrVer',EmrVer)
def get_Tags(self):
return self.get_query_params().get('Tag')
def set_Tags(self, Tags):
for depth1 in range(len(Tags)):
if Tags[depth1].get('Value') is not None:
self.add_query_param('Tag.' + str(depth1 + 1) + '.Value', Tags[depth1].get('Value'))
if Tags[depth1].get('Key') is not None:
self.add_query_param('Tag.' + str(depth1 + 1) + '.Key', Tags[depth1].get('Key'))
def get_IsOpenPublicIp(self):
return self.get_query_params().get('IsOpenPublicIp')
def set_IsOpenPublicIp(self,IsOpenPublicIp):
self.add_query_param('IsOpenPublicIp',IsOpenPublicIp)
def get_Period(self):
return self.get_query_params().get('Period')
def set_Period(self,Period):
self.add_query_param('Period',Period)
def get_InstanceGeneration(self):
return self.get_query_params().get('InstanceGeneration')
def set_InstanceGeneration(self,InstanceGeneration):
self.add_query_param('InstanceGeneration',InstanceGeneration)
def get_VSwitchId(self):
return self.get_query_params().get('VSwitchId')
def set_VSwitchId(self,VSwitchId):
self.add_query_param('VSwitchId',VSwitchId)
def get_ClusterType(self):
return self.get_query_params().get('ClusterType')
def set_ClusterType(self,ClusterType):
self.add_query_param('ClusterType',ClusterType)
def get_AutoRenew(self):
return self.get_query_params().get('AutoRenew')
def set_AutoRenew(self,AutoRenew):
self.add_query_param('AutoRenew',AutoRenew)
def get_OptionSoftWareLists(self):
return self.get_query_params().get('OptionSoftWareList')
def set_OptionSoftWareLists(self, OptionSoftWareLists):
for depth1 in range(len(OptionSoftWareLists)):
if OptionSoftWareLists[depth1] is not None:
self.add_query_param('OptionSoftWareList.' + str(depth1 + 1) , OptionSoftWareLists[depth1])
def get_NetType(self):
return self.get_query_params().get('NetType')
def set_NetType(self,NetType):
self.add_query_param('NetType',NetType)
def get_ZoneId(self):
return self.get_query_params().get('ZoneId')
def set_ZoneId(self,ZoneId):
self.add_query_param('ZoneId',ZoneId)
def get_UseCustomHiveMetaDb(self):
return self.get_query_params().get('UseCustomHiveMetaDb')
def set_UseCustomHiveMetaDb(self,UseCustomHiveMetaDb):
self.add_query_param('UseCustomHiveMetaDb',UseCustomHiveMetaDb)
def get_InitCustomHiveMetaDb(self):
return self.get_query_params().get('InitCustomHiveMetaDb')
def set_InitCustomHiveMetaDb(self,InitCustomHiveMetaDb):
self.add_query_param('InitCustomHiveMetaDb',InitCustomHiveMetaDb)
def get_IoOptimized(self):
return self.get_query_params().get('IoOptimized')
def set_IoOptimized(self,IoOptimized):
self.add_query_param('IoOptimized',IoOptimized)
def get_SecurityGroupId(self):
return self.get_query_params().get('SecurityGroupId')
def set_SecurityGroupId(self,SecurityGroupId):
self.add_query_param('SecurityGroupId',SecurityGroupId)
def get_EasEnable(self):
return self.get_query_params().get('EasEnable')
def set_EasEnable(self,EasEnable):
self.add_query_param('EasEnable',EasEnable)
def get_DepositType(self):
return self.get_query_params().get('DepositType')
def set_DepositType(self,DepositType):
self.add_query_param('DepositType',DepositType)
def get_DataDiskKMSKeyId(self):
return self.get_query_params().get('DataDiskKMSKeyId')
def set_DataDiskKMSKeyId(self,DataDiskKMSKeyId):
self.add_query_param('DataDiskKMSKeyId',DataDiskKMSKeyId)
def get_UseLocalMetaDb(self):
return self.get_query_params().get('UseLocalMetaDb')
def set_UseLocalMetaDb(self,UseLocalMetaDb):
self.add_query_param('UseLocalMetaDb',UseLocalMetaDb)
def get_TemplateName(self):
return self.get_query_params().get('TemplateName')
def set_TemplateName(self,TemplateName):
self.add_query_param('TemplateName',TemplateName)
def get_UserDefinedEmrEcsRole(self):
return self.get_query_params().get('UserDefinedEmrEcsRole')
def set_UserDefinedEmrEcsRole(self,UserDefinedEmrEcsRole):
self.add_query_param('UserDefinedEmrEcsRole',UserDefinedEmrEcsRole)
def get_DataDiskEncrypted(self):
return self.get_query_params().get('DataDiskEncrypted')
def set_DataDiskEncrypted(self,DataDiskEncrypted):
self.add_query_param('DataDiskEncrypted',DataDiskEncrypted)
def get_VpcId(self):
return self.get_query_params().get('VpcId')
def set_VpcId(self,VpcId):
self.add_query_param('VpcId',VpcId)
def get_BizId(self):
return self.get_query_params().get('BizId')
def set_BizId(self,BizId):
self.add_query_param('BizId',BizId)
def get_HostGroups(self):
return self.get_query_params().get('HostGroup')
def set_HostGroups(self, HostGroups):
for depth1 in range(len(HostGroups)):
if HostGroups[depth1].get('Period') is not None:
self.add_query_param('HostGroup.' + str(depth1 + 1) + '.Period', HostGroups[depth1].get('Period'))
if HostGroups[depth1].get('SysDiskCapacity') is not None:
self.add_query_param('HostGroup.' + str(depth1 + 1) + '.SysDiskCapacity', HostGroups[depth1].get('SysDiskCapacity'))
if HostGroups[depth1].get('DiskCapacity') is not None:
self.add_query_param('HostGroup.' + str(depth1 + 1) + '.DiskCapacity', HostGroups[depth1].get('DiskCapacity'))
if HostGroups[depth1].get('SysDiskType') is not None:
self.add_query_param('HostGroup.' + str(depth1 + 1) + '.SysDiskType', HostGroups[depth1].get('SysDiskType'))
if HostGroups[depth1].get('ClusterId') is not None:
self.add_query_param('HostGroup.' + str(depth1 + 1) + '.ClusterId', HostGroups[depth1].get('ClusterId'))
if HostGroups[depth1].get('DiskType') is not None:
self.add_query_param('HostGroup.' + str(depth1 + 1) + '.DiskType', HostGroups[depth1].get('DiskType'))
if HostGroups[depth1].get('HostGroupName') is not None:
self.add_query_param('HostGroup.' + str(depth1 + 1) + '.HostGroupName', HostGroups[depth1].get('HostGroupName'))
if HostGroups[depth1].get('VSwitchId') is not None:
self.add_query_param('HostGroup.' + str(depth1 + 1) + '.VSwitchId', HostGroups[depth1].get('VSwitchId'))
if HostGroups[depth1].get('DiskCount') is not None:
self.add_query_param('HostGroup.' + str(depth1 + 1) + '.DiskCount', HostGroups[depth1].get('DiskCount'))
if HostGroups[depth1].get('AutoRenew') is not None:
self.add_query_param('HostGroup.' + str(depth1 + 1) + '.AutoRenew', HostGroups[depth1].get('AutoRenew'))
if HostGroups[depth1].get('HostGroupId') is not None:
self.add_query_param('HostGroup.' + str(depth1 + 1) + '.HostGroupId', HostGroups[depth1].get('HostGroupId'))
if HostGroups[depth1].get('NodeCount') is not None:
self.add_query_param('HostGroup.' + str(depth1 + 1) + '.NodeCount', HostGroups[depth1].get('NodeCount'))
if HostGroups[depth1].get('InstanceType') is not None:
self.add_query_param('HostGroup.' + str(depth1 + 1) + '.InstanceType', HostGroups[depth1].get('InstanceType'))
if HostGroups[depth1].get('Comment') is not None:
self.add_query_param('HostGroup.' + str(depth1 + 1) + '.Comment', HostGroups[depth1].get('Comment'))
if HostGroups[depth1].get('ChargeType') is not None:
self.add_query_param('HostGroup.' + str(depth1 + 1) + '.ChargeType', HostGroups[depth1].get('ChargeType'))
if HostGroups[depth1].get('MultiInstanceTypes') is not None:
self.add_query_param('HostGroup.' + str(depth1 + 1) + '.MultiInstanceTypes', HostGroups[depth1].get('MultiInstanceTypes'))
if HostGroups[depth1].get('CreateType') is not None:
self.add_query_param('HostGroup.' + str(depth1 + 1) + '.CreateType', HostGroups[depth1].get('CreateType'))
if HostGroups[depth1].get('HostGroupType') is not None:
self.add_query_param('HostGroup.' + str(depth1 + 1) + '.HostGroupType', HostGroups[depth1].get('HostGroupType'))
def get_ChargeType(self):
return self.get_query_params().get('ChargeType')
def set_ChargeType(self,ChargeType):
self.add_query_param('ChargeType',ChargeType)
def get_Configs(self):
return self.get_query_params().get('Config')
def set_Configs(self, Configs):
for depth1 in range(len(Configs)):
if Configs[depth1].get('ConfigKey') is not None:
self.add_query_param('Config.' + str(depth1 + 1) + '.ConfigKey', Configs[depth1].get('ConfigKey'))
if Configs[depth1].get('FileName') is not None:
self.add_query_param('Config.' + str(depth1 + 1) + '.FileName', Configs[depth1].get('FileName'))
if Configs[depth1].get('Encrypt') is not None:
self.add_query_param('Config.' + str(depth1 + 1) + '.Encrypt', Configs[depth1].get('Encrypt'))
if Configs[depth1].get('Replace') is not None:
self.add_query_param('Config.' + str(depth1 + 1) + '.Replace', Configs[depth1].get('Replace'))
if Configs[depth1].get('ConfigValue') is not None:
self.add_query_param('Config.' + str(depth1 + 1) + '.ConfigValue', Configs[depth1].get('ConfigValue'))
if Configs[depth1].get('ServiceName') is not None:
self.add_query_param('Config.' + str(depth1 + 1) + '.ServiceName', Configs[depth1].get('ServiceName'))
def get_HighAvailabilityEnable(self):
return self.get_query_params().get('HighAvailabilityEnable')
def set_HighAvailabilityEnable(self,HighAvailabilityEnable):
self.add_query_param('HighAvailabilityEnable',HighAvailabilityEnable)