Interface CombineFn<I, A, O>

An interface for performing possibly distributed, commutative, associative combines (such as sum) to a set of values (e.g. in groupBy(...).combining(...).

Several implementations (such as summation) are provided in the combiners module.

See also https://beam.apache.org/documentation/programming-guide/#transforms

Type Parameters

  • I

  • A

  • O

Hierarchy

  • CombineFn

Properties

addInput: ((A: any, I: any) => A)

Type declaration

    • (A: any, I: any): A
    • Parameters

      • A: any
      • I: any

      Returns A

createAccumulator: (() => A)

Type declaration

    • (): A
    • Returns A

extractOutput: ((A: any) => O)

Type declaration

    • (A: any): O
    • Parameters

      • A: any

      Returns O

mergeAccumulators: ((accumulators: Iterable<A>) => A)

Type declaration

    • (accumulators: Iterable<A>): A
    • Parameters

      • accumulators: Iterable<A>

      Returns A

Methods

Generated using TypeDoc