K
- type of key.N
- type of namespace.S
- type of state value.@VisibleForTesting protected static class CopyOnWriteStateTableSnapshot.StateTableKeyGroupPartitioner<K,N,S> extends KeyGroupPartitioner<CopyOnWriteStateTable.StateTableEntry<K,N,S>>
KeyGroupPartitioner
for CopyOnWriteStateTable
. This class
swaps input and output in reportAllElementKeyGroups()
for performance reasons, so that we can reuse
the non-flattened original snapshot array as partitioning output.KeyGroupPartitioner.ElementReaderFunction<T>, KeyGroupPartitioner.ElementWriterFunction<T>, KeyGroupPartitioner.KeyGroupElementsConsumer<T>
computedResult, counterHistogram, elementKeyGroups, elementWriterFunction, firstKeyGroup, keyExtractorFunction, keyGroupRange, numberOfElements, partitioningDestination, partitioningSource, totalKeyGroups
Modifier and Type | Method and Description |
---|---|
protected void |
reportAllElementKeyGroups()
This method iterates over the input data and reports the key-group for each element.
|
createKeyGroupPartitionReader, partitionByKeyGroup, reportKeyGroupOfElementAtIndex
protected void reportAllElementKeyGroups()
KeyGroupPartitioner
reportAllElementKeyGroups
in class KeyGroupPartitioner<CopyOnWriteStateTable.StateTableEntry<K,N,S>>
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.