Package | Description |
---|---|
org.apache.tinkerpop.gremlin.process.computer |
Modifier and Type | Method and Description |
---|---|
default void |
MapReduce.combine(MK key,
Iterator<MV> values,
MapReduce.ReduceEmitter<RK,RV> emitter)
The combine() method is logically executed at all "machines" in parallel.
|
default void |
MapReduce.reduce(MK key,
Iterator<MV> values,
MapReduce.ReduceEmitter<RK,RV> emitter)
The reduce() method is logically on the "machine" the respective key hashes to.
|
Copyright © 2013–2019 Apache Software Foundation. All rights reserved.