emr

package
v2.9.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 16, 2020 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Cluster 

type Cluster struct {
	pulumi.CustomResourceState

	BootstrapActions ClusterBootstrapActionArrayOutput `pulumi:"bootstrapActions"`
	// Charge Type for this group of hosts: PostPaid or PrePaid. If this is not specified, charge type will follow global chargeType value.
	ChargeType pulumi.StringPtrOutput `pulumi:"chargeType"`
	// EMR Cluster Type, e.g. HADOOP, KAFKA, DRUID, GATEWAY etc. You can find all valid EMR cluster type in emr web console. Supported 'GATEWAY' available in 1.61.0+.
	ClusterType pulumi.StringOutput `pulumi:"clusterType"`
	// Cluster deposit type, HALF_MANAGED or FULL_MANAGED.
	DepositType pulumi.StringPtrOutput `pulumi:"depositType"`
	// High security cluster (true) or not. Default value is false.
	EasEnable pulumi.BoolPtrOutput `pulumi:"easEnable"`
	// EMR Version, e.g. EMR-3.22.0. You can find the all valid EMR Version in emr web console.
	EmrVer pulumi.StringOutput `pulumi:"emrVer"`
	// High Available for HDFS and YARN. If this is set true, MASTER group must have two nodes.
	HighAvailabilityEnable pulumi.BoolPtrOutput `pulumi:"highAvailabilityEnable"`
	// Groups of Host, You can specify MASTER as a group, CORE as a group (just like the above example).
	HostGroups     ClusterHostGroupArrayOutput `pulumi:"hostGroups"`
	IsOpenPublicIp pulumi.BoolPtrOutput        `pulumi:"isOpenPublicIp"`
	// Ssh key pair.
	KeyPairName pulumi.StringPtrOutput `pulumi:"keyPairName"`
	// Master ssh password.
	MasterPwd pulumi.StringPtrOutput `pulumi:"masterPwd"`
	// bootstrap action name.
	Name pulumi.StringOutput `pulumi:"name"`
	// Optional software list.
	OptionSoftwareLists pulumi.StringArrayOutput `pulumi:"optionSoftwareLists"`
	// This specify the related cluster id, if this cluster is a Gateway.
	RelatedClusterId pulumi.StringPtrOutput `pulumi:"relatedClusterId"`
	// Security Group ID for Cluster, you can also specify this key for each host group.
	SecurityGroupId pulumi.StringPtrOutput `pulumi:"securityGroupId"`
	// If this is set true, we can ssh into cluster. Default value is false.
	SshEnable pulumi.BoolPtrOutput `pulumi:"sshEnable"`
	// A mapping of tags to assign to the resource.
	Tags pulumi.MapOutput `pulumi:"tags"`
	// Use local metadb. Default is false.
	UseLocalMetadb pulumi.BoolPtrOutput `pulumi:"useLocalMetadb"`
	// Alicloud EMR uses roles to perform actions on your behalf when provisioning cluster resources, running applications, dynamically scaling resources. EMR uses the following roles when interacting with other Alicloud services. Default value is AliyunEmrEcsDefaultRole.
	UserDefinedEmrEcsRole pulumi.StringPtrOutput `pulumi:"userDefinedEmrEcsRole"`
	// Global vswitch id, you can also specify it in host group.
	VswitchId pulumi.StringPtrOutput `pulumi:"vswitchId"`
	// Zone ID, e.g. cn-huhehaote-a
	ZoneId pulumi.StringOutput `pulumi:"zoneId"`
}

Provides a EMR Cluster resource. With this you can create, read, and release EMR Cluster.

> **NOTE:** Available in 1.57.0+.

func GetCluster 

func GetCluster(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *ClusterState, opts ...pulumi.ResourceOption) (*Cluster, error)

GetCluster gets an existing Cluster resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).

func NewCluster 

func NewCluster(ctx *pulumi.Context,
	name string, args *ClusterArgs, opts ...pulumi.ResourceOption) (*Cluster, error)

NewCluster registers a new resource with the given unique name, arguments, and options.

type ClusterArgs 

type ClusterArgs struct {
	BootstrapActions ClusterBootstrapActionArrayInput
	// Charge Type for this group of hosts: PostPaid or PrePaid. If this is not specified, charge type will follow global chargeType value.
	ChargeType pulumi.StringPtrInput
	// EMR Cluster Type, e.g. HADOOP, KAFKA, DRUID, GATEWAY etc. You can find all valid EMR cluster type in emr web console. Supported 'GATEWAY' available in 1.61.0+.
	ClusterType pulumi.StringInput
	// Cluster deposit type, HALF_MANAGED or FULL_MANAGED.
	DepositType pulumi.StringPtrInput
	// High security cluster (true) or not. Default value is false.
	EasEnable pulumi.BoolPtrInput
	// EMR Version, e.g. EMR-3.22.0. You can find the all valid EMR Version in emr web console.
	EmrVer pulumi.StringInput
	// High Available for HDFS and YARN. If this is set true, MASTER group must have two nodes.
	HighAvailabilityEnable pulumi.BoolPtrInput
	// Groups of Host, You can specify MASTER as a group, CORE as a group (just like the above example).
	HostGroups     ClusterHostGroupArrayInput
	IsOpenPublicIp pulumi.BoolPtrInput
	// Ssh key pair.
	KeyPairName pulumi.StringPtrInput
	// Master ssh password.
	MasterPwd pulumi.StringPtrInput
	// bootstrap action name.
	Name pulumi.StringPtrInput
	// Optional software list.
	OptionSoftwareLists pulumi.StringArrayInput
	// This specify the related cluster id, if this cluster is a Gateway.
	RelatedClusterId pulumi.StringPtrInput
	// Security Group ID for Cluster, you can also specify this key for each host group.
	SecurityGroupId pulumi.StringPtrInput
	// If this is set true, we can ssh into cluster. Default value is false.
	SshEnable pulumi.BoolPtrInput
	// A mapping of tags to assign to the resource.
	Tags pulumi.MapInput
	// Use local metadb. Default is false.
	UseLocalMetadb pulumi.BoolPtrInput
	// Alicloud EMR uses roles to perform actions on your behalf when provisioning cluster resources, running applications, dynamically scaling resources. EMR uses the following roles when interacting with other Alicloud services. Default value is AliyunEmrEcsDefaultRole.
	UserDefinedEmrEcsRole pulumi.StringPtrInput
	// Global vswitch id, you can also specify it in host group.
	VswitchId pulumi.StringPtrInput
	// Zone ID, e.g. cn-huhehaote-a
	ZoneId pulumi.StringInput
}

