public class JarManager
extends java.lang.Object
Constructor and Description |
---|
JarManager() |
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 void |
createJar(java.io.OutputStream os,
java.util.Set<java.lang.String> funcs,
PigContext pigContext)
Create a jarfile in a temporary path, that is a merge of all the jarfiles containing the
functions and the core pig classes.
|
static java.lang.String |
findContainingJar(java.lang.Class my_class)
Find a jar that contains a class of the same name, if any.
|
public static void createJar(java.io.OutputStream os, java.util.Set<java.lang.String> funcs, PigContext pigContext) throws java.lang.ClassNotFoundException, java.io.IOException
funcs
- the functions that will be used in a job and whose jar files need to be included
in the final merged jar file.java.lang.ClassNotFoundException
java.io.IOException
public static java.lang.String findContainingJar(java.lang.Class my_class)
my_class
- the class to findjava.io.IOException
public static void addDependencyJars(org.apache.hadoop.mapreduce.Job job, java.lang.Class<?>... classes) throws java.io.IOException
job
- Job objectclasses
- classes to findjava.io.IOException
Copyright © 2007-2012 The Apache Software Foundation