Class: Google::Apis::DataflowV1b3::MapTask
- Inherits:
-
Object
- Object
- Google::Apis::DataflowV1b3::MapTask
- Includes:
- Core::Hashable, Core::JsonObjectSupport
- Defined in:
- generated/google/apis/dataflow_v1b3/classes.rb,
generated/google/apis/dataflow_v1b3/representations.rb,
generated/google/apis/dataflow_v1b3/representations.rb
Overview
MapTask consists of an ordered set of instructions, each of which describes one particular low-level operation for the worker to perform in order to accomplish the MapTask's WorkItem. Each instruction must appear in the list before any instructions which depends on its output.
Instance Attribute Summary collapse
-
#counter_prefix ⇒ String
Counter prefix that can be used to prefix counters.
-
#instructions ⇒ Array<Google::Apis::DataflowV1b3::ParallelInstruction>
The instructions in the MapTask.
-
#stage_name ⇒ String
System-defined name of the stage containing this MapTask.
-
#system_name ⇒ String
System-defined name of this MapTask.
Instance Method Summary collapse
-
#initialize(**args) ⇒ MapTask
constructor
A new instance of MapTask.
-
#update!(**args) ⇒ Object
Update properties of this object.
Methods included from Core::JsonObjectSupport
Methods included from Core::Hashable
Constructor Details
#initialize(**args) ⇒ MapTask
Returns a new instance of MapTask.
2575 2576 2577 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2575 def initialize(**args) update!(**args) end |
Instance Attribute Details
#counter_prefix ⇒ String
Counter prefix that can be used to prefix counters. Not currently used in
Dataflow.
Corresponds to the JSON property counterPrefix
2556 2557 2558 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2556 def counter_prefix @counter_prefix end |
#instructions ⇒ Array<Google::Apis::DataflowV1b3::ParallelInstruction>
The instructions in the MapTask.
Corresponds to the JSON property instructions
2561 2562 2563 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2561 def instructions @instructions end |
#stage_name ⇒ String
System-defined name of the stage containing this MapTask.
Unique across the workflow.
Corresponds to the JSON property stageName
2567 2568 2569 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2567 def stage_name @stage_name end |
#system_name ⇒ String
System-defined name of this MapTask.
Unique across the workflow.
Corresponds to the JSON property systemName
2573 2574 2575 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2573 def system_name @system_name end |
Instance Method Details
#update!(**args) ⇒ Object
Update properties of this object
2580 2581 2582 2583 2584 2585 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2580 def update!(**args) @counter_prefix = args[:counter_prefix] if args.key?(:counter_prefix) @instructions = args[:instructions] if args.key?(:instructions) @stage_name = args[:stage_name] if args.key?(:stage_name) @system_name = args[:system_name] if args.key?(:system_name) end |