public class MedianVertexProgram extends GraknVertexProgram<Long>
| Constructor and Description |
|---|
MedianVertexProgram() |
MedianVertexProgram(Set<LabelId> selectedLabelId,
Set<LabelId> statisticsResourceLabelIds,
ResourceType.DataType resourceDataType,
String randomId) |
| Modifier and Type | Method and Description |
|---|---|
Set<String> |
getElementComputeKeys() |
Set<String> |
getMemoryComputeKeys() |
Set<org.apache.tinkerpop.gremlin.process.computer.MessageScope> |
getMessageScopes(org.apache.tinkerpop.gremlin.process.computer.Memory memory) |
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.
|
void |
setup(org.apache.tinkerpop.gremlin.process.computer.Memory memory) |
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. |
boolean |
terminate(org.apache.tinkerpop.gremlin.process.computer.Memory memory) |
clone, execute, getPreferredPersist, getPreferredResultGraphtoStringpublic static final String MEDIAN
public Set<org.apache.tinkerpop.gremlin.process.computer.MessageScope> getMessageScopes(org.apache.tinkerpop.gremlin.process.computer.Memory memory)
getMessageScopes in interface org.apache.tinkerpop.gremlin.process.computer.VertexProgram<Long>getMessageScopes in class GraknVertexProgram<Long>public 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.VertexProgram<Long>storeState in class GraknVertexProgram<Long>configuration - the apache config object that will be propagatedpublic void loadState(org.apache.tinkerpop.gremlin.structure.Graph graph,
org.apache.commons.configuration.Configuration configuration)
CommonOLAPpersistentProperties and any hard coded fields from an apache config object for use by the
spark executor.loadState in interface org.apache.tinkerpop.gremlin.process.computer.VertexProgram<Long>loadState in class CommonOLAPgraph - the tinker graphconfiguration - the apache config object containing the valuespublic void setup(org.apache.tinkerpop.gremlin.process.computer.Memory memory)
setup in interface org.apache.tinkerpop.gremlin.process.computer.VertexProgram<Long>setup in class GraknVertexProgram<Long>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)
GraknVertexProgramvertex - a vertex that may be a ghostmessenger - Tinker message passing objectmemory - Tinker memory objectpublic boolean terminate(org.apache.tinkerpop.gremlin.process.computer.Memory memory)
Copyright © 2017 Grakn Labs Ltd. All rights reserved.