public final class TinkerWorkerPool extends Object implements AutoCloseable
| Constructor and Description |
|---|
TinkerWorkerPool(int numberOfWorkers) |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
void |
executeMapReduce(Consumer<MapReduce> worker) |
void |
executeVertexProgram(Consumer<VertexProgram> worker) |
void |
setMapReduce(MapReduce mapReduce) |
void |
setVertexProgram(VertexProgram vertexProgram) |
public void setVertexProgram(VertexProgram vertexProgram)
public void setMapReduce(MapReduce mapReduce)
public void executeVertexProgram(Consumer<VertexProgram> worker)
public void close()
throws Exception
close in interface AutoCloseableExceptionCopyright © 2013–2016 Apache Software Foundation. All rights reserved.