Class: AWSCDK::StepFunctionsTasks::WorkerTypeV2

Inherits:
Jsii::Object
  • Object
show all
Defined in:
step_functions_tasks/worker_type_v2.rb

Overview

The type of predefined worker that is allocated when a job runs.

If you need to use a WorkerTypeV2 that doesn't exist as a static member, you can instantiate a WorkerTypeV2 object, e.g: WorkerTypeV2.of('other type').

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(*args) ⇒ WorkerTypeV2

Returns a new instance of WorkerTypeV2.

Raises:

  • (NoMethodError) 


11
12
13
 
# File 'step_functions_tasks/worker_type_v2.rb', line 11

def initialize(*args)
  raise NoMethodError, "aws-cdk-lib.aws_stepfunctions_tasks.WorkerTypeV2 does not have a visible constructor; use the provided factory methods"
end

Class Method Details

.G_025_X ⇒ AWSCDK::StepFunctionsTasks::WorkerTypeV2

Each worker maps to 0.25 DPU (2 vCPU, 4 GB of memory, 64 GB disk), and provides 1 executor per worker. Suitable for low volume streaming jobs.

Returns:

  • (AWSCDK::StepFunctionsTasks::WorkerTypeV2) 


33
34
35
 
# File 'step_functions_tasks/worker_type_v2.rb', line 33

def self.G_025_X()
  Jsii::Kernel.instance.get_static("aws-cdk-lib.aws_stepfunctions_tasks.WorkerTypeV2", "G_025X")
end

.G_1_X ⇒ AWSCDK::StepFunctionsTasks::WorkerTypeV2

Each worker maps to 1 DPU (4 vCPU, 16 GB of memory, 64 GB disk), and provides 1 executor per worker.

Suitable for memory-intensive jobs.

Returns:

  • (AWSCDK::StepFunctionsTasks::WorkerTypeV2) 


42
43
44
 
# File 'step_functions_tasks/worker_type_v2.rb', line 42

def self.G_1_X()
  Jsii::Kernel.instance.get_static("aws-cdk-lib.aws_stepfunctions_tasks.WorkerTypeV2", "G_1X")
end

.G_2_X ⇒ AWSCDK::StepFunctionsTasks::WorkerTypeV2

Each worker maps to 2 DPU (8 vCPU, 32 GB of memory, 128 GB disk), and provides 1 executor per worker.

Suitable for memory-intensive jobs.

Returns:

  • (AWSCDK::StepFunctionsTasks::WorkerTypeV2) 


51
52
53
 
# File 'step_functions_tasks/worker_type_v2.rb', line 51

def self.G_2_X()
  Jsii::Kernel.instance.get_static("aws-cdk-lib.aws_stepfunctions_tasks.WorkerTypeV2", "G_2X")
end

.G_4_X ⇒ AWSCDK::StepFunctionsTasks::WorkerTypeV2

Each worker maps to 4 DPU (16 vCPU, 64 GB of memory, 256 GB disk), and provides 1 executor per worker.

We recommend this worker type for jobs whose workloads contain your most demanding transforms, aggregations, joins, and queries. This worker type is available only for AWS Glue version 3.0 or later jobs.

Returns:

  • (AWSCDK::StepFunctionsTasks::WorkerTypeV2) 


60
61
62
 
# File 'step_functions_tasks/worker_type_v2.rb', line 60

def self.G_4_X()
  Jsii::Kernel.instance.get_static("aws-cdk-lib.aws_stepfunctions_tasks.WorkerTypeV2", "G_4X")
end

.G_8_X ⇒ AWSCDK::StepFunctionsTasks::WorkerTypeV2

Each worker maps to 8 DPU (32 vCPU, 128 GB of memory, 512 GB disk), and provides 1 executor per worker.

We recommend this worker type for jobs whose workloads contain your most demanding transforms, aggregations, joins, and queries. This worker type is available only for AWS Glue version 3.0 or later jobs.

Returns:

  • (AWSCDK::StepFunctionsTasks::WorkerTypeV2) 


69
70
71
 
# File 'step_functions_tasks/worker_type_v2.rb', line 69

def self.G_8_X()
  Jsii::Kernel.instance.get_static("aws-cdk-lib.aws_stepfunctions_tasks.WorkerTypeV2", "G_8X")
end

.jsii_overridable_methods ⇒ Object 



15
16
17
18
19
 
# File 'step_functions_tasks/worker_type_v2.rb', line 15

def self.jsii_overridable_methods
  {
    :name => { kind: :property, name: "name", is_optional: false },
  }
end

.of(worker_type) ⇒ AWSCDK::StepFunctionsTasks::WorkerTypeV2

Custom worker type.

Parameters:

  • worker_type (String) —

    custom worker type.

Returns:

  • (AWSCDK::StepFunctionsTasks::WorkerTypeV2) 


25
26
27
28
 
# File 'step_functions_tasks/worker_type_v2.rb', line 25

def self.of(worker_type)
  Jsii::Type.check_type(worker_type, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJzdHJpbmcifQ==")), "workerType")
  Jsii::Kernel.instance.call_static("aws-cdk-lib.aws_stepfunctions_tasks.WorkerTypeV2", "of", [worker_type])
end

.STANDARD ⇒ AWSCDK::StepFunctionsTasks::WorkerTypeV2

Each worker provides 4 vCPU, 16 GB of memory and a 50GB disk, and 2 executors per worker.

Returns:

  • (AWSCDK::StepFunctionsTasks::WorkerTypeV2) 


76
77
78
 
# File 'step_functions_tasks/worker_type_v2.rb', line 76

def self.STANDARD()
  Jsii::Kernel.instance.get_static("aws-cdk-lib.aws_stepfunctions_tasks.WorkerTypeV2", "STANDARD")
end

.Z_2_X ⇒ AWSCDK::StepFunctionsTasks::WorkerTypeV2

Each worker maps to 2 high-memory DPU M-DPU.

Supported in Ray jobs.

Returns:

  • (AWSCDK::StepFunctionsTasks::WorkerTypeV2) 


85
86
87
 
# File 'step_functions_tasks/worker_type_v2.rb', line 85

def self.Z_2_X()
  Jsii::Kernel.instance.get_static("aws-cdk-lib.aws_stepfunctions_tasks.WorkerTypeV2", "Z_2X")
end

Instance Method Details

#name ⇒ String

The name of this WorkerType, as expected by Job resource.

Returns:

  • (String) 


92
93
94
 
# File 'step_functions_tasks/worker_type_v2.rb', line 92

def name()
  jsii_get_property("name")
end