public interface Supervisor
Modifier and Type | Method and Description |
---|---|
void |
checkpoint(String sequenceName,
DataSourceMetadata previousCheckPoint,
DataSourceMetadata currentCheckPoint)
The definition of checkpoint is not very strict as currently it does not affect data or control path.
|
SupervisorReport |
getStatus() |
void |
reset(DataSourceMetadata dataSourceMetadata) |
void |
start() |
void |
stop(boolean stopGracefully) |
void start()
void stop(boolean stopGracefully)
stopGracefully
- If true, supervisor will cleanly shutdown managed tasks if possible (for example signalling
them to publish their segments and exit). The implementation may block until the tasks have
either acknowledged or completed. If false, supervisor will stop immediately and leave any
running tasks as they are.SupervisorReport getStatus()
void reset(DataSourceMetadata dataSourceMetadata)
void checkpoint(@Nullable String sequenceName, @Nullable DataSourceMetadata previousCheckPoint, @Nullable DataSourceMetadata currentCheckPoint)
sequenceName
- unique Identifier to figure out for which sequence to do checkpointingpreviousCheckPoint
- DataSourceMetadata checkpointed in previous callcurrentCheckPoint
- current DataSourceMetadata to be checkpointedCopyright © 2011–2018. All rights reserved.