The set of arguments for constructing a Cluster resource.

func (ClusterArgs) ElementType 

func (ClusterArgs) ElementType() reflect.Type

type ClusterBootstrapAction 

type ClusterBootstrapAction struct {
	// bootstrap action args, e.g. "--a=b".
	Arg *string `pulumi:"arg"`
	// bootstrap action name.
	Name *string `pulumi:"name"`
	// bootstrap action path, e.g. "oss://bucket/path".
	Path *string `pulumi:"path"`
}

type ClusterBootstrapActionArgs 

type ClusterBootstrapActionArgs struct {
	// bootstrap action args, e.g. "--a=b".
	Arg pulumi.StringPtrInput `pulumi:"arg"`
	// bootstrap action name.
	Name pulumi.StringPtrInput `pulumi:"name"`
	// bootstrap action path, e.g. "oss://bucket/path".
	Path pulumi.StringPtrInput `pulumi:"path"`
}

func (ClusterBootstrapActionArgs) ElementType 

func (ClusterBootstrapActionArgs) ElementType() reflect.Type

func (ClusterBootstrapActionArgs) ToClusterBootstrapActionOutput 

func (i ClusterBootstrapActionArgs) ToClusterBootstrapActionOutput() ClusterBootstrapActionOutput

func (ClusterBootstrapActionArgs) ToClusterBootstrapActionOutputWithContext 

func (i ClusterBootstrapActionArgs) ToClusterBootstrapActionOutputWithContext(ctx context.Context) ClusterBootstrapActionOutput

type ClusterBootstrapActionArray 

type ClusterBootstrapActionArray []ClusterBootstrapActionInput

func (ClusterBootstrapActionArray) ElementType 

func (ClusterBootstrapActionArray) ElementType() reflect.Type

func (ClusterBootstrapActionArray) ToClusterBootstrapActionArrayOutput 

func (i ClusterBootstrapActionArray) ToClusterBootstrapActionArrayOutput() ClusterBootstrapActionArrayOutput

func (ClusterBootstrapActionArray) ToClusterBootstrapActionArrayOutputWithContext 

func (i ClusterBootstrapActionArray) ToClusterBootstrapActionArrayOutputWithContext(ctx context.Context) ClusterBootstrapActionArrayOutput

type ClusterBootstrapActionArrayInput 

type ClusterBootstrapActionArrayInput interface {
	pulumi.Input

	ToClusterBootstrapActionArrayOutput() ClusterBootstrapActionArrayOutput
	ToClusterBootstrapActionArrayOutputWithContext(context.Context) ClusterBootstrapActionArrayOutput
}

ClusterBootstrapActionArrayInput is an input type that accepts ClusterBootstrapActionArray and ClusterBootstrapActionArrayOutput values. You can construct a concrete instance of `ClusterBootstrapActionArrayInput` via: 

ClusterBootstrapActionArray{ ClusterBootstrapActionArgs{...} }

type ClusterBootstrapActionArrayOutput 

type ClusterBootstrapActionArrayOutput struct{ *pulumi.OutputState }

func (ClusterBootstrapActionArrayOutput) ElementType 

func (ClusterBootstrapActionArrayOutput) ElementType() reflect.Type

func (ClusterBootstrapActionArrayOutput) Index 

func (o ClusterBootstrapActionArrayOutput) Index(i pulumi.IntInput) ClusterBootstrapActionOutput

func (ClusterBootstrapActionArrayOutput) ToClusterBootstrapActionArrayOutput 

func (o ClusterBootstrapActionArrayOutput) ToClusterBootstrapActionArrayOutput() ClusterBootstrapActionArrayOutput

func (ClusterBootstrapActionArrayOutput) ToClusterBootstrapActionArrayOutputWithContext 

func (o ClusterBootstrapActionArrayOutput) ToClusterBootstrapActionArrayOutputWithContext(ctx context.Context) ClusterBootstrapActionArrayOutput

type ClusterBootstrapActionInput 

type ClusterBootstrapActionInput interface {
	pulumi.Input

	ToClusterBootstrapActionOutput() ClusterBootstrapActionOutput
	ToClusterBootstrapActionOutputWithContext(context.Context) ClusterBootstrapActionOutput
}

ClusterBootstrapActionInput is an input type that accepts ClusterBootstrapActionArgs and ClusterBootstrapActionOutput values. You can construct a concrete instance of `ClusterBootstrapActionInput` via: 

ClusterBootstrapActionArgs{...}

type ClusterBootstrapActionOutput 

type ClusterBootstrapActionOutput struct{ *pulumi.OutputState }

func (ClusterBootstrapActionOutput) Arg 

func (o ClusterBootstrapActionOutput) Arg() pulumi.StringPtrOutput

bootstrap action args, e.g. "--a=b".

func (ClusterBootstrapActionOutput) ElementType 

func (ClusterBootstrapActionOutput) ElementType() reflect.Type

func (ClusterBootstrapActionOutput) Name 

func (o ClusterBootstrapActionOutput) Name() pulumi.StringPtrOutput

bootstrap action name.

func (ClusterBootstrapActionOutput) Path 

func (o ClusterBootstrapActionOutput) Path() pulumi.StringPtrOutput

bootstrap action path, e.g. "oss://bucket/path".

func (ClusterBootstrapActionOutput) ToClusterBootstrapActionOutput 

func (o ClusterBootstrapActionOutput) ToClusterBootstrapActionOutput() ClusterBootstrapActionOutput

func (ClusterBootstrapActionOutput) ToClusterBootstrapActionOutputWithContext 

func (o ClusterBootstrapActionOutput) ToClusterBootstrapActionOutputWithContext(ctx context.Context) ClusterBootstrapActionOutput

type ClusterHostGroup 

type ClusterHostGroup struct {
	// Auto renew for prepaid, true of false. Default is false.
	AutoRenew *bool `pulumi:"autoRenew"`
	// Charge Type for this group of hosts: PostPaid or PrePaid. If this is not specified, charge type will follow global chargeType value.
	ChargeType *string `pulumi:"chargeType"`
	// Data disk capacity.
	DiskCapacity *string `pulumi:"diskCapacity"`
	// Data disk count.
	DiskCount *string `pulumi:"diskCount"`
	// Data disk type. Supported value: cloud,cloud_efficiency,cloud_ssd,local_disk,cloud_essd.
	DiskType  *string `pulumi:"diskType"`
	GpuDriver *string `pulumi:"gpuDriver"`
	// host group name.
	HostGroupName *string `pulumi:"hostGroupName"`
	// host group type, supported value: MASTER, CORE or TASK, supported 'GATEWAY' available in 1.61.0+.
	HostGroupType *string `pulumi:"hostGroupType"`
	// Instance list for cluster scale down. This value follows the json format, e.g. ["instanceId1","instanceId2"]. escape character for " is \".
	InstanceList *string `pulumi:"instanceList"`
	// Host Ecs instance type.
	InstanceType *string `pulumi:"instanceType"`
	// Host number in this group.
	NodeCount *string `pulumi:"nodeCount"`
	// If charge type is PrePaid, this should be specified, unit is month. Supported value: 1、2、3、4、5、6、7、8、9、12、24、36.
	Period *int `pulumi:"period"`
	// System disk capacity.
	SysDiskCapacity *string `pulumi:"sysDiskCapacity"`
	// System disk type. Supported value: cloud,cloud_efficiency,cloud_ssd,cloud_essd.
	SysDiskType *string `pulumi:"sysDiskType"`
}

type ClusterHostGroupArgs 

type ClusterHostGroupArgs struct {
	// Auto renew for prepaid, true of false. Default is false.
	AutoRenew pulumi.BoolPtrInput `pulumi:"autoRenew"`
	// Charge Type for this group of hosts: PostPaid or PrePaid. If this is not specified, charge type will follow global chargeType value.
	ChargeType pulumi.StringPtrInput `pulumi:"chargeType"`
	// Data disk capacity.
	DiskCapacity pulumi.StringPtrInput `pulumi:"diskCapacity"`
	// Data disk count.
	DiskCount pulumi.StringPtrInput `pulumi:"diskCount"`
	// Data disk type. Supported value: cloud,cloud_efficiency,cloud_ssd,local_disk,cloud_essd.
	DiskType  pulumi.StringPtrInput `pulumi:"diskType"`
	GpuDriver pulumi.StringPtrInput `pulumi:"gpuDriver"`
	// host group name.
	HostGroupName pulumi.StringPtrInput `pulumi:"hostGroupName"`
	// host group type, supported value: MASTER, CORE or TASK, supported 'GATEWAY' available in 1.61.0+.
	HostGroupType pulumi.StringPtrInput `pulumi:"hostGroupType"`
	// Instance list for cluster scale down. This value follows the json format, e.g. ["instanceId1","instanceId2"]. escape character for " is \".
	InstanceList pulumi.StringPtrInput `pulumi:"instanceList"`
	// Host Ecs instance type.
	InstanceType pulumi.StringPtrInput `pulumi:"instanceType"`
	// Host number in this group.
	NodeCount pulumi.StringPtrInput `pulumi:"nodeCount"`
	// If charge type is PrePaid, this should be specified, unit is month. Supported value: 1、2、3、4、5、6、7、8、9、12、24、36.
	Period pulumi.IntPtrInput `pulumi:"period"`
	// System disk capacity.
	SysDiskCapacity pulumi.StringPtrInput `pulumi:"sysDiskCapacity"`
	// System disk type. Supported value: cloud,cloud_efficiency,cloud_ssd,cloud_essd.
	SysDiskType pulumi.StringPtrInput `pulumi:"sysDiskType"`
}

func (ClusterHostGroupArgs) ElementType 

func (ClusterHostGroupArgs) ElementType() reflect.Type

func (ClusterHostGroupArgs) ToClusterHostGroupOutput 

func (i ClusterHostGroupArgs) ToClusterHostGroupOutput() ClusterHostGroupOutput

func (ClusterHostGroupArgs) ToClusterHostGroupOutputWithContext 

func (i ClusterHostGroupArgs) ToClusterHostGroupOutputWithContext(ctx context.Context) ClusterHostGroupOutput

type ClusterHostGroupArray 

type ClusterHostGroupArray []ClusterHostGroupInput

func (ClusterHostGroupArray) ElementType 

func (ClusterHostGroupArray) ElementType() reflect.Type

func (ClusterHostGroupArray) ToClusterHostGroupArrayOutput 

func (i ClusterHostGroupArray) ToClusterHostGroupArrayOutput() ClusterHostGroupArrayOutput

func (ClusterHostGroupArray) ToClusterHostGroupArrayOutputWithContext 

func (i ClusterHostGroupArray) ToClusterHostGroupArrayOutputWithContext(ctx context.Context) ClusterHostGroupArrayOutput

type ClusterHostGroupArrayInput 

type ClusterHostGroupArrayInput interface {
	pulumi.Input

	ToClusterHostGroupArrayOutput() ClusterHostGroupArrayOutput
	ToClusterHostGroupArrayOutputWithContext(context.Context) ClusterHostGroupArrayOutput
}

ClusterHostGroupArrayInput is an input type that accepts ClusterHostGroupArray and ClusterHostGroupArrayOutput values. You can construct a concrete instance of `ClusterHostGroupArrayInput` via: 

ClusterHostGroupArray{ ClusterHostGroupArgs{...} }

type ClusterHostGroupArrayOutput 

type ClusterHostGroupArrayOutput struct{ *pulumi.OutputState }

func (ClusterHostGroupArrayOutput) ElementType 

func (ClusterHostGroupArrayOutput) ElementType() reflect.Type

func (ClusterHostGroupArrayOutput) Index 

func (o ClusterHostGroupArrayOutput) Index(i pulumi.IntInput) ClusterHostGroupOutput

func (ClusterHostGroupArrayOutput) ToClusterHostGroupArrayOutput 

func (o ClusterHostGroupArrayOutput) ToClusterHostGroupArrayOutput() ClusterHostGroupArrayOutput

func (ClusterHostGroupArrayOutput) ToClusterHostGroupArrayOutputWithContext 

