org.apache.spark.streaming.ui

Class UIUtils

Object

org.apache.spark.streaming.ui.UIUtils

public class UIUtils
extends Object

Constructor Summary

Constructors

Constructor and Description
UIUtils()

Method Summary

Modifier and Type	Method and Description
static double	convertToTimeUnit(long milliseconds, java.util.concurrent.TimeUnit unit) Convert milliseconds to the specified unit.
static String	createOutputOperationFailureForUI(String failure)
static scala.collection.Seq<scala.xml.Node>	failureReasonCell(String failureReason, int rowspan, boolean includeFirstLineInExpandDetails)
static scala.Tuple2<Object,java.util.concurrent.TimeUnit>	normalizeDuration(long milliseconds) Find the best TimeUnit for converting milliseconds to a friendly string.
static String	shortTimeUnitString(java.util.concurrent.TimeUnit unit) Return the short string for a TimeUnit.

Methods inherited from class Object

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

Constructor Detail

UIUtils

public UIUtils()

Method Detail

shortTimeUnitString

public static String shortTimeUnitString(java.util.concurrent.TimeUnit unit)

Return the short string for a TimeUnit.

Parameters:

unit - (undocumented)

Returns:

(undocumented)

normalizeDuration

public static scala.Tuple2<Object,java.util.concurrent.TimeUnit> normalizeDuration(long milliseconds)

Find the best TimeUnit for converting milliseconds to a friendly string. Return the value after converting, also with its TimeUnit.

Parameters:

milliseconds - (undocumented)

Returns:

(undocumented)

convertToTimeUnit

public static double convertToTimeUnit(long milliseconds,
                                       java.util.concurrent.TimeUnit unit)

Convert milliseconds to the specified unit. We cannot use TimeUnit.convert because it will discard the fractional part.

Parameters:

milliseconds - (undocumented)

unit - (undocumented)

Returns:

(undocumented)

createOutputOperationFailureForUI

public static String createOutputOperationFailureForUI(String failure)

failureReasonCell

public static scala.collection.Seq<scala.xml.Node> failureReasonCell(String failureReason,
                                                                     int rowspan,
                                                                     boolean includeFirstLineInExpandDetails)