org.apache.drill.yarn.core

Class DoYUtil

java.lang.Object

org.apache.drill.yarn.core.DoYUtil

public class DoYUtil
extends Object

Method Summary

Modifier and Type	Method and Description
static void	addNonEmpty(List<String> list, String value)
static double	callGetDiskIfExists(Object target)
static void	callSetDiskIfExists(Object target, double arg)
static String	describeContainer(org.apache.hadoop.yarn.api.records.Container container) Utility method to display YARN container information in a useful way for log messages.
static Object	dynamicCall(Object target, String fnName, Object[] args, Class<?>[] types)
static boolean	isBlank(String str)
static String	join(String separator, List<String> list)
static String	labelContainer(org.apache.hadoop.yarn.api.records.Container container)
static String	toIsoTime(long timestamp)
static String	unwrapAmUrl(String trackingUrl) The tracking URL given to YARN is a redirect URL.

Methods inherited from class java.lang.Object

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

Method Detail

join

public static String join(String separator,
                          List<String> list)

addNonEmpty

public static void addNonEmpty(List<String> list,
                               String value)

isBlank

public static boolean isBlank(String str)

toIsoTime

public static String toIsoTime(long timestamp)

labelContainer

public static String labelContainer(org.apache.hadoop.yarn.api.records.Container container)

describeContainer

public static String describeContainer(org.apache.hadoop.yarn.api.records.Container container)

Utility method to display YARN container information in a useful way for log messages.

Parameters:

container -

Returns:

unwrapAmUrl

public static String unwrapAmUrl(String trackingUrl)

The tracking URL given to YARN is a redirect URL. When giving the URL to the user, "unwrap" that redirect URL to get the actual site URL.

Parameters:

trackingUrl -

Returns:

dynamicCall

public static Object dynamicCall(Object target,
                                 String fnName,
                                 Object[] args,
                                 Class<?>[] types)

callSetDiskIfExists

public static void callSetDiskIfExists(Object target,
                                       double arg)

callGetDiskIfExists

public static double callGetDiskIfExists(Object target)