azkaban.utils

Class Utils

java.lang.Object

azkaban.utils.Utils

public class Utils
extends java.lang.Object

A util helper class full of static methods that are commonly used.

Method Summary

Modifier and Type	Method and Description
static java.lang.Object	callConstructor(java.lang.Class<?> cls, java.lang.Object... args) Construct a class object with the given arguments
static java.lang.Double	convertToDouble(java.lang.Object obj)
static void	copyStream(java.io.InputStream input, java.io.OutputStream output)
static java.io.File	createTempDir()
static java.io.File	createTempDir(java.io.File parent)
static void	croak(java.lang.String message, int exitCode) Print the message and then exit with the given exit code
static boolean	equals(java.lang.Object a, java.lang.Object b) Equivalent to Object.equals except that it handles nulls.
static java.io.File	findFilefromDir(java.io.File dir, java.lang.String fn)
static java.lang.String	flattenToString(java.util.Collection<?> collection, java.lang.String delimiter)
static <T> T	ifNull(T value, T defaultValue) Return the value itself if it is non-null, otherwise return the default value
static java.lang.Object	invokeStaticMethod(java.lang.ClassLoader loader, java.lang.String className, java.lang.String methodName, java.lang.Object... args)
static boolean	isCronExpressionValid(java.lang.String cronExpression, org.joda.time.DateTimeZone timezone)
static boolean	isValidPort(int port) Tests whether a port is valid or not
static void	mergeStringList(java.util.List<java.lang.String> destinationList, java.util.List<java.lang.String> sourceList) Merge elements in Source List into the Destination List
static void	mergeTypeClassPaths(java.util.List<java.lang.String> destinationPaths, java.util.List<java.lang.String> sourcePaths, java.lang.String rootPath) Merge the absolute paths of source paths into the list of destination paths
static <T> T	nonNull(T t) Return the object if it is non-null, otherwise throw an exception
static org.quartz.CronExpression	parseCronExpression(java.lang.String cronExpression, org.joda.time.DateTimeZone timezone)
static long	parseMemString(java.lang.String strMemSize)
static java.util.ArrayList<java.lang.String>	runProcess(java.lang.String... commands) Run a sequence of commands
static void	unzip(java.util.zip.ZipFile source, java.io.File dest)
static void	zip(java.io.File input, java.io.File output)
static void	zipFolderContent(java.io.File folder, java.io.File output)

Methods inherited from class java.lang.Object

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

Method Detail

equals

public static boolean equals(java.lang.Object a,
                             java.lang.Object b)

Equivalent to Object.equals except that it handles nulls. If a and b are both null, true is returned.

nonNull

public static <T> T nonNull(T t)

Return the object if it is non-null, otherwise throw an exception

Type Parameters:

T - The type of the object

Parameters:

t - The object

Returns:

The object if it is not null

Throws:

java.lang.IllegalArgumentException - if the object is null

findFilefromDir

public static java.io.File findFilefromDir(java.io.File dir,
                                           java.lang.String fn)

ifNull

public static <T> T ifNull(T value,
                           T defaultValue)

Return the value itself if it is non-null, otherwise return the default value

Type Parameters:

T - The type of the object

Parameters:

value - The object

defaultValue - default value if object == null

Returns:

The object itself or default value when it is null

croak

public static void croak(java.lang.String message,
                         int exitCode)

Print the message and then exit with the given exit code

Parameters:

message - The message to print

exitCode - The exit code

isValidPort

public static boolean isValidPort(int port)

Tests whether a port is valid or not

Returns:

true, if port is valid

createTempDir

public static java.io.File createTempDir()

createTempDir

public static java.io.File createTempDir(java.io.File parent)

zip

public static void zip(java.io.File input,
                       java.io.File output)
                throws java.io.IOException

Throws:

java.io.IOException

zipFolderContent

public static void zipFolderContent(java.io.File folder,
                                    java.io.File output)
                             throws java.io.IOException

Throws:

java.io.IOException

unzip

public static void unzip(java.util.zip.ZipFile source,
                         java.io.File dest)
                  throws java.io.IOException

Throws:

java.io.IOException

flattenToString

public static java.lang.String flattenToString(java.util.Collection<?> collection,
                                               java.lang.String delimiter)

convertToDouble

public static java.lang.Double convertToDouble(java.lang.Object obj)

callConstructor

public static java.lang.Object callConstructor(java.lang.Class<?> cls,
                                               java.lang.Object... args)

Construct a class object with the given arguments

Parameters:

cls - The class

args - The arguments

Returns:

Constructed Object

invokeStaticMethod

public static java.lang.Object invokeStaticMethod(java.lang.ClassLoader loader,
                                                  java.lang.String className,
                                                  java.lang.String methodName,
                                                  java.lang.Object... args)
                                           throws java.lang.ClassNotFoundException,
                                                  java.lang.SecurityException,
                                                  java.lang.NoSuchMethodException,
                                                  java.lang.IllegalArgumentException,
                                                  java.lang.IllegalAccessException,
                                                  java.lang.reflect.InvocationTargetException

Throws:

java.lang.ClassNotFoundException

java.lang.SecurityException

java.lang.NoSuchMethodException

java.lang.IllegalArgumentException

java.lang.IllegalAccessException

java.lang.reflect.InvocationTargetException

copyStream

public static void copyStream(java.io.InputStream input,
                              java.io.OutputStream output)
                       throws java.io.IOException

Throws:

java.io.IOException

parseMemString

public static long parseMemString(java.lang.String strMemSize)

Parameters:

strMemSize - : memory string in the format such as 1G, 500M, 3000K, 5000

Returns:

: long value of memory amount in kb

parseCronExpression

public static org.quartz.CronExpression parseCronExpression(java.lang.String cronExpression,
                                                            org.joda.time.DateTimeZone timezone)

Parameters:

cronExpression: - A cron expression is a string separated by white space, to provide a parser and evaluator for Quartz cron expressions.

Returns:

: org.quartz.CronExpression object. TODO: Currently, we have to transform Joda Timezone to Java Timezone due to CronExpression. Since Java8 enhanced Time functionalities, We consider transform all Jodatime to Java Time in future.

isCronExpressionValid

public static boolean isCronExpressionValid(java.lang.String cronExpression,
                                            org.joda.time.DateTimeZone timezone)

Returns:

if the cronExpression is valid or not.

runProcess

public static java.util.ArrayList<java.lang.String> runProcess(java.lang.String... commands)
                                                        throws java.lang.InterruptedException,
                                                               java.io.IOException

Run a sequence of commands

Parameters:

commands - sequence of commands

Returns:

list of output result

Throws:

java.lang.InterruptedException

java.io.IOException

mergeTypeClassPaths

public static void mergeTypeClassPaths(java.util.List<java.lang.String> destinationPaths,
                                       java.util.List<java.lang.String> sourcePaths,
                                       java.lang.String rootPath)

Merge the absolute paths of source paths into the list of destination paths

Parameters:

destinationPaths - the path list which the source paths will be merged into

sourcePaths - source paths

rootPath - defined root path for source paths when they are not absolute path

mergeStringList

public static void mergeStringList(java.util.List<java.lang.String> destinationList,
                                   java.util.List<java.lang.String> sourceList)

Merge elements in Source List into the Destination List

Parameters:

destinationList - the list which the source elements will be merged into

sourceList - source List