ai.grakn.graql.internal.analytics

Class StatisticsMapReduce<T>

java.lang.Object

ai.grakn.graql.internal.analytics.CommonOLAP

ai.grakn.graql.internal.analytics.GraknMapReduce<T>

ai.grakn.graql.internal.analytics.StatisticsMapReduce<T>

Type Parameters:

T - Determines the return type of th MapReduce statistics computation

All Implemented Interfaces:

Cloneable, org.apache.tinkerpop.gremlin.process.computer.MapReduce<Serializable,T,Serializable,T,Map<Serializable,T>>

Direct Known Subclasses:

MaxMapReduce, MeanMapReduce, MinMapReduce, StdMapReduce, SumMapReduce

public abstract class StatisticsMapReduce<T>
extends GraknMapReduce<T>

The abstract MapReduce program for computing statistics.

Author:

Jason Liu

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.tinkerpop.gremlin.process.computer.MapReduce

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

Field Summary

Fields inherited from class ai.grakn.graql.internal.analytics.GraknMapReduce

RESERVED_TYPE_LABEL_KEY

Fields inherited from interface org.apache.tinkerpop.gremlin.process.computer.MapReduce

MAP_REDUCE

Method Summary

Modifier and Type	Method and Description
void	loadState(org.apache.tinkerpop.gremlin.structure.Graph graph, org.apache.commons.configuration.Configuration configuration) Load persistentProperties and any hard coded fields from an apache config object for use by the spark executor.

Methods inherited from class ai.grakn.graql.internal.analytics.GraknMapReduce

clone, combine, doStage, generateFinalResult, getMemoryKey, map, reduce, storeState

Methods inherited from class ai.grakn.graql.internal.analytics.CommonOLAP

toString

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.tinkerpop.gremlin.process.computer.MapReduce

addResultToMemory, createMapReduce, getMapKeySort, getReduceKeySort, workerEnd, workerStart

Method Detail

loadState

public void loadState(org.apache.tinkerpop.gremlin.structure.Graph graph,
                      org.apache.commons.configuration.Configuration configuration)

Description copied from class: CommonOLAP

Load persistentProperties and any hard coded fields from an apache config object for use by the spark executor.

Specified by:

loadState in interface org.apache.tinkerpop.gremlin.process.computer.MapReduce<Serializable,T,Serializable,T,Map<Serializable,T>>

Overrides:

loadState in class CommonOLAP

Parameters:

graph - the tinker graph

configuration - the apache config object containing the values