public interface ComputationManager
Modifier and Type | Method and Description |
---|---|
boolean |
drainAndStop(Duration timeout)
Stop computations when input streams are empty.
|
long |
getLowWatermark() |
long |
getLowWatermark(String computationName) |
boolean |
isDone(long timestamp) |
void |
shutdown()
Shutdown immediately
|
void |
start()
Run the computations
|
boolean |
stop() |
boolean |
stop(Duration timeout)
Stop computations gracefully after processing a record or a timer.
|
boolean |
waitForAssignments(Duration timeout)
Wait for the computations to have assigned partitions ready to process records.
|
void start()
boolean waitForAssignments(Duration timeout) throws InterruptedException
true
if all computations have assigned partitions during the timeout delay.InterruptedException
boolean stop(Duration timeout)
boolean stop()
boolean drainAndStop(Duration timeout)
true
if computations are stopped during the timeout delay.void shutdown()
long getLowWatermark()
long getLowWatermark(String computationName)
boolean isDone(long timestamp)
Copyright © 2017 Nuxeo. All rights reserved.