com.thinkaurelius.titan.graphdb.olap.computer

Class VertexMapJob.Executor

java.lang.Object

com.thinkaurelius.titan.graphdb.olap.VertexJobConverter

com.thinkaurelius.titan.graphdb.olap.computer.VertexMapJob.Executor

All Implemented Interfaces:

ScanJob, Cloneable

Enclosing class:

VertexMapJob

public static class VertexMapJob.Executor
extends VertexJobConverter

Nested Class Summary

Nested classes/interfaces inherited from class com.thinkaurelius.titan.graphdb.olap.VertexJobConverter

VertexJobConverter.GraphProvider

Field Summary

Fields inherited from class com.thinkaurelius.titan.graphdb.olap.VertexJobConverter

GHOST_VERTEX_COUNT, graph, job, TRUNCATED_ENTRY_LISTS, tx, VERTEX_EXISTS_QUERY

Method Summary

Modifier and Type	Method and Description
VertexMapJob.Executor	clone() Returns a clone of this ScanJob.
List<SliceQuery>	getQueries() Returns one or more SliceQuery instances belonging to this ScanJob.
void	workerIterationEnd(ScanMetrics metrics) Invoked after a block of computation (i.e.

Methods inherited from class com.thinkaurelius.titan.graphdb.olap.VertexJobConverter

convert, convert, getKeyFilter, getVertexId, isGhostVertex, process, startTransaction, workerIterationStart

Methods inherited from class java.lang.Object

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

Method Detail

getQueries

public List<SliceQuery> getQueries()

Description copied from interface: ScanJob

Returns one or more SliceQuery instances belonging to this ScanJob.

Before calling ScanJob.process(com.thinkaurelius.titan.diskstorage.StaticBuffer, java.util.Map, ScanMetrics), users of this interface must check that the key in question contains at least one entry matching the initial SliceQuery returned by this method. See the javadoc for the process method for more information.

If this method returns more than one query, then the initial query's lower bound must be all zero bits and the initial query's upper bound must be all one bits (per the preconditions in StandardScannerExecutor, the reference ScanJob executor).

Specified by:

getQueries in interface ScanJob

Overrides:

getQueries in class VertexJobConverter

Returns:

one or more queries

workerIterationEnd

public void workerIterationEnd(ScanMetrics metrics)

Description copied from interface: ScanJob

Invoked after a block of computation (i.e. multiple process() calls) is handed to this particular ScanJob. Can be used to close any resources held by this job. This method is called exactly once for each after a block of computation. This method is semantically aligned with com.tinkerpop.gremlin.process.computer.VertexProgram#workerIterationEnd() This method may not be called if there is no data to be processed. Correspondingly, the start method won't be called either. No-op default implementation.

Specified by:

workerIterationEnd in interface ScanJob

Overrides:

workerIterationEnd in class VertexJobConverter

Parameters:

metrics - ScanMetrics for this job

clone

public VertexMapJob.Executor clone()

Description copied from interface: ScanJob

Returns a clone of this ScanJob. 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 ScanJob

Overrides:

clone in class VertexJobConverter

Returns:

A clone of this ScanJob