| Modifier and Type | Class and Description | 
|---|---|
| class  | HadoopCombine.HadoopCombineEmitter<OK,OV> | 
| class  | HadoopReduce.HadoopReduceEmitter<OK,OV> | 
| 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. | 
| 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) | 
| 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) | 
| 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<?>> values,
      MapReduce.ReduceEmitter<K,V> emitter) | 
| void | GroupStepV3d0.GroupMapReduceV3d0. 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) | 
| 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<?>> values,
      MapReduce.ReduceEmitter<K,V> emitter) | 
| void | GroupSideEffectStepV3d0.GroupSideEffectMapReduceV3d0. 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) | 
| Modifier and Type | Method and Description | 
|---|---|
| void | ReducingBarrierStep.DefaultMapReduce. reduce(MapReduce.NullObject key,
      Iterator<Object> values,
      MapReduce.ReduceEmitter<MapReduce.NullObject,Object> emitter) | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | TinkerReduceEmitter<OK,OV> | 
Copyright © 2013–2015 Apache Software Foundation. All rights reserved.