func (o ClusterHostGroupArrayOutput) ToClusterHostGroupArrayOutputWithContext(ctx context.Context) ClusterHostGroupArrayOutput

type ClusterHostGroupInput 

type ClusterHostGroupInput interface {
	pulumi.Input

	ToClusterHostGroupOutput() ClusterHostGroupOutput
	ToClusterHostGroupOutputWithContext(context.Context) ClusterHostGroupOutput
}

ClusterHostGroupInput is an input type that accepts ClusterHostGroupArgs and ClusterHostGroupOutput values. You can construct a concrete instance of `ClusterHostGroupInput` via: 

ClusterHostGroupArgs{...}

type ClusterHostGroupOutput 

type ClusterHostGroupOutput struct{ *pulumi.OutputState }

func (ClusterHostGroupOutput) AutoRenew 

func (o ClusterHostGroupOutput) AutoRenew() pulumi.BoolPtrOutput

Auto renew for prepaid, true of false. Default is false.

func (ClusterHostGroupOutput) ChargeType 

func (o ClusterHostGroupOutput) ChargeType() pulumi.StringPtrOutput

Charge Type for this group of hosts: PostPaid or PrePaid. If this is not specified, charge type will follow global chargeType value.

func (ClusterHostGroupOutput) DiskCapacity 

func (o ClusterHostGroupOutput) DiskCapacity() pulumi.StringPtrOutput

Data disk capacity.

func (ClusterHostGroupOutput) DiskCount 

func (o ClusterHostGroupOutput) DiskCount() pulumi.StringPtrOutput

Data disk count.

func (ClusterHostGroupOutput) DiskType 

func (o ClusterHostGroupOutput) DiskType() pulumi.StringPtrOutput

Data disk type. Supported value: cloud,cloud_efficiency,cloud_ssd,local_disk,cloud_essd.

func (ClusterHostGroupOutput) ElementType 

func (ClusterHostGroupOutput) ElementType() reflect.Type

func (ClusterHostGroupOutput) GpuDriver 

func (o ClusterHostGroupOutput) GpuDriver() pulumi.StringPtrOutput

func (ClusterHostGroupOutput) HostGroupName 

func (o ClusterHostGroupOutput) HostGroupName() pulumi.StringPtrOutput

host group name.

func (ClusterHostGroupOutput) HostGroupType 

func (o ClusterHostGroupOutput) HostGroupType() pulumi.StringPtrOutput

host group type, supported value: MASTER, CORE or TASK, supported 'GATEWAY' available in 1.61.0+.

func (ClusterHostGroupOutput) InstanceList 

func (o ClusterHostGroupOutput) InstanceList() pulumi.StringPtrOutput

Instance list for cluster scale down. This value follows the json format, e.g. ["instanceId1","instanceId2"]. escape character for " is \".

func (ClusterHostGroupOutput) InstanceType 

func (o ClusterHostGroupOutput) InstanceType() pulumi.StringPtrOutput

Host Ecs instance type.

func (ClusterHostGroupOutput) NodeCount 

func (o ClusterHostGroupOutput) NodeCount() pulumi.StringPtrOutput

Host number in this group.

func (ClusterHostGroupOutput) Period 

func (o ClusterHostGroupOutput) Period() pulumi.IntPtrOutput

If charge type is PrePaid, this should be specified, unit is month. Supported value: 1、2、3、4、5、6、7、8、9、12、24、36.

func (ClusterHostGroupOutput) SysDiskCapacity 

func (o ClusterHostGroupOutput) SysDiskCapacity() pulumi.StringPtrOutput

System disk capacity.

func (ClusterHostGroupOutput) SysDiskType 

func (o ClusterHostGroupOutput) SysDiskType() pulumi.StringPtrOutput

System disk type. Supported value: cloud,cloud_efficiency,cloud_ssd,cloud_essd.

func (ClusterHostGroupOutput) ToClusterHostGroupOutput 

func (o ClusterHostGroupOutput) ToClusterHostGroupOutput() ClusterHostGroupOutput

func (ClusterHostGroupOutput) ToClusterHostGroupOutputWithContext 

func (o ClusterHostGroupOutput) ToClusterHostGroupOutputWithContext(ctx context.Context) ClusterHostGroupOutput

type ClusterState 

type ClusterState struct {
	BootstrapActions ClusterBootstrapActionArrayInput
	// Charge Type for this group of hosts: PostPaid or PrePaid. If this is not specified, charge type will follow global chargeType value.
	ChargeType pulumi.StringPtrInput
	// EMR Cluster Type, e.g. HADOOP, KAFKA, DRUID, GATEWAY etc. You can find all valid EMR cluster type in emr web console. Supported 'GATEWAY' available in 1.61.0+.
	ClusterType pulumi.StringPtrInput
	// Cluster deposit type, HALF_MANAGED or FULL_MANAGED.
	DepositType pulumi.StringPtrInput
	// High security cluster (true) or not. Default value is false.
	EasEnable pulumi.BoolPtrInput
	// EMR Version, e.g. EMR-3.22.0. You can find the all valid EMR Version in emr web console.
	EmrVer pulumi.StringPtrInput
	// High Available for HDFS and YARN. If this is set true, MASTER group must have two nodes.
	HighAvailabilityEnable pulumi.BoolPtrInput
	// Groups of Host, You can specify MASTER as a group, CORE as a group (just like the above example).
	HostGroups     ClusterHostGroupArrayInput
	IsOpenPublicIp pulumi.BoolPtrInput
	// Ssh key pair.
	KeyPairName pulumi.StringPtrInput
	// Master ssh password.
	MasterPwd pulumi.StringPtrInput
	// bootstrap action name.
	Name pulumi.StringPtrInput
	// Optional software list.
	OptionSoftwareLists pulumi.StringArrayInput
	// This specify the related cluster id, if this cluster is a Gateway.
	RelatedClusterId pulumi.StringPtrInput
	// Security Group ID for Cluster, you can also specify this key for each host group.
	SecurityGroupId pulumi.StringPtrInput
	// If this is set true, we can ssh into cluster. Default value is false.
	SshEnable pulumi.BoolPtrInput
	// A mapping of tags to assign to the resource.
	Tags pulumi.MapInput
	// Use local metadb. Default is false.
	UseLocalMetadb pulumi.BoolPtrInput
	// Alicloud EMR uses roles to perform actions on your behalf when provisioning cluster resources, running applications, dynamically scaling resources. EMR uses the following roles when interacting with other Alicloud services. Default value is AliyunEmrEcsDefaultRole.
	UserDefinedEmrEcsRole pulumi.StringPtrInput
	// Global vswitch id, you can also specify it in host group.
	VswitchId pulumi.StringPtrInput
	// Zone ID, e.g. cn-huhehaote-a
	ZoneId pulumi.StringPtrInput
}

