edu.stolaf.cs.wmrserver.streaming
Class StreamUtil

java.lang.Object
  edu.stolaf.cs.wmrserver.streaming.StreamUtil

public class StreamUtil
extends java.lang.Object

Utilities not available elsewhere in Hadoop.

Constructor Summary

StreamUtil()

Method Summary

static java.lang.String	classNameToPath(java.lang.String className)
static java.lang.String	findInClasspath(java.lang.Class<?> clazz)
static java.lang.String	findInClasspath(java.lang.String className)
static java.lang.String	findInClasspath(java.lang.String className, java.lang.ClassLoader loader)
static java.lang.String	getClassBasePath(java.net.URL classUrl, java.lang.Class<?> clazz)
static java.lang.String	getClassBasePath(java.net.URL classUrl, java.lang.String className)
static java.net.URL	getClassResource(java.lang.Class<?> clazz)
static java.net.URL	getClassResource(java.lang.String className, java.lang.ClassLoader loader)
static edu.stolaf.cs.wmrserver.streaming.StreamUtil.TaskId	getTaskInfo(org.apache.hadoop.mapred.JobConf job)
static boolean	isLocalJobTracker(org.apache.hadoop.mapred.JobConf job)

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamUtil

public StreamUtil()

Method Detail

getClassResource

public static java.net.URL getClassResource(java.lang.Class<?> clazz)

classNameToPath

public static java.lang.String classNameToPath(java.lang.String className)

getClassResource

public static java.net.URL getClassResource(java.lang.String className,
                                            java.lang.ClassLoader loader)

getClassBasePath

public static java.lang.String getClassBasePath(java.net.URL classUrl,
                                                java.lang.Class<?> clazz)

getClassBasePath

public static java.lang.String getClassBasePath(java.net.URL classUrl,
                                                java.lang.String className)

findInClasspath

public static java.lang.String findInClasspath(java.lang.String className)

findInClasspath

public static java.lang.String findInClasspath(java.lang.String className,
                                               java.lang.ClassLoader loader)

Returns:

a jar file path or a base directory or null if not found.

findInClasspath

public static java.lang.String findInClasspath(java.lang.Class<?> clazz)

isLocalJobTracker

public static boolean isLocalJobTracker(org.apache.hadoop.mapred.JobConf job)

getTaskInfo

public static edu.stolaf.cs.wmrserver.streaming.StreamUtil.TaskId getTaskInfo(org.apache.hadoop.mapred.JobConf job)