Packages

package streaming

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Type Members

  1. case class ContinuousTrigger(intervalMs: Long) extends Trigger with Product with Serializable

    A Trigger that continuously processes streaming data, asynchronously checkpointing at the specified interval.

  2. case class ProcessingTimeTrigger(intervalMs: Long) extends Trigger with Product with Serializable

    A Trigger that runs a query periodically based on the processing time.

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

  3. case class RealTimeTrigger(batchDurationMs: Long) extends Trigger with Product with Serializable

    A Trigger that runs a query in real time mode.

    A Trigger that runs a query in real time mode.

    batchDurationMs

    The duration of each batch in milliseconds. This must be strictly positive.

    Annotations
    @Experimental()

Value Members

  1. case object AvailableNowTrigger extends Trigger with Product with Serializable

    A Trigger that processes all available data in multiple batches then terminates the query.

  2. object ContinuousTrigger extends Serializable
  3. case object OneTimeTrigger extends Trigger with Product with Serializable

    A Trigger that processes all available data in one batch then terminates the query.

  4. object ProcessingTimeTrigger extends Serializable
  5. object RealTimeTrigger extends Serializable
    Annotations
    @Experimental()

Ungrouped