org.nuxeo.lib.stream.computation.log

Class ComputationPool

java.lang.Object

org.nuxeo.lib.stream.computation.log.ComputationPool

public class ComputationPool
extends Object

Pool of ComputationRunner

Since:

9.3

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	ComputationPool.NamedThreadFactory

Field Summary

Fields

Modifier and Type	Field and Description
protected List<List<LogPartition>>	defaultAssignments
protected Codec<Record>	inputCodec
protected LogManager	manager
protected ComputationMetadataMapping	metadata
protected Codec<Record>	outputCodec
protected List<ComputationRunner>	runners
protected Supplier<Computation>	supplier
protected ExecutorService	threadPool
protected int	threads

Constructor Summary

Constructors

Constructor and Description
ComputationPool(Supplier<Computation> supplier, ComputationMetadataMapping metadata, List<List<LogPartition>> defaultAssignments, LogManager manager, Codec<Record> inputCodec, Codec<Record> outputCodec)

Method Summary

Modifier and Type	Method and Description
protected boolean	awaitPoolTermination(Duration timeout)
boolean	drainAndStop(Duration timeout)
String	getComputationName()
long	getLowWatermark()
boolean	isTerminated()
void	shutdown()
void	start()
boolean	stop(Duration timeout)
boolean	waitForAssignments(Duration timeout)

Methods inherited from class java.lang.Object

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

Field Detail

metadata

protected final ComputationMetadataMapping metadata

threads

protected final int threads

manager

protected final LogManager manager

supplier

protected final Supplier<Computation> supplier

defaultAssignments

protected final List<List<LogPartition>> defaultAssignments

runners

protected final List<ComputationRunner> runners

inputCodec

protected final Codec<Record> inputCodec

outputCodec

protected final Codec<Record> outputCodec

threadPool

protected ExecutorService threadPool

Constructor Detail

ComputationPool

public ComputationPool(Supplier<Computation> supplier,
                       ComputationMetadataMapping metadata,
                       List<List<LogPartition>> defaultAssignments,
                       LogManager manager,
                       Codec<Record> inputCodec,
                       Codec<Record> outputCodec)

Method Detail

getComputationName

public String getComputationName()

start

public void start()

isTerminated

public boolean isTerminated()

waitForAssignments

public boolean waitForAssignments(Duration timeout)
                           throws InterruptedException

Throws:

InterruptedException

drainAndStop

public boolean drainAndStop(Duration timeout)

stop

public boolean stop(Duration timeout)

shutdown

public void shutdown()

awaitPoolTermination

protected boolean awaitPoolTermination(Duration timeout)

getLowWatermark

public long getLowWatermark()