class Google::Apis::DataflowV1b3::ParallelInstruction

Describes a particular operation comprising a MapTask.

Attributes

flatten[RW]

An instruction that copies its inputs (zero or more) to its (single) output. Corresponds to the JSON property `flatten` @return [Google::Apis::DataflowV1b3::FlattenInstruction]

name[RW]

User-provided name of this operation. Corresponds to the JSON property `name` @return [String]

original_name[RW]

System-defined name for the operation in the original workflow graph. Corresponds to the JSON property `originalName` @return [String]

outputs[RW]

Describes the outputs of the instruction. Corresponds to the JSON property `outputs` @return [Array<Google::Apis::DataflowV1b3::InstructionOutput>]

par_do[RW]

An instruction that does a ParDo operation. Takes one main input and zero or more side inputs, and produces zero or more outputs. Runs user code. Corresponds to the JSON property `parDo` @return [Google::Apis::DataflowV1b3::ParDoInstruction]

partial_group_by_key[RW]

An instruction that does a partial group-by-key. One input and one output. Corresponds to the JSON property `partialGroupByKey` @return [Google::Apis::DataflowV1b3::PartialGroupByKeyInstruction]

read[RW]

An instruction that reads records. Takes no inputs, produces one output. Corresponds to the JSON property `read` @return [Google::Apis::DataflowV1b3::ReadInstruction]

system_name[RW]

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

write[RW]

An instruction that writes records. Takes one input, produces no outputs. Corresponds to the JSON property `write` @return [Google::Apis::DataflowV1b3::WriteInstruction]

Public Class Methods

new(**args) click to toggle source
# File lib/google/apis/dataflow_v1b3/classes.rb, line 3248
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 3253
def update!(**args)
  @flatten = args[:flatten] if args.key?(:flatten)
  @name = args[:name] if args.key?(:name)
  @original_name = args[:original_name] if args.key?(:original_name)
  @outputs = args[:outputs] if args.key?(:outputs)
  @par_do = args[:par_do] if args.key?(:par_do)
  @partial_group_by_key = args[:partial_group_by_key] if args.key?(:partial_group_by_key)
  @read = args[:read] if args.key?(:read)
  @system_name = args[:system_name] if args.key?(:system_name)
  @write = args[:write] if args.key?(:write)
end