ProcessingTimeExecutor is created for the following Triggers:
- Trigger.ProcessingTime in Micro-Batch Stream Processing
- Trigger.Continuous in Continuous Stream Processing
Continuous Stream Processing
ProcessingTimeExecutor takes the following to be created:
ProcessingTimeExecutor is created when:
MicroBatchExecutionis created (with a ProcessingTimeTrigger)
ContinuousExecutionis created (with a ContinuousTrigger)
execute( triggerHandler: () => Boolean): Unit
execute is part of the TriggerExecutor abstraction.
execute executes the given
triggerHandler every processingTimeTrigger until the given
false (to signal execution termination).
Next Batch's Start Time¶
nextBatchTime( now: Long): Long
nextBatchTime returns the start time (in millis) of the next batch interval given the current