Trigger

type Trigger =
  | {
  interval: string;
  kind: "processingTime";
}
  | {
  kind: "availableNow";
}
  | {
  kind: "once";
}
  | {
  interval: string;
  kind: "continuous";
};

Defined in: streaming/trigger.ts:17

Trigger policy for a streaming query, set via DataStreamWriter.trigger.

Mirrors Spark’s org.apache.spark.sql.streaming.Trigger. Each variant maps to one case of the trigger oneof on WriteStreamOperationStart.

See

Spark source: Trigger.scala

Example

df.writeStream.trigger(Trigger.processingTime("10 seconds")).start();
df.writeStream.trigger(Trigger.availableNow()).start();