Skip to content

SupportsTriggerAvailableNow¶

SupportsTriggerAvailableNow is an extension of the SupportsAdmissionControl abstraction for streaming sources to support Trigger.AvailableNow mode.

Contract¶

prepareForTriggerAvailableNow¶

void prepareForTriggerAvailableNow()

Lets a streaming source to prepare for the default ReadLimit (in Trigger.AvailableNow mode)

Used when:

MicroBatchExecution is requested for the logicalPlan (and the uniqueSources for MultiBatchExecutor)

Implementations¶