func (ClusterState) ElementType 

func (ClusterState) ElementType() reflect.Type

type GetDiskTypesArgs 

type GetDiskTypesArgs struct {
	// The cluster type of the emr cluster instance. Possible values: `HADOOP`, `KAFKA`, `ZOOKEEPER`, `DRUID`.
	ClusterType string `pulumi:"clusterType"`
	// The destination resource of emr cluster instance
	DestinationResource string `pulumi:"destinationResource"`
	// Filter the results by charge type. Valid values: `PrePaid` and `PostPaid`. Default to `PostPaid`.
	InstanceChargeType string `pulumi:"instanceChargeType"`
	// The ecs instance type of create emr cluster instance.
	InstanceType string  `pulumi:"instanceType"`
	OutputFile   *string `pulumi:"outputFile"`
	// The Zone to create emr cluster instance.
	ZoneId *string `pulumi:"zoneId"`
}

A collection of arguments for invoking getDiskTypes.

type GetDiskTypesResult 

type GetDiskTypesResult struct {
	ClusterType         string `pulumi:"clusterType"`
	DestinationResource string `pulumi:"destinationResource"`
	// The provider-assigned unique ID for this managed resource.
	Id string `pulumi:"id"`
	// A list of data disk and system disk type IDs.
	Ids                []string `pulumi:"ids"`
	InstanceChargeType string   `pulumi:"instanceChargeType"`
	InstanceType       string   `pulumi:"instanceType"`
	OutputFile         *string  `pulumi:"outputFile"`
	// A list of emr instance types. Each element contains the following attributes:
	Types  []GetDiskTypesType `pulumi:"types"`
	ZoneId *string            `pulumi:"zoneId"`
}

A collection of values returned by getDiskTypes.

func GetDiskTypes 

func GetDiskTypes(ctx *pulumi.Context, args *GetDiskTypesArgs, opts ...pulumi.InvokeOption) (*GetDiskTypesResult, error)

The `emr.getDiskTypes` data source provides a collection of data disk and system disk types available in Alibaba Cloud account when create a emr cluster.

> **NOTE:** Available in 1.60.0+

type GetDiskTypesType 

type GetDiskTypesType struct {
	// The maximum value of the data disk to supported the specific instance type
	Max int `pulumi:"max"`
	// The mininum value of the data disk to supported the specific instance type
	Min int `pulumi:"min"`
	// The value of the data disk or system disk
	Value string `pulumi:"value"`
}

type GetDiskTypesTypeArgs 

type GetDiskTypesTypeArgs struct {
	// The maximum value of the data disk to supported the specific instance type
	Max pulumi.IntInput `pulumi:"max"`
	// The mininum value of the data disk to supported the specific instance type
	Min pulumi.IntInput `pulumi:"min"`
	// The value of the data disk or system disk
	Value pulumi.StringInput `pulumi:"value"`
}

func (GetDiskTypesTypeArgs) ElementType 

func (GetDiskTypesTypeArgs) ElementType() reflect.Type

func (GetDiskTypesTypeArgs) ToGetDiskTypesTypeOutput 

func (i GetDiskTypesTypeArgs) ToGetDiskTypesTypeOutput() GetDiskTypesTypeOutput

func (GetDiskTypesTypeArgs) ToGetDiskTypesTypeOutputWithContext 

func (i GetDiskTypesTypeArgs) ToGetDiskTypesTypeOutputWithContext(ctx context.Context) GetDiskTypesTypeOutput

type GetDiskTypesTypeArray 

type GetDiskTypesTypeArray []GetDiskTypesTypeInput

func (GetDiskTypesTypeArray) ElementType 

func (GetDiskTypesTypeArray) ElementType() reflect.Type

func (GetDiskTypesTypeArray) ToGetDiskTypesTypeArrayOutput 

func (i GetDiskTypesTypeArray) ToGetDiskTypesTypeArrayOutput() GetDiskTypesTypeArrayOutput

func (GetDiskTypesTypeArray) ToGetDiskTypesTypeArrayOutputWithContext 

func (i GetDiskTypesTypeArray) ToGetDiskTypesTypeArrayOutputWithContext(ctx context.Context) GetDiskTypesTypeArrayOutput

type GetDiskTypesTypeArrayInput 

type GetDiskTypesTypeArrayInput interface {
	pulumi.Input

	ToGetDiskTypesTypeArrayOutput() GetDiskTypesTypeArrayOutput
	ToGetDiskTypesTypeArrayOutputWithContext(context.Context) GetDiskTypesTypeArrayOutput
}

GetDiskTypesTypeArrayInput is an input type that accepts GetDiskTypesTypeArray and GetDiskTypesTypeArrayOutput values. You can construct a concrete instance of `GetDiskTypesTypeArrayInput` via: 

GetDiskTypesTypeArray{ GetDiskTypesTypeArgs{...} }

type GetDiskTypesTypeArrayOutput 

type GetDiskTypesTypeArrayOutput struct{ *pulumi.OutputState }

func (GetDiskTypesTypeArrayOutput) ElementType 

func (GetDiskTypesTypeArrayOutput) ElementType() reflect.Type

func (GetDiskTypesTypeArrayOutput) Index 

func (o GetDiskTypesTypeArrayOutput) Index(i pulumi.IntInput) GetDiskTypesTypeOutput

func (GetDiskTypesTypeArrayOutput) ToGetDiskTypesTypeArrayOutput 

func (o GetDiskTypesTypeArrayOutput) ToGetDiskTypesTypeArrayOutput() GetDiskTypesTypeArrayOutput

func (GetDiskTypesTypeArrayOutput) ToGetDiskTypesTypeArrayOutputWithContext 

