GoogleApi.Dataflow.V1b3.Model.PartialGroupByKeyInstruction (google_api_dataflow v0.39.0) View Source

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

Attributes

input (type: GoogleApi.Dataflow.V1b3.Model.InstructionInput.t, default: nil) - Describes the input to the partial group-by-key instruction.
inputElementCodec (type: map(), default: nil) - The codec to use for interpreting an element in the input PTable.
originalCombineValuesInputStoreName (type: String.t, default: nil) - If this instruction includes a combining function this is the name of the intermediate store between the GBK and the CombineValues.
originalCombineValuesStepName (type: String.t, default: nil) - If this instruction includes a combining function, this is the name of the CombineValues instruction lifted into this instruction.
sideInputs (type: list(GoogleApi.Dataflow.V1b3.Model.SideInputInfo.t), default: nil) - Zero or more side inputs.
valueCombiningFn (type: map(), default: nil) - The value combining function to invoke.

Link to this section Summary

Types

t()

Functions

decode(value, options)

Unwrap a decoded JSON object into its complex fields.

Link to this section Types

t()

Specs

t() :: %GoogleApi.Dataflow.V1b3.Model.PartialGroupByKeyInstruction{
  input: GoogleApi.Dataflow.V1b3.Model.InstructionInput.t() | nil,
  inputElementCodec: map() | nil,
  originalCombineValuesInputStoreName: String.t() | nil,
  originalCombineValuesStepName: String.t() | nil,
  sideInputs: [GoogleApi.Dataflow.V1b3.Model.SideInputInfo.t()] | nil,
  valueCombiningFn: map() | nil
}

Link to this section Functions

decode(value, options)

Specs

decode(struct(), keyword()) :: struct()

Unwrap a decoded JSON object into its complex fields.