Package | Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
ReducingSubmittableJob<EntryKey,KeyIn,ValueIn> |
ReducingSubmittableJob.chunkSize(int chunkSize)
Defines the number of elements per chunk.
|
ReducingSubmittableJob<EntryKey,KeyIn,ValueIn> |
ReducingSubmittableJob.keyPredicate(KeyPredicate<EntryKey> predicate)
Defines the
KeyPredicate implementation to preselect keys the MapReduce task
will be executed on. |
ReducingSubmittableJob<EntryKey,KeyIn,ValueIn> |
ReducingSubmittableJob.onKeys(EntryKey... keys)
Defines keys to execute the mapper and a possibly defined reducer against.
|
ReducingSubmittableJob<EntryKey,KeyIn,ValueIn> |
ReducingSubmittableJob.onKeys(Iterable<EntryKey> keys)
Defines keys to execute the mapper and a possibly defined reducer against.
|
<ValueOut> ReducingSubmittableJob<EntryKey,KeyIn,ValueOut> |
MappingJob.reducer(ReducerFactory<? super KeyIn,? super ValueIn,? extends ValueOut> reducerFactory)
Defines the
ReducerFactory for this task. |
<ValueOut> ReducingSubmittableJob<EntryKey,KeyIn,ValueOut> |
ReducingJob.reducer(ReducerFactory<KeyIn,ValueIn,ValueOut> reducerFactory)
Defines the
ReducerFactory for this task. |
ReducingSubmittableJob<EntryKey,KeyIn,ValueIn> |
ReducingSubmittableJob.topologyChangedStrategy(TopologyChangedStrategy topologyChangedStrategy)
Defines the strategy to handle topology changes while executing the map reduce job.
|
Modifier and Type | Class and Description |
---|---|
protected class |
AbstractJob.ReducingSubmittableJobImpl<EntryKey,Key,Value>
This class is just used to comply to the public DSL style API
|
Modifier and Type | Method and Description |
---|---|
ReducingSubmittableJob<EntryKey,Key,Value> |
AbstractJob.ReducingSubmittableJobImpl.chunkSize(int chunkSize) |
ReducingSubmittableJob<EntryKey,Key,Value> |
AbstractJob.ReducingSubmittableJobImpl.keyPredicate(KeyPredicate<EntryKey> predicate) |
ReducingSubmittableJob<EntryKey,Key,Value> |
AbstractJob.ReducingSubmittableJobImpl.onKeys(EntryKey... keys) |
ReducingSubmittableJob<EntryKey,Key,Value> |
AbstractJob.ReducingSubmittableJobImpl.onKeys(Iterable<EntryKey> keys) |
<ValueOut> ReducingSubmittableJob<EntryKey,Key,ValueOut> |
AbstractJob.MappingJobImpl.reducer(ReducerFactory<? super Key,? super Value,? extends ValueOut> reducerFactory) |
<ValueOut> ReducingSubmittableJob<EntryKey,Key,ValueOut> |
AbstractJob.ReducingJobImpl.reducer(ReducerFactory<Key,Value,ValueOut> reducerFactory) |
ReducingSubmittableJob<EntryKey,Key,Value> |
AbstractJob.ReducingSubmittableJobImpl.topologyChangedStrategy(TopologyChangedStrategy topologyChangedStrategy) |
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.