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<KeyIn> keys, KeyPredicate<KeyIn> predicate)

Method Summary

Methods

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<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>