KeyIn
- type of the input keyValueIn
- type of the input valueKeyOut
- type of the emitted keyValueOut
- type of the emitted valuepublic abstract class MappingPhase<KeyIn,ValueIn,KeyOut,ValueOut> extends Object
KeyPredicate
implementations.Constructor and Description |
---|
MappingPhase(Collection<? extends KeyIn> keys,
KeyPredicate<? super KeyIn> predicate) |
Modifier and Type | Method and Description |
---|---|
void |
cancel() |
protected abstract void |
executeMappingPhase(KeyValueSource<KeyIn,ValueIn> keyValueSource,
Mapper<KeyIn,ValueIn,KeyOut,ValueOut> mapper,
Context<KeyOut,ValueOut> context) |
protected boolean |
isCancelled() |
protected boolean |
matches(KeyIn key) |
protected boolean |
processingPartitionNecessary(int partitionId,
InternalPartitionService partitionService) |
public MappingPhase(Collection<? extends KeyIn> keys, KeyPredicate<? super KeyIn> predicate)
public void cancel()
protected boolean isCancelled()
protected boolean processingPartitionNecessary(int partitionId, InternalPartitionService partitionService)
protected boolean matches(KeyIn key)
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.