public class TempletonUtils
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static java.util.regex.Pattern[] |
ID_PATTERNS |
static java.util.regex.Pattern |
JAR_COMPLETE |
static java.util.regex.Pattern |
JAR_ID |
static java.util.regex.Pattern |
PIG_COMPLETE |
static java.util.regex.Pattern |
PIG_ID |
Constructor and Description |
---|
TempletonUtils() |
Modifier and Type | Method and Description |
---|---|
static void |
addCmdForWindows(java.util.ArrayList<java.lang.String> args) |
static java.lang.String |
addUserHomeDirectoryIfApplicable(java.lang.String origPathStr,
java.lang.String user) |
static java.lang.String[] |
decodeArray(java.lang.String s)
Take an encode strings and decode it into an array of strings.
|
static java.lang.String |
encodeArray(java.util.List<java.lang.String> list)
Encode a List into a string.
|
static java.lang.String |
encodeArray(java.lang.String[] plain)
Take an array of strings and encode it into one string.
|
static java.lang.String |
extractChildJobId(java.lang.String line)
Extract the job id from jar jobs.
|
static java.lang.String |
extractPercentComplete(java.lang.String line)
Extract the percent complete line from Pig or Jar jobs.
|
static int |
fetchUrl(java.net.URL url)
GET the given url.
|
static java.lang.String |
hadoopFsFilename(java.lang.String fname,
Configuration conf,
java.lang.String user) |
static boolean |
hadoopFsIsMissing(FileSystem fs,
Path p) |
static java.lang.String[] |
hadoopFsListAsArray(java.lang.String files,
Configuration conf,
java.lang.String user) |
static java.lang.String |
hadoopFsListAsString(java.lang.String files,
Configuration conf,
java.lang.String user) |
static Path |
hadoopFsPath(java.lang.String fname,
Configuration conf,
java.lang.String user) |
static java.util.Map<java.lang.String,java.lang.String> |
hadoopUserEnv(java.lang.String user,
java.lang.String overrideClasspath)
Set the environment variables to specify the hadoop user.
|
static boolean |
isset(char ch)
Is the object non-empty?
|
static <T> boolean |
isset(java.util.Collection<T> col)
Is the object non-empty?
|
static <K,V> boolean |
isset(java.util.Map<K,V> col)
Is the object non-empty?
|
static boolean |
isset(java.lang.String s)
Is the object non-empty?
|
static <T> boolean |
isset(T[] a)
Is the object non-empty?
|
static java.lang.String |
quoteForWindows(java.lang.String param) |
public static final java.util.regex.Pattern JAR_COMPLETE
public static final java.util.regex.Pattern PIG_COMPLETE
public static final java.util.regex.Pattern JAR_ID
public static final java.util.regex.Pattern PIG_ID
public static final java.util.regex.Pattern[] ID_PATTERNS
public static boolean isset(java.lang.String s)
public static boolean isset(char ch)
public static <T> boolean isset(T[] a)
public static <T> boolean isset(java.util.Collection<T> col)
public static <K,V> boolean isset(java.util.Map<K,V> col)
public static java.lang.String extractPercentComplete(java.lang.String line)
public static java.lang.String extractChildJobId(java.lang.String line)
public static java.lang.String encodeArray(java.lang.String[] plain)
public static java.lang.String encodeArray(java.util.List<java.lang.String> list)
public static java.lang.String[] decodeArray(java.lang.String s)
public static java.lang.String[] hadoopFsListAsArray(java.lang.String files, Configuration conf, java.lang.String user) throws java.net.URISyntaxException, java.io.FileNotFoundException, java.io.IOException, java.lang.InterruptedException
java.net.URISyntaxException
java.io.FileNotFoundException
java.io.IOException
java.lang.InterruptedException
public static java.lang.String hadoopFsListAsString(java.lang.String files, Configuration conf, java.lang.String user) throws java.net.URISyntaxException, java.io.FileNotFoundException, java.io.IOException, java.lang.InterruptedException
java.net.URISyntaxException
java.io.FileNotFoundException
java.io.IOException
java.lang.InterruptedException
public static java.lang.String hadoopFsFilename(java.lang.String fname, Configuration conf, java.lang.String user) throws java.net.URISyntaxException, java.io.FileNotFoundException, java.io.IOException, java.lang.InterruptedException
java.net.URISyntaxException
java.io.FileNotFoundException
java.io.IOException
java.lang.InterruptedException
public static boolean hadoopFsIsMissing(FileSystem fs, Path p)
public static java.lang.String addUserHomeDirectoryIfApplicable(java.lang.String origPathStr, java.lang.String user) throws java.io.IOException, java.net.URISyntaxException
java.io.IOException
java.net.URISyntaxException
public static Path hadoopFsPath(java.lang.String fname, Configuration conf, java.lang.String user) throws java.net.URISyntaxException, java.io.IOException, java.lang.InterruptedException
java.net.URISyntaxException
java.io.IOException
java.lang.InterruptedException
public static int fetchUrl(java.net.URL url) throws java.io.IOException
java.io.IOException
public static java.util.Map<java.lang.String,java.lang.String> hadoopUserEnv(java.lang.String user, java.lang.String overrideClasspath)
public static java.lang.String quoteForWindows(java.lang.String param) throws BadParam
BadParam
public static void addCmdForWindows(java.util.ArrayList<java.lang.String> args)
Copyright © 2012 The Apache Software Foundation