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(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.
|
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) |
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–2017 Apache Software Foundation. All rights reserved.