package org.apache.spark.sql.execution.streaming
trait TriggerExecutor {
def execute(batchRunner: () => Boolean): Unit
}
TriggerExecutor
TriggerExecutor
is the interface for trigger executors that StreamExecution
uses to execute a batch runner.
Note
|
Batch runner is an executable code that is executed at regular intervals. It is also called a trigger handler. |
Note
|
StreamExecution reports a IllegalStateException when TriggerExecutor is different from the two built-in implementations: OneTimeExecutor
or ProcessingTimeExecutor .
|
TriggerExecutor | Description | ||
---|---|---|---|
Executes |
|||
Executes
|