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