Class: Google::Apis::DataflowV1b3::ParallelInstruction
- Inherits:
-
Object
- Object
- Google::Apis::DataflowV1b3::ParallelInstruction
- 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
Describes a particular operation comprising a MapTask.
Instance Attribute Summary collapse
-
#flatten ⇒ Google::Apis::DataflowV1b3::FlattenInstruction
An instruction that copies its inputs (zero or more) to its (single) output.
-
#name ⇒ String
User-provided name of this operation.
-
#original_name ⇒ String
System-defined name for the operation in the original workflow graph.
-
#outputs ⇒ Array<Google::Apis::DataflowV1b3::InstructionOutput>
Describes the outputs of the instruction.
-
#par_do ⇒ Google::Apis::DataflowV1b3::ParDoInstruction
An instruction that does a ParDo operation.
-
#partial_group_by_key ⇒ Google::Apis::DataflowV1b3::PartialGroupByKeyInstruction
An instruction that does a partial group-by-key.
-
#read ⇒ Google::Apis::DataflowV1b3::ReadInstruction
An instruction that reads records.
-
#system_name ⇒ String
System-defined name of this operation.
-
#write ⇒ Google::Apis::DataflowV1b3::WriteInstruction
An instruction that writes records.
Instance Method Summary collapse
-
#initialize(**args) ⇒ ParallelInstruction
constructor
A new instance of ParallelInstruction.
-
#update!(**args) ⇒ Object
Update properties of this object.
Methods included from Core::JsonObjectSupport
Methods included from Core::Hashable
Constructor Details
#initialize(**args) ⇒ ParallelInstruction
Returns a new instance of ParallelInstruction.
2960 2961 2962 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2960 def initialize(**args) update!(**args) end |
Instance Attribute Details
#flatten ⇒ Google::Apis::DataflowV1b3::FlattenInstruction
An instruction that copies its inputs (zero or more) to its (single) output.
Corresponds to the JSON property flatten
2911 2912 2913 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2911 def flatten @flatten end |
#name ⇒ String
User-provided name of this operation.
Corresponds to the JSON property name
2916 2917 2918 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2916 def name @name end |
#original_name ⇒ String
System-defined name for the operation in the original workflow graph.
Corresponds to the JSON property originalName
2921 2922 2923 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2921 def original_name @original_name end |
#outputs ⇒ Array<Google::Apis::DataflowV1b3::InstructionOutput>
Describes the outputs of the instruction.
Corresponds to the JSON property outputs
2926 2927 2928 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2926 def outputs @outputs end |
#par_do ⇒ Google::Apis::DataflowV1b3::ParDoInstruction
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
2934 2935 2936 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2934 def par_do @par_do end |
#partial_group_by_key ⇒ Google::Apis::DataflowV1b3::PartialGroupByKeyInstruction
An instruction that does a partial group-by-key.
One input and one output.
Corresponds to the JSON property partialGroupByKey
2940 2941 2942 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2940 def partial_group_by_key @partial_group_by_key end |
#read ⇒ Google::Apis::DataflowV1b3::ReadInstruction
An instruction that reads records.
Takes no inputs, produces one output.
Corresponds to the JSON property read
2946 2947 2948 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2946 def read @read end |
#system_name ⇒ String
System-defined name of this operation.
Unique across the workflow.
Corresponds to the JSON property systemName
2952 2953 2954 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2952 def system_name @system_name end |
#write ⇒ Google::Apis::DataflowV1b3::WriteInstruction
An instruction that writes records.
Takes one input, produces no outputs.
Corresponds to the JSON property write
2958 2959 2960 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2958 def write @write end |
Instance Method Details
#update!(**args) ⇒ Object
Update properties of this object
2965 2966 2967 2968 2969 2970 2971 2972 2973 2974 2975 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2965 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 |