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)