func (o GetDiskTypesTypeArrayOutput) ToGetDiskTypesTypeArrayOutputWithContext(ctx context.Context) GetDiskTypesTypeArrayOutput

type GetDiskTypesTypeInput 

type GetDiskTypesTypeInput interface {
	pulumi.Input

	ToGetDiskTypesTypeOutput() GetDiskTypesTypeOutput
	ToGetDiskTypesTypeOutputWithContext(context.Context) GetDiskTypesTypeOutput
}

GetDiskTypesTypeInput is an input type that accepts GetDiskTypesTypeArgs and GetDiskTypesTypeOutput values. You can construct a concrete instance of `GetDiskTypesTypeInput` via: 

GetDiskTypesTypeArgs{...}

type GetDiskTypesTypeOutput 

type GetDiskTypesTypeOutput struct{ *pulumi.OutputState }

func (GetDiskTypesTypeOutput) ElementType 

func (GetDiskTypesTypeOutput) ElementType() reflect.Type

func (GetDiskTypesTypeOutput) Max 

func (o GetDiskTypesTypeOutput) Max() pulumi.IntOutput

The maximum value of the data disk to supported the specific instance type

func (GetDiskTypesTypeOutput) Min 

func (o GetDiskTypesTypeOutput) Min() pulumi.IntOutput

The mininum value of the data disk to supported the specific instance type

func (GetDiskTypesTypeOutput) ToGetDiskTypesTypeOutput 

func (o GetDiskTypesTypeOutput) ToGetDiskTypesTypeOutput() GetDiskTypesTypeOutput

func (GetDiskTypesTypeOutput) ToGetDiskTypesTypeOutputWithContext 

func (o GetDiskTypesTypeOutput) ToGetDiskTypesTypeOutputWithContext(ctx context.Context) GetDiskTypesTypeOutput

func (GetDiskTypesTypeOutput) Value 

func (o GetDiskTypesTypeOutput) Value() pulumi.StringOutput

The value of the data disk or system disk

type GetInstanceTypesArgs 

type GetInstanceTypesArgs struct {
	// The cluster type of the emr cluster instance. Possible values: `HADOOP`, `KAFKA`, `ZOOKEEPER`, `DRUID`.
	ClusterType string `pulumi:"clusterType"`
	// The destination resource of emr cluster instance
	DestinationResource string `pulumi:"destinationResource"`
	// Filter the results by charge type. Valid values: `PrePaid` and `PostPaid`. Default to `PostPaid`.
	InstanceChargeType string `pulumi:"instanceChargeType"`
	// Filter the specific ecs instance type to create emr cluster.
	InstanceType *string `pulumi:"instanceType"`
	OutputFile   *string `pulumi:"outputFile"`
	// Whether the current storage disk is local or not.
	SupportLocalStorage *bool `pulumi:"supportLocalStorage"`
	// The specific supported node type list.
	// Possible values may be any one or combination of these: ["MASTER", "CORE", "TASK", "GATEWAY"]
	SupportNodeTypes []string `pulumi:"supportNodeTypes"`
	// The supported resources of specific zoneId.
	ZoneId *string `pulumi:"zoneId"`
}

A collection of arguments for invoking getInstanceTypes.

type GetInstanceTypesResult 

type GetInstanceTypesResult struct {
	ClusterType         string `pulumi:"clusterType"`
	DestinationResource string `pulumi:"destinationResource"`
	// The provider-assigned unique ID for this managed resource.
	Id string `pulumi:"id"`
	// A list of emr instance types IDs.
	Ids                 []string `pulumi:"ids"`
	InstanceChargeType  string   `pulumi:"instanceChargeType"`
	InstanceType        *string  `pulumi:"instanceType"`
	OutputFile          *string  `pulumi:"outputFile"`
	SupportLocalStorage *bool    `pulumi:"supportLocalStorage"`
	SupportNodeTypes    []string `pulumi:"supportNodeTypes"`
	// A list of emr instance types. Each element contains the following attributes:
	Types []GetInstanceTypesType `pulumi:"types"`
	// The available zone id in Alibaba Cloud account
	ZoneId *string `pulumi:"zoneId"`
}

A collection of values returned by getInstanceTypes.

func GetInstanceTypes 

func GetInstanceTypes(ctx *pulumi.Context, args *GetInstanceTypesArgs, opts ...pulumi.InvokeOption) (*GetInstanceTypesResult, error)

The `emr.getInstanceTypes` data source provides a collection of ecs instance types available in Alibaba Cloud account when create a emr cluster.

> **NOTE:** Available in 1.59.0+

type GetInstanceTypesType 

type GetInstanceTypesType struct {
	// The ID of the instance type.
	Id string `pulumi:"id"`
	// Local capacity of the applied ecs instance for emr cluster. Unit: GB.
	LocalStorageCapacity int `pulumi:"localStorageCapacity"`
	// The supported resources of specific zoneId.
	ZoneId string `pulumi:"zoneId"`
}

type GetInstanceTypesTypeArgs 

type GetInstanceTypesTypeArgs struct {
	// The ID of the instance type.
	Id pulumi.StringInput `pulumi:"id"`
	// Local capacity of the applied ecs instance for emr cluster. Unit: GB.
	LocalStorageCapacity pulumi.IntInput `pulumi:"localStorageCapacity"`
	// The supported resources of specific zoneId.
	ZoneId pulumi.StringInput `pulumi:"zoneId"`
}

func (GetInstanceTypesTypeArgs) ElementType 

func (GetInstanceTypesTypeArgs) ElementType() reflect.Type

func (GetInstanceTypesTypeArgs) ToGetInstanceTypesTypeOutput 

func (i GetInstanceTypesTypeArgs) ToGetInstanceTypesTypeOutput() GetInstanceTypesTypeOutput

func (GetInstanceTypesTypeArgs) ToGetInstanceTypesTypeOutputWithContext 

func (i GetInstanceTypesTypeArgs) ToGetInstanceTypesTypeOutputWithContext(ctx context.Context) GetInstanceTypesTypeOutput

type GetInstanceTypesTypeArray 

type GetInstanceTypesTypeArray []GetInstanceTypesTypeInput

func (GetInstanceTypesTypeArray) ElementType 

func (GetInstanceTypesTypeArray) ElementType() reflect.Type

func (GetInstanceTypesTypeArray) ToGetInstanceTypesTypeArrayOutput 

