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

Class PartialGroupByKeyOperation.BufferingGroupingTable<K,V>

java.lang.Object

com.google.cloud.dataflow.sdk.util.common.worker.PartialGroupByKeyOperation.BufferingGroupingTable<K,V>

Enclosing class:

PartialGroupByKeyOperation

public static class PartialGroupByKeyOperation.BufferingGroupingTable<K,V>
extends Object

A grouping table that simply buffers all inserted values in a list.

Field Summary

Fields

Modifier and Type	Field and Description
PartialGroupByKeyOperation.SizeEstimator<? super K>	keySizer
PartialGroupByKeyOperation.SizeEstimator<? super V>	valueSizer

Constructor Summary

Constructors

Constructor and Description
BufferingGroupingTable(long maxSize, PartialGroupByKeyOperation.GroupingKeyCreator<? super K> groupingKeyCreator, PartialGroupByKeyOperation.PairInfo pairInfo, PartialGroupByKeyOperation.SizeEstimator<? super K> keySizer, PartialGroupByKeyOperation.SizeEstimator<? super V> valueSizer)

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Detail

keySizer

public final PartialGroupByKeyOperation.SizeEstimator<? super K> keySizer

valueSizer

public final PartialGroupByKeyOperation.SizeEstimator<? super V> valueSizer

Constructor Detail

BufferingGroupingTable

public BufferingGroupingTable(long maxSize,
                              PartialGroupByKeyOperation.GroupingKeyCreator<? super K> groupingKeyCreator,
                              PartialGroupByKeyOperation.PairInfo pairInfo,
                              PartialGroupByKeyOperation.SizeEstimator<? super K> keySizer,
                              PartialGroupByKeyOperation.SizeEstimator<? super V> valueSizer)

Method Detail

createTableEntry

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

Throws:

Exception