Skip to content

TriggerExecutor

TriggerExecutor is an abstraction of trigger executors.

Contract

Executing Batches

execute(
  batchRunner: () => Boolean): Unit

Executes batches (triggers) using a batch runner (trigger handler).

batchRunner is assumed to return false to indicate execution termination

Used when:

Implementations

MultiBatchExecutor

Executes the batch runner until it returns false

Handles AvailableNowTrigger in MicroBatchExecution

Used when:

SingleBatchExecutor

Executes the batch runner exactly once