ai.grakn.graql.internal.analytics

Class DegreeVertexProgram

java.lang.Object

ai.grakn.graql.internal.analytics.GraknVertexProgram<Long>

ai.grakn.graql.internal.analytics.DegreeVertexProgram

All Implemented Interfaces:

Cloneable, org.apache.tinkerpop.gremlin.process.computer.VertexProgram<Long>

public class DegreeVertexProgram
extends GraknVertexProgram<Long>

Nested Class Summary

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

org.apache.tinkerpop.gremlin.process.computer.VertexProgram.Builder, org.apache.tinkerpop.gremlin.process.computer.VertexProgram.Features

Field Summary

Fields

Modifier and Type	Field and Description
static Set<String>	analyticsElements The types that are reserved by analytics and are not "seen" by analytics.
static String	DEGREE

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

VERTEX_PROGRAM

Constructor Summary

Constructors

Constructor and Description
DegreeVertexProgram()
DegreeVertexProgram(Set<String> types)

Method Summary

Modifier and Type	Method and Description
Set<String>	getElementComputeKeys()
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.
void	safeExecute(org.apache.tinkerpop.gremlin.structure.Vertex vertex, org.apache.tinkerpop.gremlin.process.computer.Messenger<Long> messenger, org.apache.tinkerpop.gremlin.process.computer.Memory memory) An alternative to the execute method when ghost vertices are an issue.
boolean	terminate(org.apache.tinkerpop.gremlin.process.computer.Memory memory)
String	toString()

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

clone, execute, getMessageScopes, getPreferredPersist, getPreferredResultGraph, setup, storeState

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.VertexProgram

createVertexProgram, getFeatures, getMapReducers, getMemoryComputeKeys, getMessageCombiner, loadState, workerIterationEnd, workerIterationStart

Field Detail

DEGREE

public static final String DEGREE

See Also:

Constant Field Values

analyticsElements

public static final Set<String> analyticsElements

The types that are reserved by analytics and are not "seen" by analytics.

Constructor Detail

DegreeVertexProgram

public DegreeVertexProgram()

DegreeVertexProgram

public DegreeVertexProgram(Set<String> types)

Method Detail

getElementComputeKeys

public Set<String> getElementComputeKeys()

safeExecute

public void safeExecute(org.apache.tinkerpop.gremlin.structure.Vertex vertex,
                        org.apache.tinkerpop.gremlin.process.computer.Messenger<Long> messenger,
                        org.apache.tinkerpop.gremlin.process.computer.Memory memory)

Description copied from class: GraknVertexProgram

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

Parameters:

vertex - a vertex that may be a ghost

messenger - Tinker message passing object

memory - Tinker memory object

terminate

public boolean terminate(org.apache.tinkerpop.gremlin.process.computer.Memory memory)

loadState

public 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.

Parameters:

graph - the tinker graph

configuration - the apache config object containing the values

toString

public String toString()

Overrides:

toString in class Object