org.apache.lens.server.util

Class UtilityMethods

java.lang.Object

org.apache.lens.server.util.UtilityMethods

public final class UtilityMethods
extends Object

The Class UtilityMethods.

Method Summary

Modifier and Type	Method and Description
static boolean	anyNull(Object... args) Any null.
static <T extends Enum<T>> T	checkAndGetOperation(String operation, Class<T> enumType, T... supportedOperations)
static String	confToString(org.apache.hadoop.conf.Configuration conf) Conf to string.
static byte[]	generateHashOfWritable(org.apache.hadoop.io.Writable writable) Generates a md5 hash of a writable object.
static SchedulerJobHandle	generateSchedulerJobHandle()
static SchedulerJobInstanceHandle	generateSchedulerJobInstanceHandle()
static org.apache.commons.dbcp.BasicDataSource	getDataSourceFromConf(org.apache.hadoop.conf.Configuration conf) Gets the data source from conf.
static org.apache.commons.dbcp.BasicDataSource	getDataSourceFromConfForScheduler(org.apache.hadoop.conf.Configuration conf)
static DataSource	getPoolingDataSourceFromConf(org.apache.hadoop.conf.Configuration conf)
static <K,V> void	mergeMaps(Map<K,V> into, Map<K,V> from, boolean override) Merge maps.
static void	pipe(InputStream is, OutputStream os) Pipe input stream to output stream
static String[]	queryDatabase(DataSource ds, String querySql, boolean allowNull, Object... args) Query database.
static String	removeDomain(String username) Removes the domain.

Methods inherited from class java.lang.Object

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

Method Detail

mergeMaps

public static <K,V> void mergeMaps(Map<K,V> into,
                                   Map<K,V> from,
                                   boolean override)

Merge maps.

Type Parameters:

K - the key type

V - the value type

Parameters:

into - the into

from - the from

override - the override

removeDomain

public static String removeDomain(String username)

Removes the domain.

Parameters:

username - the username

Returns:

the string

anyNull

public static boolean anyNull(Object... args)

Any null.

Parameters:

args - the args

Returns:

true, if successful

queryDatabase

public static String[] queryDatabase(DataSource ds,
                                     String querySql,
                                     boolean allowNull,
                                     Object... args)
                              throws SQLException

Query database.

Parameters:

ds - the ds

querySql - the query sql

allowNull - the allow null

args - the args

Returns:

the string[]

Throws:

SQLException - the SQL exception

getDataSourceFromConf

public static org.apache.commons.dbcp.BasicDataSource getDataSourceFromConf(org.apache.hadoop.conf.Configuration conf)

Gets the data source from conf.

Parameters:

conf - the conf

Returns:

the data source from conf

getPoolingDataSourceFromConf

public static DataSource getPoolingDataSourceFromConf(org.apache.hadoop.conf.Configuration conf)

confToString

public static String confToString(org.apache.hadoop.conf.Configuration conf)

Conf to string.

Parameters:

conf - the conf

Returns:

the string

pipe

public static void pipe(InputStream is,
                        OutputStream os)
                 throws IOException

Pipe input stream to output stream

Parameters:

is - the is

os - the os

Throws:

IOException - Signals that an I/O exception has occurred.

generateHashOfWritable

public static byte[] generateHashOfWritable(org.apache.hadoop.io.Writable writable)

Generates a md5 hash of a writable object.

Parameters:

writable -

Returns:

hash of a writable object

getDataSourceFromConfForScheduler

public static org.apache.commons.dbcp.BasicDataSource getDataSourceFromConfForScheduler(org.apache.hadoop.conf.Configuration conf)

Parameters:

conf -

Returns:

generateSchedulerJobHandle

public static SchedulerJobHandle generateSchedulerJobHandle()

generateSchedulerJobInstanceHandle

public static SchedulerJobInstanceHandle generateSchedulerJobInstanceHandle()

checkAndGetOperation

public static <T extends Enum<T>> T checkAndGetOperation(String operation,
                                                         Class<T> enumType,
                                                         T... supportedOperations)
                                                  throws UnSupportedOpException

Throws:

UnSupportedOpException