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
2842 2843 2844 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2842 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
2793 2794 2795 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2793 def flatten @flatten end |
#name ⇒ String
User-provided name of this operation.
Corresponds to the JSON property name
2798 2799 2800 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2798 def name @name end |
#original_name ⇒ String
System-defined name for the operation in the original workflow graph.
Corresponds to the JSON property originalName
2803 2804 2805 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2803 def original_name @original_name end |
#outputs ⇒ Array<Google::Apis::DataflowV1b3::InstructionOutput>
Describes the outputs of the instruction.
Corresponds to the JSON property outputs
2808 2809 2810 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2808 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
2816 2817 2818 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2816 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
2822 2823 2824 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2822 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
2828 2829 2830 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2828 def read @read end |
#system_name ⇒ String
System-defined name of this operation.
Unique across the workflow.
Corresponds to the JSON property systemName
2834 2835 2836 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2834 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
2840 2841 2842 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2840 def write @write end |
Instance Method Details
#update!(**args) ⇒ Object
Update properties of this object
2847 2848 2849 2850 2851 2852 2853 2854 2855 2856 2857 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2847 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 |