SupportsTriggerAvailableNow¶
SupportsTriggerAvailableNow is an extension of the SupportsAdmissionControl abstraction for streaming sources that support Trigger.AvailableNow mode.
Contract¶
prepareForTriggerAvailableNow¶
void prepareForTriggerAvailableNow()
Lets a streaming source to prepare for the default ReadLimit (in Trigger.AvailableNow mode)
See:
- AvailableNowDataStreamWrapper
- FileStreamSource
- KafkaMicroBatchStream
- KafkaSource
- MemoryStreamBaseClass
- RatePerMicroBatchStream
Used when:
MicroBatchExecutionis requested for the logicalPlan (and the uniqueSources for MultiBatchExecutor)