KeyIn
- ValueIn
- public class DefaultContext<KeyIn,ValueIn> extends Object implements Context<KeyIn,ValueIn>
Combiner
or by utilizing the internal
collecting combiner (which is just a better HashMap ;-)).MapCombineTask
about an emitted value to eventually send out chunks on reaching the chunk size limit.Modifier | Constructor and Description |
---|---|
protected |
DefaultContext(CombinerFactory<KeyIn,ValueIn,?> combinerFactory,
MapCombineTask mapCombineTask) |
Modifier and Type | Method and Description |
---|---|
void |
emit(KeyIn key,
ValueIn value)
Emits a key-value pair to the intermediate working space.
|
void |
finalizeCombiners() |
int |
getCollected() |
Combiner<ValueIn,?> |
getOrCreateCombiner(KeyIn key) |
<Chunk> Map<KeyIn,Chunk> |
requestChunk() |
void |
setPartitionId(int partitionId) |
protected DefaultContext(CombinerFactory<KeyIn,ValueIn,?> combinerFactory, MapCombineTask mapCombineTask)
public void setPartitionId(int partitionId)
public void emit(KeyIn key, ValueIn value)
Context
public int getCollected()
public void finalizeCombiners()
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.