Class: Google::Apis::DataflowV1b3::PartialGroupByKeyInstruction

Inherits:
Object
  • Object
show all
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

Instance Method Summary collapse

Methods included from Core::JsonObjectSupport

#to_json

Methods included from Core::Hashable

process_value, #to_h

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

Returns:



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

Returns:

  • (Hash<String,Object>) 


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

Returns:

  • (String) 


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

Returns:

  • (String) 


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

Returns:



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

Returns:

  • (Hash<String,Object>) 


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