org.apache.spark.sql.streaming.ui

Class UIUtils

Object

org.apache.spark.sql.streaming.ui.UIUtils

public class UIUtils
extends Object

Constructor Summary

Constructors

Constructor and Description
UIUtils()

Method Summary

Modifier and Type	Method and Description
static String	getQueryName(org.apache.spark.sql.streaming.ui.StreamingQueryUIData query)
static String	getQueryStatus(org.apache.spark.sql.streaming.ui.StreamingQueryUIData query)
static long	parseProgressTimestamp(String timestamp)
static <T> T	withNoProgress(org.apache.spark.sql.streaming.ui.StreamingQueryUIData query, scala.Function0<T> body, T default_) Execute a block of code when there is already one completed batch in streaming query, otherwise return default value.
static double	withNumberInvalid(scala.Function0<Object> number) Check whether number is valid, if not return 0.0d

Methods inherited from class Object

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

Constructor Detail

UIUtils

public UIUtils()

Method Detail

withNumberInvalid

public static double withNumberInvalid(scala.Function0<Object> number)

Check whether number is valid, if not return 0.0d

Parameters:

number - (undocumented)

Returns:

(undocumented)

withNoProgress

public static <T> T withNoProgress(org.apache.spark.sql.streaming.ui.StreamingQueryUIData query,
                                   scala.Function0<T> body,
                                   T default_)

Execute a block of code when there is already one completed batch in streaming query, otherwise return default value.

Parameters:

query - (undocumented)

body - (undocumented)

default_ - (undocumented)

Returns:

(undocumented)

getQueryName

public static String getQueryName(org.apache.spark.sql.streaming.ui.StreamingQueryUIData query)

getQueryStatus

public static String getQueryStatus(org.apache.spark.sql.streaming.ui.StreamingQueryUIData query)

parseProgressTimestamp

public static long parseProgressTimestamp(String timestamp)