com.continuent.tungsten.replicator.pipeline
Interface TaskScheduler
public interface TaskScheduler
Denotes a class that provides scheduling information for stage tasks.
- Version:
- 1.0
- Author:
- Robert Hodges
|
Method Summary |
boolean |
proceed(ReplDBMSHeader lastEvent)
Controls whether stage task should continue processing events. |
proceed
boolean proceed(ReplDBMSHeader lastEvent)
- Controls whether stage task should continue processing events. This call
may do of the following:
- Return true in which case stage should proceed to handle the next
event.
- Return false in which case the stage should exit.
- Pause (hang), then return one of the preceeding statuses
The final case is how we implement a pause operation on stage tasks.
- Parameters:
lastEvent - Last event processed by this task