Package 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	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 Details

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)