class Google::Apis::DataflowV1b3::ParallelInstruction
Describes a particular operation comprising a MapTask
.
Attributes
An instruction that copies its inputs (zero or more) to its (single) output. Corresponds to the JSON property `flatten` @return [Google::Apis::DataflowV1b3::FlattenInstruction]
User-provided name of this operation. Corresponds to the JSON property `name` @return [String]
System-defined name for the operation in the original workflow graph. Corresponds to the JSON property `originalName` @return [String]
Describes the outputs of the instruction. Corresponds to the JSON property `outputs` @return [Array<Google::Apis::DataflowV1b3::InstructionOutput>]
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]
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]
An instruction that reads records. Takes no inputs, produces one output. Corresponds to the JSON property `read` @return [Google::Apis::DataflowV1b3::ReadInstruction]
System-defined name of this operation. Unique across the workflow. Corresponds to the JSON property `systemName` @return [String]
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
# File lib/google/apis/dataflow_v1b3/classes.rb, line 3248 def initialize(**args) update!(**args) end
Public Instance Methods
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