class Google::Apis::DataflowV1b3::PartialGroupByKeyInstruction

An instruction that does a partial group-by-key. One input and one output.

Attributes

input[RW]

An input of an instruction, as a reference to an output of a producer instruction. Corresponds to the JSON property `input` @return [Google::Apis::DataflowV1b3::InstructionInput]

input_element_codec[RW]

The codec to use for interpreting an element in the input PTable. Corresponds to the JSON property `inputElementCodec` @return [Hash<String,Object>]

original_combine_values_input_store_name[RW]

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` @return [String]

original_combine_values_step_name[RW]

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` @return [String]

side_inputs[RW]

Zero or more side inputs. Corresponds to the JSON property `sideInputs` @return [Array<Google::Apis::DataflowV1b3::SideInputInfo>]

value_combining_fn[RW]

The value combining function to invoke. Corresponds to the JSON property `valueCombiningFn` @return [Hash<String,Object>]

Public Class Methods

new(**args) click to toggle source
# File lib/google/apis/dataflow_v1b3/classes.rb, line 3384
def initialize(**args)
   update!(**args)
end

Public Instance Methods

update!(**args) click to toggle source

Update properties of this object

# File lib/google/apis/dataflow_v1b3/classes.rb, line 3389
def update!(**args)
  @input = args[:input] if args.key?(:input)
  @input_element_codec = args[:input_element_codec] if args.key?(:input_element_codec)
  @original_combine_values_input_store_name = args[:original_combine_values_input_store_name] if args.key?(:original_combine_values_input_store_name)
  @original_combine_values_step_name = args[:original_combine_values_step_name] if args.key?(:original_combine_values_step_name)
  @side_inputs = args[:side_inputs] if args.key?(:side_inputs)
  @value_combining_fn = args[:value_combining_fn] if args.key?(:value_combining_fn)
end