com.google.cloud.dataflow.sdk.runners.worker

Class MapTaskExecutorFactory.ValueCombiner<K,InputT,AccumT,OutputT>

java.lang.Object

com.google.cloud.dataflow.sdk.runners.worker.MapTaskExecutorFactory.ValueCombiner<K,InputT,AccumT,OutputT>

All Implemented Interfaces:

PartialGroupByKeyOperation.Combiner<WindowedValue<K>,InputT,AccumT,OutputT>

Enclosing class:

MapTaskExecutorFactory

public static class MapTaskExecutorFactory.ValueCombiner<K,InputT,AccumT,OutputT>
extends Object
implements PartialGroupByKeyOperation.Combiner<WindowedValue<K>,InputT,AccumT,OutputT>

Implements PGBKOp.Combiner via Combine.KeyedCombineFn.

Method Summary

Modifier and Type	Method and Description
AccumT	add(WindowedValue<K> windowedKey, AccumT accumulator, InputT value)
AccumT	createAccumulator(WindowedValue<K> windowedKey)
OutputT	extract(WindowedValue<K> windowedKey, AccumT accumulator)
AccumT	merge(WindowedValue<K> windowedKey, Iterable<AccumT> accumulators)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

createAccumulator

public AccumT createAccumulator(WindowedValue<K> windowedKey)

Specified by:

createAccumulator in interface PartialGroupByKeyOperation.Combiner<WindowedValue<K>,InputT,AccumT,OutputT>

add

public AccumT add(WindowedValue<K> windowedKey,
                  AccumT accumulator,
                  InputT value)

Specified by:

add in interface PartialGroupByKeyOperation.Combiner<WindowedValue<K>,InputT,AccumT,OutputT>

merge

public AccumT merge(WindowedValue<K> windowedKey,
                    Iterable<AccumT> accumulators)

Specified by:

merge in interface PartialGroupByKeyOperation.Combiner<WindowedValue<K>,InputT,AccumT,OutputT>

extract

public OutputT extract(WindowedValue<K> windowedKey,
                       AccumT accumulator)

Specified by:

extract in interface PartialGroupByKeyOperation.Combiner<WindowedValue<K>,InputT,AccumT,OutputT>