org.apache.tinkerpop.gremlin.process.computer.util

Class MapReducePool

java.lang.Object

org.apache.tinkerpop.gremlin.process.computer.util.MapReducePool

public final class MapReducePool
extends Object

Author:

Marko A. Rodriguez (http://markorodriguez.com)

Constructor Summary

Constructors

Constructor and Description
MapReducePool(MapReduce mapReduce, int poolSize)

Method Summary

Modifier and Type	Method and Description
void	offer(MapReduce<?,?,?,?,?> mapReduce)
MapReduce	take()
void	workerEnd(MapReduce.Stage stage)
void	workerStart(MapReduce.Stage stage)

Methods inherited from class java.lang.Object

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

Constructor Detail

MapReducePool

public MapReducePool(MapReduce mapReduce,
                     int poolSize)

Method Detail

take

public MapReduce take()

offer

public void offer(MapReduce<?,?,?,?,?> mapReduce)

workerStart

public void workerStart(MapReduce.Stage stage)

workerEnd

public void workerEnd(MapReduce.Stage stage)