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

Constructors

Constructor and Description
KeyValueSourceMappingPhase(Collection<? extends KeyIn> keys, KeyPredicate<? super KeyIn> predicate)

Method Summary

Modifier and Type	Method and Description
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, processingPartitionNecessary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KeyValueSourceMappingPhase

public KeyValueSourceMappingPhase(Collection<? extends KeyIn> keys,
                                  KeyPredicate<? super 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>