func (i GetInstanceTypesTypeArray) ToGetInstanceTypesTypeArrayOutput() GetInstanceTypesTypeArrayOutput

func (GetInstanceTypesTypeArray) ToGetInstanceTypesTypeArrayOutputWithContext 

func (i GetInstanceTypesTypeArray) ToGetInstanceTypesTypeArrayOutputWithContext(ctx context.Context) GetInstanceTypesTypeArrayOutput

type GetInstanceTypesTypeArrayInput 

type GetInstanceTypesTypeArrayInput interface {
	pulumi.Input

	ToGetInstanceTypesTypeArrayOutput() GetInstanceTypesTypeArrayOutput
	ToGetInstanceTypesTypeArrayOutputWithContext(context.Context) GetInstanceTypesTypeArrayOutput
}

GetInstanceTypesTypeArrayInput is an input type that accepts GetInstanceTypesTypeArray and GetInstanceTypesTypeArrayOutput values. You can construct a concrete instance of `GetInstanceTypesTypeArrayInput` via: 

GetInstanceTypesTypeArray{ GetInstanceTypesTypeArgs{...} }

type GetInstanceTypesTypeArrayOutput 

type GetInstanceTypesTypeArrayOutput struct{ *pulumi.OutputState }

func (GetInstanceTypesTypeArrayOutput) ElementType 

func (GetInstanceTypesTypeArrayOutput) ElementType() reflect.Type

func (GetInstanceTypesTypeArrayOutput) Index 

func (o GetInstanceTypesTypeArrayOutput) Index(i pulumi.IntInput) GetInstanceTypesTypeOutput

func (GetInstanceTypesTypeArrayOutput) ToGetInstanceTypesTypeArrayOutput 

func (o GetInstanceTypesTypeArrayOutput) ToGetInstanceTypesTypeArrayOutput() GetInstanceTypesTypeArrayOutput

func (GetInstanceTypesTypeArrayOutput) ToGetInstanceTypesTypeArrayOutputWithContext 

func (o GetInstanceTypesTypeArrayOutput) ToGetInstanceTypesTypeArrayOutputWithContext(ctx context.Context) GetInstanceTypesTypeArrayOutput

type GetInstanceTypesTypeInput 

type GetInstanceTypesTypeInput interface {
	pulumi.Input

	ToGetInstanceTypesTypeOutput() GetInstanceTypesTypeOutput
	ToGetInstanceTypesTypeOutputWithContext(context.Context) GetInstanceTypesTypeOutput
}

GetInstanceTypesTypeInput is an input type that accepts GetInstanceTypesTypeArgs and GetInstanceTypesTypeOutput values. You can construct a concrete instance of `GetInstanceTypesTypeInput` via: 

GetInstanceTypesTypeArgs{...}

type GetInstanceTypesTypeOutput 

type GetInstanceTypesTypeOutput struct{ *pulumi.OutputState }

func (GetInstanceTypesTypeOutput) ElementType 

func (GetInstanceTypesTypeOutput) ElementType() reflect.Type

func (GetInstanceTypesTypeOutput) Id 

func (o GetInstanceTypesTypeOutput) Id() pulumi.StringOutput

The ID of the instance type.

func (GetInstanceTypesTypeOutput) LocalStorageCapacity 

func (o GetInstanceTypesTypeOutput) LocalStorageCapacity() pulumi.IntOutput

Local capacity of the applied ecs instance for emr cluster. Unit: GB.

func (GetInstanceTypesTypeOutput) ToGetInstanceTypesTypeOutput 

func (o GetInstanceTypesTypeOutput) ToGetInstanceTypesTypeOutput() GetInstanceTypesTypeOutput

func (GetInstanceTypesTypeOutput) ToGetInstanceTypesTypeOutputWithContext 

func (o GetInstanceTypesTypeOutput) ToGetInstanceTypesTypeOutputWithContext(ctx context.Context) GetInstanceTypesTypeOutput

func (GetInstanceTypesTypeOutput) ZoneId 

func (o GetInstanceTypesTypeOutput) ZoneId() pulumi.StringOutput

The supported resources of specific zoneId.

type GetMainVersionsArgs 

type GetMainVersionsArgs struct {
	// The supported clusterType of this emr version.
	// Possible values may be any one or combination of these: ["HADOOP", "DRUID", "KAFKA", "ZOOKEEPER", "FLINK", "CLICKHOUSE"]
	ClusterTypes []string `pulumi:"clusterTypes"`
	// The version of the emr cluster instance. Possible values: `EMR-4.0.0`, `EMR-3.23.0`, `EMR-3.22.0`.
	EmrVersion *string `pulumi:"emrVersion"`
	OutputFile *string `pulumi:"outputFile"`
}

A collection of arguments for invoking getMainVersions.

type GetMainVersionsMainVersion 

type GetMainVersionsMainVersion struct {
	// A list of cluster types the emr cluster supported. Possible values: `HADOOP`, `ZOOKEEPER`, `KAFKA`, `DRUID`.
	ClusterTypes []string `pulumi:"clusterTypes"`
	// The version of the emr cluster instance. Possible values: `EMR-4.0.0`, `EMR-3.23.0`, `EMR-3.22.0`.
	EmrVersion string `pulumi:"emrVersion"`
	// The image id of the emr cluster instance.
	ImageId string `pulumi:"imageId"`
}

type GetMainVersionsMainVersionArgs 

type GetMainVersionsMainVersionArgs struct {
	// A list of cluster types the emr cluster supported. Possible values: `HADOOP`, `ZOOKEEPER`, `KAFKA`, `DRUID`.
	ClusterTypes pulumi.StringArrayInput `pulumi:"clusterTypes"`
	// The version of the emr cluster instance. Possible values: `EMR-4.0.0`, `EMR-3.23.0`, `EMR-3.22.0`.
	EmrVersion pulumi.StringInput `pulumi:"emrVersion"`
	// The image id of the emr cluster instance.
	ImageId pulumi.StringInput `pulumi:"imageId"`
}

func (GetMainVersionsMainVersionArgs) ElementType 

func (GetMainVersionsMainVersionArgs) ElementType() reflect.Type

func (GetMainVersionsMainVersionArgs) ToGetMainVersionsMainVersionOutput 

