Uses of Interface
org.apache.tinkerpop.gremlin.process.computer.MapReduce.ReduceEmitter
-
-
Uses of MapReduce.ReduceEmitter in org.apache.tinkerpop.gremlin.process.computer
Methods in org.apache.tinkerpop.gremlin.process.computer with parameters of type MapReduce.ReduceEmitter Modifier and Type Method 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.void
GraphComputerTest.MapReduceB. reduce(Integer key, Iterator<Integer> values, MapReduce.ReduceEmitter<Integer,Integer> emitter)
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. -
Uses of MapReduce.ReduceEmitter in org.apache.tinkerpop.gremlin.process.computer.clustering.peerpressure
Methods in org.apache.tinkerpop.gremlin.process.computer.clustering.peerpressure with parameters of type MapReduce.ReduceEmitter Modifier and Type Method Description void
ClusterPopulationMapReduce. combine(Serializable key, Iterator<Long> values, MapReduce.ReduceEmitter<Serializable,Long> emitter)
void
ClusterCountMapReduce. reduce(MapReduce.NullObject key, Iterator<Serializable> values, MapReduce.ReduceEmitter<MapReduce.NullObject,Integer> emitter)
void
ClusterPopulationMapReduce. reduce(Serializable key, Iterator<Long> values, MapReduce.ReduceEmitter<Serializable,Long> emitter)
-
Uses of MapReduce.ReduceEmitter in org.apache.tinkerpop.gremlin.tinkergraph.process.computer
Classes in org.apache.tinkerpop.gremlin.tinkergraph.process.computer that implement MapReduce.ReduceEmitter Modifier and Type Class Description class
TinkerReduceEmitter<OK,OV>
-