public class CountMapReduce extends GraknMapReduce<Long>
org.apache.tinkerpop.gremlin.process.computer.MapReduce.MapEmitter<K,V>, org.apache.tinkerpop.gremlin.process.computer.MapReduce.NullObject, org.apache.tinkerpop.gremlin.process.computer.MapReduce.ReduceEmitter<OK,OV>, org.apache.tinkerpop.gremlin.process.computer.MapReduce.Stage| Constructor and Description |
|---|
CountMapReduce() |
CountMapReduce(Set<LabelId> labelIds) |
| Modifier and Type | Method and Description |
|---|---|
void |
safeMap(org.apache.tinkerpop.gremlin.structure.Vertex vertex,
org.apache.tinkerpop.gremlin.process.computer.MapReduce.MapEmitter<Serializable,Long> emitter)
An alternative to the execute method when ghost vertices are an issue.
|
clone, combine, doStage, generateFinalResult, getMemoryKey, map, reduce, storeStateloadState, toStringpublic void safeMap(org.apache.tinkerpop.gremlin.structure.Vertex vertex,
org.apache.tinkerpop.gremlin.process.computer.MapReduce.MapEmitter<Serializable,Long> emitter)
GraknMapReducevertex - a vertex that may be a ghostemitter - Tinker emitter objectCopyright © 2017 Grakn Labs Ltd. All rights reserved.