class Google::Apis::DataflowV1b3::MapTask

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.

Attributes

counter_prefix[RW]

Counter prefix that can be used to prefix counters. Not currently used in Dataflow. Corresponds to the JSON property `counterPrefix` @return [String]

instructions[RW]

The instructions in the MapTask. Corresponds to the JSON property `instructions` @return [Array<Google::Apis::DataflowV1b3::ParallelInstruction>]

stage_name[RW]

System-defined name of the stage containing this MapTask. Unique across the workflow. Corresponds to the JSON property `stageName` @return [String]

system_name[RW]

System-defined name of this MapTask. Unique across the workflow. Corresponds to the JSON property `systemName` @return [String]

Public Class Methods

new(**args) click to toggle source
# File lib/google/apis/dataflow_v1b3/classes.rb, line 2846
def initialize(**args)
   update!(**args)
end

Public Instance Methods

update!(**args) click to toggle source

Update properties of this object

# File lib/google/apis/dataflow_v1b3/classes.rb, line 2851
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