org.apache.spark.sql.streaming

Class ProcessingTime

Object

org.apache.spark.sql.streaming.Trigger

org.apache.spark.sql.streaming.ProcessingTime

All Implemented Interfaces:

java.io.Serializable, scala.Equals, scala.Product

Deprecated.

use Trigger.ProcessingTime(intervalMs). Since 2.2.0.

public class ProcessingTime
extends Trigger
implements scala.Product, scala.Serializable

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

Scala Example:

   df.writeStream.trigger(ProcessingTime("10 seconds"))

   import scala.concurrent.duration._
   df.writeStream.trigger(ProcessingTime(10.seconds))
 

Java Example:

   df.writeStream.trigger(ProcessingTime.create("10 seconds"))

   import java.util.concurrent.TimeUnit
   df.writeStream.trigger(ProcessingTime.create(10, TimeUnit.SECONDS))
 

Since:

2.0.0

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ProcessingTime(long intervalMs) Deprecated.

Method Summary

Modifier and Type	Method and Description
static ProcessingTime	apply(scala.concurrent.duration.Duration interval) Deprecated. use Trigger.ProcessingTime(interval)
static ProcessingTime	apply(String interval) Deprecated. use Trigger.ProcessingTime(interval)
static ProcessingTime	create(long interval, java.util.concurrent.TimeUnit unit) Deprecated. use Trigger.ProcessingTime(interval, unit)
static ProcessingTime	create(String interval) Deprecated. use Trigger.ProcessingTime(interval)
long	intervalMs() Deprecated.

Methods inherited from class org.apache.spark.sql.streaming.Trigger

Continuous, Continuous, Continuous, Continuous, Once, ProcessingTime, ProcessingTime, ProcessingTime, ProcessingTime

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface scala.Product

productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

ProcessingTime

public ProcessingTime(long intervalMs)

Deprecated.

Method Detail

apply

public static ProcessingTime apply(String interval)

Deprecated. use Trigger.ProcessingTime(interval)

Create a ProcessingTime. If interval is 0, the query will run as fast as possible.

Example:

   df.writeStream.trigger(ProcessingTime("10 seconds"))
 

Parameters:

interval - (undocumented)

Returns:

(undocumented)

Since:

2.0.0

apply

public static ProcessingTime apply(scala.concurrent.duration.Duration interval)

Deprecated. use Trigger.ProcessingTime(interval)

Create a ProcessingTime. If interval is 0, the query will run as fast as possible.

Example:

   import scala.concurrent.duration._
   df.writeStream.trigger(ProcessingTime(10.seconds))
 

Parameters:

interval - (undocumented)

Returns:

(undocumented)

Since:

2.0.0

create

public static ProcessingTime create(String interval)

Deprecated. use Trigger.ProcessingTime(interval)

Create a ProcessingTime. If interval is 0, the query will run as fast as possible.

Example:

   df.writeStream.trigger(ProcessingTime.create("10 seconds"))
 

Parameters:

interval - (undocumented)

Returns:

(undocumented)

Since:

2.0.0

create

public static ProcessingTime create(long interval,
                                    java.util.concurrent.TimeUnit unit)

Deprecated. use Trigger.ProcessingTime(interval, unit)

Create a ProcessingTime. If interval is 0, the query will run as fast as possible.

Example:

   import java.util.concurrent.TimeUnit
   df.writeStream.trigger(ProcessingTime.create(10, TimeUnit.SECONDS))
 

Parameters:

interval - (undocumented)

unit - (undocumented)

Returns:

(undocumented)

Since:

2.0.0

intervalMs

public long intervalMs()

Deprecated.