Trigger

Trigger: {
  availableNow: Trigger;
  continuous: Trigger;
  once: Trigger;
  processingTime: Trigger;
};

Defined in: streaming/trigger.ts:17

Factory helpers for Trigger.

Type Declaration

availableNow()

availableNow(): Trigger;

Process all currently-available data in one or more micro-batches and stop. Preferred over Trigger.once for new code (Spark 3.3+).

Returns

Trigger

continuous()

continuous(interval): Trigger;

Continuous-mode processing with the given checkpoint interval (e.g. "1 second"). Experimental in Spark; limited sink support.

Parameters

Parameter	Type
interval	string

Returns

Trigger

once()

once(): Trigger;

Process all currently-available data in a single batch and stop. Marked deprecated upstream; use Trigger.availableNow instead.

Returns

Trigger

processingTime()

processingTime(interval): Trigger;

Run a micro-batch every interval (e.g. "10 seconds", "1 minute").

Parameters

Parameter	Type
interval	string

Returns

Trigger