ai.grakn.graql.internal.analytics

Class StdMapReduce

java.lang.Object

ai.grakn.graql.internal.analytics.CommonOLAP

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

ai.grakn.graql.internal.analytics.StatisticsMapReduce<Map<String,Double>>

ai.grakn.graql.internal.analytics.StdMapReduce

All Implemented Interfaces:

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

public class StdMapReduce
extends StatisticsMapReduce<Map<String,Double>>

The MapReduce program for computing the standard deviation of the given resource.

Author:

Jason Liu, Sheldon Hall

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

Modifier and Type	Field and Description
static String	COUNT
static String	SQUARE_SUM
static String	SUM

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

Constructor Summary

Constructors

Constructor and Description
StdMapReduce()
StdMapReduce(Set<LabelId> selectedLabelIds, AttributeType.DataType resourceDataType, String degreePropertyKey)

Method Summary

Modifier and Type	Method and Description
void	safeMap(org.apache.tinkerpop.gremlin.structure.Vertex vertex, org.apache.tinkerpop.gremlin.process.computer.MapReduce.MapEmitter<Serializable,Map<String,Double>> emitter) An alternative to the execute method when ghost vertices are an issue.

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

loadState

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

Field Detail

COUNT

public static final String COUNT

See Also:

Constant Field Values

SUM

public static final String SUM

See Also:

Constant Field Values

SQUARE_SUM

public static final String SQUARE_SUM

See Also:

Constant Field Values

Constructor Detail

StdMapReduce

public StdMapReduce()

StdMapReduce

public StdMapReduce(Set<LabelId> selectedLabelIds,
                    AttributeType.DataType resourceDataType,
                    String degreePropertyKey)

Method Detail

safeMap

public void safeMap(org.apache.tinkerpop.gremlin.structure.Vertex vertex,
                    org.apache.tinkerpop.gremlin.process.computer.MapReduce.MapEmitter<Serializable,Map<String,Double>> emitter)

Description copied from class: GraknMapReduce

An alternative to the execute method when ghost vertices are an issue. Our "Ghostbuster".

Parameters:

vertex - a vertex that may be a ghost

emitter - Tinker emitter object