public class ClusterSizeMapReduce extends GraknMapReduce<Long>
It returns a map, the key being the cluster id, the value being the number of vertices the given cluster has.
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 |
|---|
ClusterSizeMapReduce() |
ClusterSizeMapReduce(Set<LabelId> selectedLabelIds,
String clusterLabel) |
ClusterSizeMapReduce(Set<LabelId> selectedLabelIds,
String clusterLabel,
Long clusterSize) |
| Modifier and Type | Method and Description |
|---|---|
Map<Serializable,Long> |
generateFinalResult(Iterator<org.apache.tinkerpop.gremlin.process.computer.KeyValue<Serializable,Long>> keyValues) |
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, getMemoryKey, map, reduce, storeStateloadState, toStringpublic ClusterSizeMapReduce()
public ClusterSizeMapReduce(Set<LabelId> selectedLabelIds, String clusterLabel)
public 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 objectpublic Map<Serializable,Long> generateFinalResult(Iterator<org.apache.tinkerpop.gremlin.process.computer.KeyValue<Serializable,Long>> keyValues)
generateFinalResult in interface org.apache.tinkerpop.gremlin.process.computer.MapReduce<Serializable,Long,Serializable,Long,Map<Serializable,Long>>generateFinalResult in class GraknMapReduce<Long>Copyright © 2017 Grakn Labs Ltd. All rights reserved.