Modifier and Type | Method and Description |
---|---|
void |
MemoryMapReduce.combine(MapReduce.NullObject key,
Iterator<MapMemory> values,
MapReduce.ReduceEmitter<MapReduce.NullObject,MapMemory> emitter) |
void |
MemoryMapReduce.reduce(MapReduce.NullObject key,
Iterator<MapMemory> values,
MapReduce.ReduceEmitter<MapReduce.NullObject,MapMemory> emitter) |
Modifier and Type | Method and Description |
---|---|
void |
MemoryMapReduce.addResultToMemory(Memory.Admin memory,
Iterator<KeyValue<MapReduce.NullObject,MapMemory>> keyValues) |
void |
MemoryMapReduce.combine(MapReduce.NullObject key,
Iterator<MapMemory> values,
MapReduce.ReduceEmitter<MapReduce.NullObject,MapMemory> emitter) |
MapMemory |
MemoryMapReduce.generateFinalResult(Iterator<KeyValue<MapReduce.NullObject,MapMemory>> keyValues) |
void |
MemoryMapReduce.map(Vertex vertex,
MapReduce.MapEmitter<MapReduce.NullObject,MapMemory> emitter) |
void |
MemoryMapReduce.reduce(MapReduce.NullObject key,
Iterator<MapMemory> values,
MapReduce.ReduceEmitter<MapReduce.NullObject,MapMemory> emitter) |
Modifier and Type | Method and Description |
---|---|
static MapReduce.NullObject |
MapReduce.NullObject.instance() |
Modifier and Type | Method and Description |
---|---|
int |
MapReduce.NullObject.compareTo(MapReduce.NullObject nullObject) |
Modifier and Type | Method and Description |
---|---|
void |
ClusterCountMapReduce.combine(MapReduce.NullObject key,
Iterator<Serializable> values,
MapReduce.ReduceEmitter<MapReduce.NullObject,Integer> emitter) |
void |
ClusterCountMapReduce.reduce(MapReduce.NullObject key,
Iterator<Serializable> values,
MapReduce.ReduceEmitter<MapReduce.NullObject,Integer> emitter) |
Modifier and Type | Method and Description |
---|---|
void |
ClusterCountMapReduce.combine(MapReduce.NullObject key,
Iterator<Serializable> values,
MapReduce.ReduceEmitter<MapReduce.NullObject,Integer> emitter) |
Integer |
ClusterCountMapReduce.generateFinalResult(Iterator<KeyValue<MapReduce.NullObject,Integer>> keyValues) |
void |
ClusterCountMapReduce.map(Vertex vertex,
MapReduce.MapEmitter<MapReduce.NullObject,Serializable> emitter) |
void |
ClusterCountMapReduce.reduce(MapReduce.NullObject key,
Iterator<Serializable> values,
MapReduce.ReduceEmitter<MapReduce.NullObject,Integer> emitter) |
Modifier and Type | Method and Description |
---|---|
void |
TreeStep.TreeMapReduce.combine(MapReduce.NullObject key,
Iterator<Tree> values,
MapReduce.ReduceEmitter<MapReduce.NullObject,Tree> emitter) |
void |
TreeStep.TreeMapReduce.reduce(MapReduce.NullObject key,
Iterator<Tree> values,
MapReduce.ReduceEmitter<MapReduce.NullObject,Tree> emitter) |
Modifier and Type | Method and Description |
---|---|
void |
TreeStep.TreeMapReduce.combine(MapReduce.NullObject key,
Iterator<Tree> values,
MapReduce.ReduceEmitter<MapReduce.NullObject,Tree> emitter) |
Tree |
TreeStep.TreeMapReduce.generateFinalResult(Iterator<KeyValue<MapReduce.NullObject,Tree>> keyValues) |
void |
TreeStep.TreeMapReduce.map(Vertex vertex,
MapReduce.MapEmitter<MapReduce.NullObject,Tree> emitter) |
void |
TreeStep.TreeMapReduce.reduce(MapReduce.NullObject key,
Iterator<Tree> values,
MapReduce.ReduceEmitter<MapReduce.NullObject,Tree> emitter) |
Modifier and Type | Method and Description |
---|---|
MapReduce<MapReduce.NullObject,Object,MapReduce.NullObject,Object,Collection> |
AggregateStep.getMapReduce() |
MapReduce<MapReduce.NullObject,Object,MapReduce.NullObject,Object,Collection> |
AggregateStep.getMapReduce() |
MapReduce<MapReduce.NullObject,StandardTraversalMetrics,MapReduce.NullObject,StandardTraversalMetrics,StandardTraversalMetrics> |
ProfileStep.getMapReduce() |
MapReduce<MapReduce.NullObject,StandardTraversalMetrics,MapReduce.NullObject,StandardTraversalMetrics,StandardTraversalMetrics> |
ProfileStep.getMapReduce() |
MapReduce<MapReduce.NullObject,Object,MapReduce.NullObject,Object,Collection> |
StoreStep.getMapReduce() |
MapReduce<MapReduce.NullObject,Object,MapReduce.NullObject,Object,Collection> |
StoreStep.getMapReduce() |
Modifier and Type | Method and Description |
---|---|
void |
ProfileStep.ProfileMapReduce.combine(MapReduce.NullObject key,
Iterator<StandardTraversalMetrics> values,
MapReduce.ReduceEmitter<MapReduce.NullObject,StandardTraversalMetrics> emitter) |
void |
ProfileStep.ProfileMapReduce.reduce(MapReduce.NullObject key,
Iterator<StandardTraversalMetrics> values,
MapReduce.ReduceEmitter<MapReduce.NullObject,StandardTraversalMetrics> 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 | Method and Description |
---|---|
void |
ReducingBarrierStep.DefaultMapReduce.map(Vertex vertex,
MapReduce.MapEmitter<MapReduce.NullObject,Object> emitter) |
void |
ReducingBarrierStep.DefaultMapReduce.reduce(MapReduce.NullObject key,
Iterator<Object> values,
MapReduce.ReduceEmitter<MapReduce.NullObject,Object> emitter) |
Copyright © 2013–2015 Apache Software Foundation. All rights reserved.