Uses of Interface
com.hazelcast.mapreduce.ReducingJob

Packages that use ReducingJob
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. 
 

Uses of ReducingJob in com.hazelcast.mapreduce
 

Methods in com.hazelcast.mapreduce that return ReducingJob
 ReducingJob<EntryKey,KeyIn,ValueIn> ReducingJob.chunkSize(int chunkSize)
          Defines the number of elements per chunk.
<ValueOut> ReducingJob<EntryKey,KeyIn,ValueOut>
MappingJob.combiner(CombinerFactory<KeyIn,ValueIn,ValueOut> combinerFactory)
          Defines the CombinerFactory for this task.
 ReducingJob<EntryKey,KeyIn,ValueIn> ReducingJob.keyPredicate(KeyPredicate<EntryKey> predicate)
          Defines the KeyPredicate implementation to preselect keys the MapReduce task will be executed on.
 ReducingJob<EntryKey,KeyIn,ValueIn> ReducingJob.onKeys(EntryKey... keys)
          Defines keys to execute the mapper and a possibly defined reducer against.
 ReducingJob<EntryKey,KeyIn,ValueIn> ReducingJob.onKeys(Iterable<EntryKey> keys)
          Defines keys to execute the mapper and a possibly defined reducer against.
 ReducingJob<EntryKey,KeyIn,ValueIn> ReducingJob.topologyChangedStrategy(TopologyChangedStrategy topologyChangedStrategy)
          Defines the strategy to handle topology changes while executing the map reduce job.
 

Uses of ReducingJob in com.hazelcast.mapreduce.impl
 

Classes in com.hazelcast.mapreduce.impl that implement ReducingJob
protected  class AbstractJob.ReducingJobImpl<EntryKey,Key,Value>
          This class is just used to comply to the public DSL style API
 

Methods in com.hazelcast.mapreduce.impl that return ReducingJob
 ReducingJob<EntryKey,Key,Value> AbstractJob.ReducingJobImpl.chunkSize(int chunkSize)
           
<ValueOut> ReducingJob<EntryKey,Key,ValueOut>
AbstractJob.MappingJobImpl.combiner(CombinerFactory<Key,Value,ValueOut> combinerFactory)
           
 ReducingJob<EntryKey,Key,Value> AbstractJob.ReducingJobImpl.keyPredicate(KeyPredicate<EntryKey> predicate)
           
 ReducingJob<EntryKey,Key,Value> AbstractJob.ReducingJobImpl.onKeys(EntryKey... keys)
           
 ReducingJob<EntryKey,Key,Value> AbstractJob.ReducingJobImpl.onKeys(Iterable<EntryKey> keys)
           
 ReducingJob<EntryKey,Key,Value> AbstractJob.ReducingJobImpl.topologyChangedStrategy(TopologyChangedStrategy topologyChangedStrategy)
           
 



Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.