org.apache.tinkerpop.gremlin.tinkergraph.process.computer

Class TinkerWorkerPool

java.lang.Object

org.apache.tinkerpop.gremlin.tinkergraph.process.computer.TinkerWorkerPool

All Implemented Interfaces:

AutoCloseable

public final class TinkerWorkerPool
extends Object
implements AutoCloseable

Author:

Marko A. Rodriguez (http://markorodriguez.com), Stephen Mallette (http://stephen.genoprime.com)

Constructor Summary

Constructors

Constructor and Description
TinkerWorkerPool(int numberOfWorkers)

Method Summary

Modifier and Type	Method and Description
void	close()
void	executeMapReduce(Consumer<MapReduce> worker)
void	executeVertexProgram(Consumer<VertexProgram> worker)
void	mapReduceWorkerEnd(MapReduce.Stage stage)
void	mapReduceWorkerStart(MapReduce.Stage stage)
void	setMapReduce(MapReduce mapReduce)
void	setVertexProgram(VertexProgram vertexProgram)
void	vertexProgramWorkerIterationEnd(Memory memory)
void	vertexProgramWorkerIterationStart(Memory memory)

Methods inherited from class java.lang.Object

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

Constructor Detail

TinkerWorkerPool

public TinkerWorkerPool(int numberOfWorkers)

Method Detail

setVertexProgram

public void setVertexProgram(VertexProgram vertexProgram)

setMapReduce

public void setMapReduce(MapReduce mapReduce)

vertexProgramWorkerIterationStart

public void vertexProgramWorkerIterationStart(Memory memory)

vertexProgramWorkerIterationEnd

public void vertexProgramWorkerIterationEnd(Memory memory)

executeVertexProgram

public void executeVertexProgram(Consumer<VertexProgram> worker)

mapReduceWorkerStart

public void mapReduceWorkerStart(MapReduce.Stage stage)

mapReduceWorkerEnd

public void mapReduceWorkerEnd(MapReduce.Stage stage)

executeMapReduce

public void executeMapReduce(Consumer<MapReduce> worker)

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception