Class: Google::Apis::DataflowV1b3::PartialGroupByKeyInstruction
- Inherits:
-
Object
- Object
- Google::Apis::DataflowV1b3::PartialGroupByKeyInstruction
- 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
An instruction that does a partial group-by-key. One input and one output.
Instance Attribute Summary collapse
-
#input ⇒ Google::Apis::DataflowV1b3::InstructionInput
An input of an instruction, as a reference to an output of a producer instruction.
-
#input_element_codec ⇒ Hash<String,Object>
The codec to use for interpreting an element in the input PTable.
-
#original_combine_values_input_store_name ⇒ String
If this instruction includes a combining function this is the name of the intermediate store between the GBK and the CombineValues.
-
#original_combine_values_step_name ⇒ String
If this instruction includes a combining function, this is the name of the CombineValues instruction lifted into this instruction.
-
#side_inputs ⇒ Array<Google::Apis::DataflowV1b3::SideInputInfo>
Zero or more side inputs.
-
#value_combining_fn ⇒ Hash<String,Object>
The value combining function to invoke.
Instance Method Summary collapse
-
#initialize(**args) ⇒ PartialGroupByKeyInstruction
constructor
A new instance of PartialGroupByKeyInstruction.
-
#update!(**args) ⇒ Object
Update properties of this object.
Methods included from Core::JsonObjectSupport
Methods included from Core::Hashable
Constructor Details
#initialize(**args) ⇒ PartialGroupByKeyInstruction
Returns a new instance of PartialGroupByKeyInstruction.
2907 2908 2909 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2907 def initialize(**args) update!(**args) end |
Instance Attribute Details
#input ⇒ Google::Apis::DataflowV1b3::InstructionInput
An input of an instruction, as a reference to an output of a producer
instruction.
Corresponds to the JSON property input
2878 2879 2880 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2878 def input @input end |
#input_element_codec ⇒ Hash<String,Object>
The codec to use for interpreting an element in the input PTable.
Corresponds to the JSON property inputElementCodec
2883 2884 2885 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2883 def input_element_codec @input_element_codec end |
#original_combine_values_input_store_name ⇒ String
If this instruction includes a combining function this is the name of the
intermediate store between the GBK and the CombineValues.
Corresponds to the JSON property originalCombineValuesInputStoreName
2905 2906 2907 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2905 def original_combine_values_input_store_name @original_combine_values_input_store_name end |
#original_combine_values_step_name ⇒ String
If this instruction includes a combining function, this is the name of the
CombineValues instruction lifted into this instruction.
Corresponds to the JSON property originalCombineValuesStepName
2899 2900 2901 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2899 def original_combine_values_step_name @original_combine_values_step_name end |
#side_inputs ⇒ Array<Google::Apis::DataflowV1b3::SideInputInfo>
Zero or more side inputs.
Corresponds to the JSON property sideInputs
2893 2894 2895 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2893 def side_inputs @side_inputs end |
#value_combining_fn ⇒ Hash<String,Object>
The value combining function to invoke.
Corresponds to the JSON property valueCombiningFn
2888 2889 2890 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2888 def value_combining_fn @value_combining_fn end |
Instance Method Details
#update!(**args) ⇒ Object
Update properties of this object
2912 2913 2914 2915 2916 2917 2918 2919 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2912 def update!(**args) @input = args[:input] if args.key?(:input) @input_element_codec = args[:input_element_codec] if args.key?(:input_element_codec) @value_combining_fn = args[:value_combining_fn] if args.key?(:value_combining_fn) @side_inputs = args[:side_inputs] if args.key?(:side_inputs) @original_combine_values_step_name = args[:original_combine_values_step_name] if args.key?(:original_combine_values_step_name) @original_combine_values_input_store_name = args[:original_combine_values_input_store_name] if args.key?(:original_combine_values_input_store_name) end |