com.google.cloud.dataflow.sdk.transforms

Interface Combine.AccumulatingCombineFn.Accumulator<VI,VA,VO>

Enclosing class:

Combine.AccumulatingCombineFn<VI,VA extends Combine.AccumulatingCombineFn.Accumulator<VI,VA,VO>,VO>

public static interface Combine.AccumulatingCombineFn.Accumulator<VI,VA,VO>

The type of mutable accumulator values used by this AccumulatingCombineFn.

Method Summary

Methods

Modifier and Type	Method and Description
void	addInput(VI input) Adds the given input value to this accumulator, modifying this accumulator.
VO	extractOutput() Returns the output value that is the result of combining all the input values represented by this accumulator.
void	mergeAccumulator(VA other) Adds the input values represented by the given accumulator into this accumulator.

Method Detail

addInput

void addInput(VI input)

Adds the given input value to this accumulator, modifying this accumulator.

mergeAccumulator

void mergeAccumulator(VA other)

Adds the input values represented by the given accumulator into this accumulator.

extractOutput

VO extractOutput()

Returns the output value that is the result of combining all the input values represented by this accumulator.