com.google.cloud.dataflow.sdk.util.common.worker

Class PartialGroupByKeyOperation.CombiningGroupingTable<K,InputT,AccumT>

java.lang.Object

com.google.cloud.dataflow.sdk.util.common.worker.PartialGroupByKeyOperation.CombiningGroupingTable<K,InputT,AccumT>

Enclosing class:

PartialGroupByKeyOperation

public static class PartialGroupByKeyOperation.CombiningGroupingTable<K,InputT,AccumT>
extends Object

A grouping table that uses the given combiner to combine values in place.

Constructor Summary

Constructors

Constructor and Description
CombiningGroupingTable(long maxSize, PartialGroupByKeyOperation.GroupingKeyCreator<? super K> groupingKeyCreator, PartialGroupByKeyOperation.PairInfo pairInfo, PartialGroupByKeyOperation.Combiner<? super K,InputT,AccumT,?> combineFn, PartialGroupByKeyOperation.SizeEstimator<? super K> keySizer, PartialGroupByKeyOperation.SizeEstimator<? super AccumT> accumulatorSizer)

Method Summary

Modifier and Type	Method and Description
com.google.cloud.dataflow.sdk.util.common.worker.PartialGroupByKeyOperation.GroupingTable.GroupingTableEntry<K,InputT,AccumT>	createTableEntry(K key)

Methods inherited from class java.lang.Object

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

Constructor Detail

CombiningGroupingTable

public CombiningGroupingTable(long maxSize,
                              PartialGroupByKeyOperation.GroupingKeyCreator<? super K> groupingKeyCreator,
                              PartialGroupByKeyOperation.PairInfo pairInfo,
                              PartialGroupByKeyOperation.Combiner<? super K,InputT,AccumT,?> combineFn,
                              PartialGroupByKeyOperation.SizeEstimator<? super K> keySizer,
                              PartialGroupByKeyOperation.SizeEstimator<? super AccumT> accumulatorSizer)

Method Detail

createTableEntry

public com.google.cloud.dataflow.sdk.util.common.worker.PartialGroupByKeyOperation.GroupingTable.GroupingTableEntry<K,InputT,AccumT> createTableEntry(K key)
                                                                                                                                               throws Exception

Throws:

Exception