Uses of Class
com.hazelcast.mapreduce.KeyValueSource

Packages that use KeyValueSource

Package	Description
com.hazelcast.client.impl.protocol.task.mapreduce	Client protocol tasks implementations for map reduce
com.hazelcast.client.proxy	This package contains client side proxy implementations of the different Hazelcast data structures and operation types
com.hazelcast.mapreduce	This package contains the MapReduce API definition for Hazelcast. All map reduce operations running in a distributed manner inside the active Hazelcast cluster.
com.hazelcast.mapreduce.impl	This package contains the default implementation for the map reduce framework internals.
com.hazelcast.mapreduce.impl.client	This package contains request and response classes for communication between cluster members and Hazelcast native clients
com.hazelcast.mapreduce.impl.operation	This package contains all remote operations that are needed to control work on supervising or worker nodes.
com.hazelcast.mapreduce.impl.task	This package contains the base implementation for a standard map reduce job.

Uses of KeyValueSource in com.hazelcast.client.impl.protocol.task.mapreduce

Methods in com.hazelcast.client.impl.protocol.task.mapreduce that return KeyValueSource

Modifier and Type	Method and Description
protected KeyValueSource	MapReduceForMapMessageTask.getKeyValueSource()
protected KeyValueSource	MapReduceForSetMessageTask.getKeyValueSource()
protected abstract KeyValueSource	AbstractMapReduceTask.getKeyValueSource()
protected KeyValueSource	MapReduceForCustomMessageTask.getKeyValueSource()
protected KeyValueSource	MapReduceForListMessageTask.getKeyValueSource()
protected KeyValueSource	MapReduceForMultiMapMessageTask.getKeyValueSource()

Uses of KeyValueSource in com.hazelcast.client.proxy

Methods in com.hazelcast.client.proxy with parameters of type KeyValueSource

Modifier and Type	Method and Description
<K,V> Job<K,V>	ClientMapReduceProxy.newJob(KeyValueSource<K,V> source)

Uses of KeyValueSource in com.hazelcast.mapreduce

Methods in com.hazelcast.mapreduce that return KeyValueSource

Modifier and Type	Method and Description
static <V> KeyValueSource<String,V>	KeyValueSource.fromList(IList<? extends V> list) A helper method to build a KeyValueSource implementation based on the specified IList. The key returned by this KeyValueSource implementation is ALWAYS the name of the list itself, whereas the value are the entries of the list, one by one.
static <K,V> KeyValueSource<K,V>	KeyValueSource.fromMap(IMap<? super K,? extends V> map) A helper method to build a KeyValueSource implementation based on the specified IMap
static <K,V> KeyValueSource<K,V>	KeyValueSource.fromMultiMap(MultiMap<? super K,? extends V> multiMap) A helper method to build a KeyValueSource implementation based on the specified MultiMap
static <V> KeyValueSource<String,V>	KeyValueSource.fromSet(ISet<? extends V> set) A helper method to build a KeyValueSource implementation based on the specified ISet. The key returned by this KeyValueSource implementation is ALWAYS the name of the set itself, whereas the value are the entries of the set, one by one.

Methods in com.hazelcast.mapreduce with parameters of type KeyValueSource

Modifier and Type	Method and Description
<K,V> Job<K,V>	JobTracker.newJob(KeyValueSource<K,V> source) Builds a Job instance for the given KeyValueSource instance.

Uses of KeyValueSource in com.hazelcast.mapreduce.impl

Subclasses of KeyValueSource in com.hazelcast.mapreduce.impl

Modifier and Type	Class and Description
class	ListKeyValueSource<V> This KeyValueSource implementation is used in fromList(com.hazelcast.core.IList) to generate a default implementation based on a Hazelcast IList.
class	MapKeyValueSource<K,V> This KeyValueSource implementation is used in fromMap(com.hazelcast.core.IMap) to generate a default implementation based on a Hazelcast IMap.
class	MultiMapKeyValueSource<K,V> This KeyValueSource implementation is used in fromMultiMap(com.hazelcast.core.MultiMap) to generate a default implementation based on a Hazelcast MultiMap.
class	SetKeyValueSource<V> This KeyValueSource implementation is used in fromSet(com.hazelcast.core.ISet) to generate a default implementation based on a Hazelcast ISet.

Fields in com.hazelcast.mapreduce.impl declared as KeyValueSource

Modifier and Type	Field and Description
protected KeyValueSource<KeyIn,ValueIn>	AbstractJob.keyValueSource

Constructors in com.hazelcast.mapreduce.impl with parameters of type KeyValueSource

Constructor and Description
AbstractJob(String name, JobTracker jobTracker, KeyValueSource<KeyIn,ValueIn> keyValueSource)

Uses of KeyValueSource in com.hazelcast.mapreduce.impl.client

Fields in com.hazelcast.mapreduce.impl.client declared as KeyValueSource

Modifier and Type	Field and Description
protected KeyValueSource	ClientMapReduceRequest.keyValueSource

Constructors in com.hazelcast.mapreduce.impl.client with parameters of type KeyValueSource

Constructor and Description
ClientMapReduceRequest(String name, String jobId, Collection keys, KeyPredicate predicate, Mapper mapper, CombinerFactory combinerFactory, ReducerFactory reducerFactory, KeyValueSource keyValueSource, int chunkSize, TopologyChangedStrategy topologyChangedStrategy)

Uses of KeyValueSource in com.hazelcast.mapreduce.impl.operation

Constructors in com.hazelcast.mapreduce.impl.operation with parameters of type KeyValueSource

Constructor and Description
KeyValueJobOperation(String name, String jobId, int chunkSize, KeyValueSource<K,V> keyValueSource, Mapper mapper, CombinerFactory combinerFactory, ReducerFactory reducerFactory, boolean communicateStats, TopologyChangedStrategy topologyChangedStrategy)

Uses of KeyValueSource in com.hazelcast.mapreduce.impl.task

Methods in com.hazelcast.mapreduce.impl.task that return KeyValueSource

Modifier and Type	Method and Description
KeyValueSource	JobTaskConfiguration.getKeyValueSource()

Methods in com.hazelcast.mapreduce.impl.task with parameters of type KeyValueSource

Modifier and Type	Method and Description
void	KeyValueSourceMappingPhase.executeMappingPhase(KeyValueSource<KeyIn,ValueIn> keyValueSource, Mapper<KeyIn,ValueIn,KeyOut,ValueOut> mapper, Context<KeyOut,ValueOut> context)
protected abstract void	MappingPhase.executeMappingPhase(KeyValueSource<KeyIn,ValueIn> keyValueSource, Mapper<KeyIn,ValueIn,KeyOut,ValueOut> mapper, Context<KeyOut,ValueOut> context)
void	MapCombineTask.processMapping(int partitionId, DefaultContext<KeyOut,ValueOut> context, KeyValueSource<KeyIn,ValueIn> keyValueSource, boolean partitionProcessor)

Constructors in com.hazelcast.mapreduce.impl.task with parameters of type KeyValueSource

Constructor and Description
JobTaskConfiguration(Address jobOwner, NodeEngine nodeEngine, int chunkSize, String name, String jobId, Mapper mapper, CombinerFactory combinerFactory, ReducerFactory reducerFactory, KeyValueSource keyValueSource, boolean communicateStats, TopologyChangedStrategy topologyChangedStrategy)
KeyValueJob(String name, AbstractJobTracker jobTracker, NodeEngine nodeEngine, MapReduceService mapReduceService, KeyValueSource<KeyIn,ValueIn> keyValueSource)