func (i GetMainVersionsMainVersionArgs) ToGetMainVersionsMainVersionOutput() GetMainVersionsMainVersionOutput

func (GetMainVersionsMainVersionArgs) ToGetMainVersionsMainVersionOutputWithContext 

func (i GetMainVersionsMainVersionArgs) ToGetMainVersionsMainVersionOutputWithContext(ctx context.Context) GetMainVersionsMainVersionOutput

type GetMainVersionsMainVersionArray 

type GetMainVersionsMainVersionArray []GetMainVersionsMainVersionInput

func (GetMainVersionsMainVersionArray) ElementType 

func (GetMainVersionsMainVersionArray) ElementType() reflect.Type

func (GetMainVersionsMainVersionArray) ToGetMainVersionsMainVersionArrayOutput 

func (i GetMainVersionsMainVersionArray) ToGetMainVersionsMainVersionArrayOutput() GetMainVersionsMainVersionArrayOutput

func (GetMainVersionsMainVersionArray) ToGetMainVersionsMainVersionArrayOutputWithContext 

func (i GetMainVersionsMainVersionArray) ToGetMainVersionsMainVersionArrayOutputWithContext(ctx context.Context) GetMainVersionsMainVersionArrayOutput

type GetMainVersionsMainVersionArrayInput 

type GetMainVersionsMainVersionArrayInput interface {
	pulumi.Input

	ToGetMainVersionsMainVersionArrayOutput() GetMainVersionsMainVersionArrayOutput
	ToGetMainVersionsMainVersionArrayOutputWithContext(context.Context) GetMainVersionsMainVersionArrayOutput
}

GetMainVersionsMainVersionArrayInput is an input type that accepts GetMainVersionsMainVersionArray and GetMainVersionsMainVersionArrayOutput values. You can construct a concrete instance of `GetMainVersionsMainVersionArrayInput` via: 

GetMainVersionsMainVersionArray{ GetMainVersionsMainVersionArgs{...} }

type GetMainVersionsMainVersionArrayOutput 

type GetMainVersionsMainVersionArrayOutput struct{ *pulumi.OutputState }

func (GetMainVersionsMainVersionArrayOutput) ElementType 

func (GetMainVersionsMainVersionArrayOutput) ElementType() reflect.Type

func (GetMainVersionsMainVersionArrayOutput) Index 

func (o GetMainVersionsMainVersionArrayOutput) Index(i pulumi.IntInput) GetMainVersionsMainVersionOutput

func (GetMainVersionsMainVersionArrayOutput) ToGetMainVersionsMainVersionArrayOutput 

func (o GetMainVersionsMainVersionArrayOutput) ToGetMainVersionsMainVersionArrayOutput() GetMainVersionsMainVersionArrayOutput

func (GetMainVersionsMainVersionArrayOutput) ToGetMainVersionsMainVersionArrayOutputWithContext 

func (o GetMainVersionsMainVersionArrayOutput) ToGetMainVersionsMainVersionArrayOutputWithContext(ctx context.Context) GetMainVersionsMainVersionArrayOutput

type GetMainVersionsMainVersionInput 

type GetMainVersionsMainVersionInput interface {
	pulumi.Input

	ToGetMainVersionsMainVersionOutput() GetMainVersionsMainVersionOutput
	ToGetMainVersionsMainVersionOutputWithContext(context.Context) GetMainVersionsMainVersionOutput
}

GetMainVersionsMainVersionInput is an input type that accepts GetMainVersionsMainVersionArgs and GetMainVersionsMainVersionOutput values. You can construct a concrete instance of `GetMainVersionsMainVersionInput` via: 

GetMainVersionsMainVersionArgs{...}

type GetMainVersionsMainVersionOutput 

type GetMainVersionsMainVersionOutput struct{ *pulumi.OutputState }

func (GetMainVersionsMainVersionOutput) ClusterTypes 

func (o GetMainVersionsMainVersionOutput) ClusterTypes() pulumi.StringArrayOutput

A list of cluster types the emr cluster supported. Possible values: `HADOOP`, `ZOOKEEPER`, `KAFKA`, `DRUID`.

func (GetMainVersionsMainVersionOutput) ElementType 

func (GetMainVersionsMainVersionOutput) ElementType() reflect.Type

func (GetMainVersionsMainVersionOutput) EmrVersion 

func (o GetMainVersionsMainVersionOutput) EmrVersion() pulumi.StringOutput

The version of the emr cluster instance. Possible values: `EMR-4.0.0`, `EMR-3.23.0`, `EMR-3.22.0`.

func (GetMainVersionsMainVersionOutput) ImageId 

func (o GetMainVersionsMainVersionOutput) ImageId() pulumi.StringOutput

The image id of the emr cluster instance.

func (GetMainVersionsMainVersionOutput) ToGetMainVersionsMainVersionOutput 

func (o GetMainVersionsMainVersionOutput) ToGetMainVersionsMainVersionOutput() GetMainVersionsMainVersionOutput

func (GetMainVersionsMainVersionOutput) ToGetMainVersionsMainVersionOutputWithContext 

func (o GetMainVersionsMainVersionOutput) ToGetMainVersionsMainVersionOutputWithContext(ctx context.Context) GetMainVersionsMainVersionOutput

type GetMainVersionsResult 

type GetMainVersionsResult struct {
	ClusterTypes []string `pulumi:"clusterTypes"`
	// The version of the emr cluster instance.
	EmrVersion *string `pulumi:"emrVersion"`
	// The provider-assigned unique ID for this managed resource.
	Id string `pulumi:"id"`
	// A list of emr instance types IDs.
	Ids []string `pulumi:"ids"`
	// A list of versions of the emr cluster instance. Each element contains the following attributes:
	MainVersions []GetMainVersionsMainVersion `pulumi:"mainVersions"`
	OutputFile   *string                      `pulumi:"outputFile"`
}

A collection of values returned by getMainVersions.

func GetMainVersions 

func GetMainVersions(ctx *pulumi.Context, args *GetMainVersionsArgs, opts ...pulumi.InvokeOption) (*GetMainVersionsResult, error)

The `emr.getMainVersions` data source provides a collection of emr main versions available in Alibaba Cloud account when create a emr cluster.

> **NOTE:** Available in 1.59.0+

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.