com.hazelcast.mapreduce.impl.task
Class KeyValueSourceMappingPhase<KeyIn,ValueIn,KeyOut,ValueOut>

java.lang.Object
  extended by com.hazelcast.mapreduce.impl.task.MappingPhase<KeyIn,ValueIn,KeyOut,ValueOut>
      extended by com.hazelcast.mapreduce.impl.task.KeyValueSourceMappingPhase<KeyIn,ValueIn,KeyOut,ValueOut>
Type Parameters:
KeyIn - type of the input key
ValueIn - type of the input value
KeyOut - type of the emitted key
ValueOut - type of the emitted value

public class KeyValueSourceMappingPhase<KeyIn,ValueIn,KeyOut,ValueOut>
extends MappingPhase<KeyIn,ValueIn,KeyOut,ValueOut>

This class executes the mapping phase for a given KeyValueSource scope.


Constructor Summary
KeyValueSourceMappingPhase(Collection<KeyIn> keys, KeyPredicate<KeyIn> predicate)
           
 
Method Summary
 void executeMappingPhase(KeyValueSource<KeyIn,ValueIn> keyValueSource, Mapper<KeyIn,ValueIn,KeyOut,ValueOut> mapper, Context<KeyOut,ValueOut> context)
           
 
Methods inherited from class com.hazelcast.mapreduce.impl.task.MappingPhase
cancel, isCancelled, matches
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

KeyValueSourceMappingPhase

public KeyValueSourceMappingPhase(Collection<KeyIn> keys,
                                  KeyPredicate<KeyIn> predicate)
Method Detail

executeMappingPhase

public void executeMappingPhase(KeyValueSource<KeyIn,ValueIn> keyValueSource,
                                Mapper<KeyIn,ValueIn,KeyOut,ValueOut> mapper,
                                Context<KeyOut,ValueOut> context)
Specified by:
executeMappingPhase in class MappingPhase<KeyIn,ValueIn,KeyOut,ValueOut>


Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.