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 String	formatBatchTime(long batchTime, long batchInterval, boolean showYYYYMMSS, java.util.TimeZone timezone) If batchInterval is less than 1 second, format batchTime with milliseconds.
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)

formatBatchTime

public static String formatBatchTime(long batchTime,
                                     long batchInterval,
                                     boolean showYYYYMMSS,
                                     java.util.TimeZone timezone)

If batchInterval is less than 1 second, format batchTime with milliseconds. Otherwise, format batchTime without milliseconds.

Parameters:

batchTime - the batch time to be formatted

batchInterval - the batch interval

showYYYYMMSS - if showing the yyyy/MM/dd part. If it's false, the return value wll be only HH:mm:ss or HH:mm:ss.SSS depending on batchInterval

timezone - only for test

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)