Uses of Interface
org.apache.tinkerpop.gremlin.process.computer.MapReduce.ReduceEmitter

Packages that use MapReduce.ReduceEmitter

Package	Description
org.apache.tinkerpop.gremlin.process.computer
org.apache.tinkerpop.gremlin.process.computer.clustering.peerpressure
org.apache.tinkerpop.gremlin.tinkergraph.process.computer

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>