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)
abstract static boolean	canEqual(Object that) Deprecated.
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)
abstract static boolean	equals(Object that) Deprecated.
long	intervalMs() Deprecated.
abstract static int	productArity() Deprecated.
abstract static Object	productElement(int n) Deprecated.
static scala.collection.Iterator<Object>	productIterator() Deprecated.
static String	productPrefix() 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

canEqual

public abstract static boolean canEqual(Object that)

Deprecated.

equals

public abstract static boolean equals(Object that)

Deprecated.

productElement

public abstract static Object productElement(int n)

Deprecated.

productArity

public abstract static int productArity()

Deprecated.

productIterator

public static scala.collection.Iterator<Object> productIterator()

Deprecated.

productPrefix

public static String productPrefix()

Deprecated.

intervalMs

public long intervalMs()

Deprecated.