org.apache.spark.sql.streaming

Class ProcessingTime

Object

org.apache.spark.sql.streaming.ProcessingTime

All Implemented Interfaces:

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

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

:: Experimental :: 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.write.trigger(ProcessingTime("10 seconds"))

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

Java Example:

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

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

Since:

2.0.0

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ProcessingTime(long intervalMs)

Method Summary

Methods

Modifier and Type	Method and Description
static ProcessingTime	apply(scala.concurrent.duration.Duration interval) Create a ProcessingTime.
static ProcessingTime	apply(String interval) Create a ProcessingTime.
abstract static boolean	canEqual(Object that)
static ProcessingTime	create(long interval, java.util.concurrent.TimeUnit unit) Create a ProcessingTime.
static ProcessingTime	create(String interval) Create a ProcessingTime.
abstract static boolean	equals(Object that)
long	intervalMs()
abstract static int	productArity()
abstract static Object	productElement(int n)
static scala.collection.Iterator<Object>	productIterator()
static String	productPrefix()

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)

Method Detail

apply

public static ProcessingTime apply(String interval)

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

Example:

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

Parameters:

interval - (undocumented)

Returns:

(undocumented)

Since:

2.0.0

apply

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

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

Example:

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

Parameters:

interval - (undocumented)

Returns:

(undocumented)

Since:

2.0.0

create

public static ProcessingTime create(String interval)

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

Example:

   df.write.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)

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

Example:

   import java.util.concurrent.TimeUnit
   df.write.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)

equals

public abstract static boolean equals(Object that)

productElement

public abstract static Object productElement(int n)

productArity

public abstract static int productArity()

productIterator

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

productPrefix

public static String productPrefix()

intervalMs

public long intervalMs()