org.apache.pig.impl.util

Class JarManager

java.lang.Object

org.apache.pig.impl.util.JarManager

public class JarManager
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
JarManager()

Method Summary

Methods

Modifier and Type	Method and Description
static void	addDependencyJars(org.apache.hadoop.mapreduce.Job job, java.lang.Class<?>... classes) Add the jars containing the given classes to the job's configuration such that JobClient will ship them to the cluster and add them to the DistributedCache
static java.io.File	createPigScriptUDFJar(PigContext pigContext)
static java.lang.String	findContainingJar(java.lang.Class my_class) Find a jar that contains a class of the same name, if any.
static java.util.List<java.lang.String>	getDefaultJars()

Methods inherited from class java.lang.Object

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

Constructor Detail

JarManager

public JarManager()

Method Detail

createPigScriptUDFJar

public static java.io.File createPigScriptUDFJar(PigContext pigContext)
                                          throws java.io.IOException

Throws:

java.io.IOException

getDefaultJars

public static java.util.List<java.lang.String> getDefaultJars()

findContainingJar

public static java.lang.String findContainingJar(java.lang.Class my_class)

Find a jar that contains a class of the same name, if any. It will return a jar file, even if that is not the first thing on the class path that has a class with the same name.

Parameters:

my_class - the class to find

Returns:

a jar file that contains the class, or null

Throws:

java.io.IOException

addDependencyJars

public static void addDependencyJars(org.apache.hadoop.mapreduce.Job job,
                     java.lang.Class<?>... classes)
                              throws java.io.IOException

Add the jars containing the given classes to the job's configuration such that JobClient will ship them to the cluster and add them to the DistributedCache

Parameters:

job - Job object

classes - classes to find

Throws:

java.io.IOException