org.janusgraph.graphdb.olap.computer

Class VertexProgramScanJob<M>

java.lang.Object

org.janusgraph.graphdb.olap.computer.VertexProgramScanJob<M>

All Implemented Interfaces:

Cloneable, VertexScanJob

public class VertexProgramScanJob<M>
extends Object
implements VertexScanJob

Author:

Matthias Broecheler (me@matthiasb.com)

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	VertexProgramScanJob.Executor

Method Summary

Modifier and Type	Method and Description
VertexProgramScanJob<M>	clone() Returns a clone of this VertexScanJob.
void	getQueries(QueryContainer queries) Specify the queries for the data to be loaded into the vertices prior to processing.
static <M> VertexProgramScanJob.Executor	getVertexProgramScanJob(StandardJanusGraph graph, FulgoraMemory memory, FulgoraVertexMemory vertexMemory, org.apache.tinkerpop.gremlin.process.computer.VertexProgram<M> vertexProgram)
void	process(JanusGraphVertex vertex, ScanMetrics metrics) Process the given vertex with its adjacency list and properties pre-loaded.
void	workerIterationEnd(ScanMetrics metrics)
void	workerIterationStart(JanusGraph graph, Configuration config, ScanMetrics metrics)

Methods inherited from class java.lang.Object

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

Method Detail

clone

public VertexProgramScanJob<M> clone()

Description copied from interface: VertexScanJob

Returns a clone of this VertexScanJob. The clone will not yet be initialized for computation but all of its internal state (if any) must match that of the original copy.

Specified by:

clone in interface VertexScanJob

Overrides:

clone in class Object

Returns:

A clone of this job

workerIterationStart

public void workerIterationStart(JanusGraph graph,
                                 Configuration config,
                                 ScanMetrics metrics)

Specified by:

workerIterationStart in interface VertexScanJob

See Also:

ScanJob

workerIterationEnd

public void workerIterationEnd(ScanMetrics metrics)

Specified by:

workerIterationEnd in interface VertexScanJob

See Also:

ScanJob

process

public void process(JanusGraphVertex vertex,
                    ScanMetrics metrics)

Description copied from interface: VertexScanJob

Process the given vertex with its adjacency list and properties pre-loaded.

Specified by:

process in interface VertexScanJob

getQueries

public void getQueries(QueryContainer queries)

Description copied from interface: VertexScanJob

Specify the queries for the data to be loaded into the vertices prior to processing.

Specified by:

getQueries in interface VertexScanJob

getVertexProgramScanJob

public static <M> VertexProgramScanJob.Executor getVertexProgramScanJob(StandardJanusGraph graph,
                                                                        FulgoraMemory memory,
                                                                        FulgoraVertexMemory vertexMemory,
                                                                        org.apache.tinkerpop.gremlin.process.computer.VertexProgram<M> vertexProgram)