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

java.lang.Object
  com.hazelcast.mapreduce.impl.task.MappingPhase<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

Direct Known Subclasses:

KeyValueSourceMappingPhase

public abstract class MappingPhase<KeyIn,ValueIn,KeyOut,ValueOut>
extends Object

This is the base of all mapping phase implementations. It's responsibility is to test keys prior to mapping the special value. This is used for preselected key-sets and given KeyPredicate implementations.

Constructor Summary

MappingPhase(Collection<KeyIn> keys, KeyPredicate<KeyIn> predicate)

Method Summary

void	cancel()
protected abstract void	executeMappingPhase(KeyValueSource<KeyIn,ValueIn> keyValueSource, Mapper<KeyIn,ValueIn,KeyOut,ValueOut> mapper, Context<KeyOut,ValueOut> context)
protected boolean	isCancelled()
protected boolean	matches(KeyIn key)

Methods inherited from class java.lang.Object

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

Constructor Detail

MappingPhase

public MappingPhase(Collection<KeyIn> keys,
                    KeyPredicate<KeyIn> predicate)

Method Detail

cancel

public void cancel()

isCancelled

protected boolean isCancelled()

matches

protected boolean matches(KeyIn key)

executeMappingPhase

protected abstract void executeMappingPhase(KeyValueSource<KeyIn,ValueIn> keyValueSource,
                                            Mapper<KeyIn,ValueIn,KeyOut,ValueOut> mapper,
                                            Context<KeyOut,ValueOut> context)