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. |
Modifier and Type | Method and Description |
---|---|
ReducingJob<EntryKey,KeyIn,ValueIn> |
ReducingJob.chunkSize(int chunkSize)
Deprecated.
Defines the number of elements per chunk.
|
<ValueOut> ReducingJob<EntryKey,KeyIn,ValueOut> |
MappingJob.combiner(CombinerFactory<? super KeyIn,? super ValueIn,? extends ValueOut> combinerFactory)
Deprecated.
Defines the
CombinerFactory for this task. |
ReducingJob<EntryKey,KeyIn,ValueIn> |
ReducingJob.keyPredicate(KeyPredicate<EntryKey> predicate)
Deprecated.
Defines the
KeyPredicate implementation to preselect keys the MapReduce task will be executed on. |
ReducingJob<EntryKey,KeyIn,ValueIn> |
ReducingJob.onKeys(EntryKey... keys)
Deprecated.
Defines keys to execute the mapper and a possibly defined reducer against.
|
ReducingJob<EntryKey,KeyIn,ValueIn> |
ReducingJob.onKeys(Iterable<EntryKey> keys)
Deprecated.
Defines keys to execute the mapper and a possibly defined reducer against.
|
ReducingJob<EntryKey,KeyIn,ValueIn> |
ReducingJob.topologyChangedStrategy(TopologyChangedStrategy topologyChangedStrategy)
Deprecated.
Defines the strategy to handle topology changes while executing the map reduce job.
|
Copyright © 2018 Hazelcast, Inc.. All rights reserved.