org.apache.spark.streaming.ui

Class UIUtils

java.lang.Object

org.apache.spark.streaming.ui.UIUtils

public class UIUtils
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
UIUtils()

Method Summary

Methods

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

Methods inherited from class java.lang.Object

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

Constructor Detail

UIUtils

public UIUtils()

Method Detail

shortTimeUnitString

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

Return the short string for a TimeUnit.

Parameters:

unit - (undocumented)

Returns:

(undocumented)

normalizeDuration

public static scala.Tuple2<java.lang.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 java.lang.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 java.lang.String createOutputOperationFailureForUI(java.lang.String failure)

failureReasonCell

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