Package 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	Description
UIUtils()

Method Summary

Modifier and Type	Method	Description
static String	getQueryName(org.apache.spark.sql.streaming.ui.StreamingQueryUIData uiData)
static String	getQueryStatus(org.apache.spark.sql.streaming.ui.StreamingQueryUIData uiData)
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 java.lang.Object

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

Constructor Details

UIUtils

public UIUtils()

Method Details

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 uiData)

getQueryStatus

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

parseProgressTimestamp

public static long parseProgressTimestamp(String timestamp)