T - type type of element that is being reducedpublic abstract class GraknMapReduce<T> extends CommonOLAP implements org.apache.tinkerpop.gremlin.process.computer.MapReduce<Serializable,T,Serializable,T,Map<Serializable,T>>
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| Modifier and Type | Method and Description |
|---|---|
org.apache.tinkerpop.gremlin.process.computer.MapReduce<Serializable,T,Serializable,T,Map<Serializable,T>> |
clone() |
void |
combine(Serializable key,
Iterator<T> values,
org.apache.tinkerpop.gremlin.process.computer.MapReduce.ReduceEmitter<Serializable,T> emitter) |
boolean |
doStage(org.apache.tinkerpop.gremlin.process.computer.MapReduce.Stage stage) |
Map<Serializable,T> |
generateFinalResult(Iterator<org.apache.tinkerpop.gremlin.process.computer.KeyValue<Serializable,T>> iterator) |
String |
getMemoryKey() |
void |
map(org.apache.tinkerpop.gremlin.structure.Vertex vertex,
org.apache.tinkerpop.gremlin.process.computer.MapReduce.MapEmitter<Serializable,T> emitter) |
void |
reduce(Serializable key,
Iterator<T> values,
org.apache.tinkerpop.gremlin.process.computer.MapReduce.ReduceEmitter<Serializable,T> emitter) |
void |
storeState(org.apache.commons.configuration.Configuration configuration)
Store
persistentProperties and any hard coded fields in an apache config object for propagation to
spark executors. |
loadState, toStringpublic void storeState(org.apache.commons.configuration.Configuration configuration)
CommonOLAPpersistentProperties and any hard coded fields in an apache config object for propagation to
spark executors.storeState in interface org.apache.tinkerpop.gremlin.process.computer.MapReduce<Serializable,T,Serializable,T,Map<Serializable,T>>storeState in class CommonOLAPconfiguration - the apache config object that will be propagatedpublic final void map(org.apache.tinkerpop.gremlin.structure.Vertex vertex,
org.apache.tinkerpop.gremlin.process.computer.MapReduce.MapEmitter<Serializable,T> emitter)
map in interface org.apache.tinkerpop.gremlin.process.computer.MapReduce<Serializable,T,Serializable,T,Map<Serializable,T>>public final void reduce(Serializable key, Iterator<T> values, org.apache.tinkerpop.gremlin.process.computer.MapReduce.ReduceEmitter<Serializable,T> emitter)
reduce in interface org.apache.tinkerpop.gremlin.process.computer.MapReduce<Serializable,T,Serializable,T,Map<Serializable,T>>public String getMemoryKey()
getMemoryKey in interface org.apache.tinkerpop.gremlin.process.computer.MapReduce<Serializable,T,Serializable,T,Map<Serializable,T>>public org.apache.tinkerpop.gremlin.process.computer.MapReduce<Serializable,T,Serializable,T,Map<Serializable,T>> clone()
clone in interface org.apache.tinkerpop.gremlin.process.computer.MapReduce<Serializable,T,Serializable,T,Map<Serializable,T>>clone in class Objectpublic boolean doStage(org.apache.tinkerpop.gremlin.process.computer.MapReduce.Stage stage)
doStage in interface org.apache.tinkerpop.gremlin.process.computer.MapReduce<Serializable,T,Serializable,T,Map<Serializable,T>>public final void combine(Serializable key, Iterator<T> values, org.apache.tinkerpop.gremlin.process.computer.MapReduce.ReduceEmitter<Serializable,T> emitter)
combine in interface org.apache.tinkerpop.gremlin.process.computer.MapReduce<Serializable,T,Serializable,T,Map<Serializable,T>>public Map<Serializable,T> generateFinalResult(Iterator<org.apache.tinkerpop.gremlin.process.computer.KeyValue<Serializable,T>> iterator)
generateFinalResult in interface org.apache.tinkerpop.gremlin.process.computer.MapReduce<Serializable,T,Serializable,T,Map<Serializable,T>>Copyright © 2017 Grakn Labs Ltd. All rights reserved.