Class: ProcessingTime

eclairjs/sql/streaming. ProcessingTime

A trigger that runs a query periodically based on the processing time. If `interval` is 0, the query will run as fast as possible.

Constructor

new ProcessingTime()

Since:
  • EclairJS 0.7 Spark 2.0.0
Source:
Example
df.write.trigger(ProcessingTime.create("10 seconds"))

Methods

(static) create(interval) → {module:eclairjs/sql/streaming.ProcessingTime}

Create a ProcessingTime. If `interval` is 0, the query will run as fast as possible. Example:
Parameters:
Name Type Description
interval string
Since:
  • EclairJS 0.7 Spark 2.0.0
Source:
Returns:
Type
module:eclairjs/sql/streaming.ProcessingTime
Example
df.write.trigger(ProcessingTime.create("10 seconds"))