Class UIUtils

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

public class UIUtils extends Object
  • Constructor Summary

    Constructors
    Constructor
    Description
     
  • 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
     
    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)