public class MQComputationPool extends Object
Modifier and Type | Class and Description |
---|---|
protected static class |
MQComputationPool.NamedThreadFactory |
Constructor and Description |
---|
MQComputationPool(Supplier<Computation> supplier,
ComputationMetadataMapping metadata,
List<List<MQPartition>> defaultAssignments,
MQManager<Record> manager) |
Modifier and Type | Method and Description |
---|---|
boolean |
drainAndStop(Duration timeout) |
String |
getComputationName() |
long |
getLowWatermark() |
void |
shutdown() |
void |
start() |
boolean |
stop(Duration timeout) |
boolean |
waitForAssignments(Duration timeout) |
public MQComputationPool(Supplier<Computation> supplier, ComputationMetadataMapping metadata, List<List<MQPartition>> defaultAssignments, MQManager<Record> manager)
public String getComputationName()
public void start()
public boolean waitForAssignments(Duration timeout) throws InterruptedException
InterruptedException
public boolean drainAndStop(Duration timeout)
public void shutdown()
public long getLowWatermark()
Copyright © 2017 Nuxeo. All rights reserved.