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

Packages that use MapReduce.ReduceEmitter

Package	Description
org.apache.tinkerpop.gremlin.hadoop.process.computer
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.hadoop.process.computer

Classes in org.apache.tinkerpop.gremlin.hadoop.process.computer that implement MapReduce.ReduceEmitter

Modifier and Type	Class and Description
class	HadoopCombine.HadoopCombineEmitter<OK,OV>
class	HadoopReduce.HadoopReduceEmitter<OK,OV>

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 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.
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 and 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 and Description
class	TinkerReduceEmitter<OK,OV>