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.hadoop.process.computer.spark
org.apache.tinkerpop.gremlin.process.computer
org.apache.tinkerpop.gremlin.process.computer.clustering.peerpressure
org.apache.tinkerpop.gremlin.process.computer.traversal.step.sideEffect.mapreduce
org.apache.tinkerpop.gremlin.process.traversal.step.map
org.apache.tinkerpop.gremlin.process.traversal.step.sideEffect
org.apache.tinkerpop.gremlin.process.traversal.step.util
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.hadoop.process.computer.spark

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

Modifier and Type	Class and Description
class	SparkReduceEmitter<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(Long key, Iterator<Long> values, MapReduce.ReduceEmitter<Long,Long> 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	ClusterCountMapReduce.combine(MapReduce.NullObject key, Iterator<Serializable> values, MapReduce.ReduceEmitter<MapReduce.NullObject,Integer> emitter)
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.process.computer.traversal.step.sideEffect.mapreduce

Methods in org.apache.tinkerpop.gremlin.process.computer.traversal.step.sideEffect.mapreduce with parameters of type MapReduce.ReduceEmitter

Modifier and Type	Method and Description
void	TraverserMapReduce.combine(Comparable comparable, Iterator<Traverser<?>> values, MapReduce.ReduceEmitter<Comparable,Traverser<?>> emitter)
void	TraverserMapReduce.reduce(Comparable comparable, Iterator<Traverser<?>> values, MapReduce.ReduceEmitter<Comparable,Traverser<?>> emitter)

Uses of MapReduce.ReduceEmitter in org.apache.tinkerpop.gremlin.process.traversal.step.map

Methods in org.apache.tinkerpop.gremlin.process.traversal.step.map with parameters of type MapReduce.ReduceEmitter

Modifier and Type	Method and Description
void	GroupCountStep.GroupCountMapReduce.combine(E key, Iterator<Long> values, MapReduce.ReduceEmitter<E,Long> emitter)
void	TreeStep.TreeMapReduce.combine(MapReduce.NullObject key, Iterator<Tree> values, MapReduce.ReduceEmitter<MapReduce.NullObject,Tree> emitter)
void	GroupCountStep.GroupCountMapReduce.reduce(E key, Iterator<Long> values, MapReduce.ReduceEmitter<E,Long> emitter)
void	GroupStep.GroupMapReduce.reduce(K key, Iterator<Collection<V>> values, MapReduce.ReduceEmitter<K,R> emitter)
void	TreeStep.TreeMapReduce.reduce(MapReduce.NullObject key, Iterator<Tree> values, MapReduce.ReduceEmitter<MapReduce.NullObject,Tree> emitter)

Uses of MapReduce.ReduceEmitter in org.apache.tinkerpop.gremlin.process.traversal.step.sideEffect

Methods in org.apache.tinkerpop.gremlin.process.traversal.step.sideEffect with parameters of type MapReduce.ReduceEmitter

Modifier and Type	Method and Description
void	GroupCountSideEffectStep.GroupCountSideEffectMapReduce.combine(E key, Iterator<Long> values, MapReduce.ReduceEmitter<E,Long> emitter)
void	ProfileStep.ProfileMapReduce.combine(MapReduce.NullObject key, Iterator<StandardTraversalMetrics> values, MapReduce.ReduceEmitter<MapReduce.NullObject,StandardTraversalMetrics> emitter)
void	TreeSideEffectStep.TreeSideEffectMapReduce.combine(MapReduce.NullObject key, Iterator<Tree> values, MapReduce.ReduceEmitter<MapReduce.NullObject,Tree> emitter)
void	GroupCountSideEffectStep.GroupCountSideEffectMapReduce.reduce(E key, Iterator<Long> values, MapReduce.ReduceEmitter<E,Long> emitter)
void	GroupSideEffectStep.GroupSideEffectMapReduce.reduce(K key, Iterator<Collection<V>> values, MapReduce.ReduceEmitter<K,R> emitter)
void	ProfileStep.ProfileMapReduce.reduce(MapReduce.NullObject key, Iterator<StandardTraversalMetrics> values, MapReduce.ReduceEmitter<MapReduce.NullObject,StandardTraversalMetrics> emitter)
void	TreeSideEffectStep.TreeSideEffectMapReduce.reduce(MapReduce.NullObject key, Iterator<Tree> values, MapReduce.ReduceEmitter<MapReduce.NullObject,Tree> emitter)

Uses of MapReduce.ReduceEmitter in org.apache.tinkerpop.gremlin.process.traversal.step.util

Methods in org.apache.tinkerpop.gremlin.process.traversal.step.util with parameters of type MapReduce.ReduceEmitter

Modifier and Type	Method and Description
void	ReducingBarrierStep.DefaultMapReduce.reduce(MapReduce.NullObject key, Iterator<Object> values, MapReduce.ReduceEmitter<MapReduce.NullObject,Object> 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>