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

java.lang.Object
  com.hazelcast.mapreduce.impl.task.MappingPhase<KeyIn,ValueIn,KeyOut,ValueOut>
      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>