public class TaskDistributedCacheManager
extends java.lang.Object
TrackerDistributedCacheManager
that represents
the cached files of a single job.
This class is internal to Hadoop, and should not be treated as a public
interface.Modifier and Type | Method and Description |
---|---|
java.util.List<java.lang.String> |
getClassPaths()
Retrieves class paths (as local references) to add.
|
java.lang.ClassLoader |
makeClassLoader(java.lang.ClassLoader parent)
Creates a class loader that includes the designated
files and archives.
|
void |
release()
Releases the cached files/archives, so that space
can be reclaimed by the
TrackerDistributedCacheManager . |
void |
setSizes(long[] sizes) |
void |
setupCache(org.apache.hadoop.conf.Configuration taskConf,
java.lang.String publicCacheSubdir,
java.lang.String privateCacheSubdir)
Retrieve public distributed cache files into the local cache and updates
the task configuration (which has been passed in via the constructor).
|
public void setupCache(org.apache.hadoop.conf.Configuration taskConf, java.lang.String publicCacheSubdir, java.lang.String privateCacheSubdir) throws java.io.IOException
JobLocalizer
.
It is the caller's responsibility to re-write the task configuration XML
file, if necessary.java.io.IOException
public java.util.List<java.lang.String> getClassPaths() throws java.io.IOException
java.io.IOException
public void release() throws java.io.IOException
TrackerDistributedCacheManager
.java.io.IOException
public void setSizes(long[] sizes) throws java.io.IOException
java.io.IOException
public java.lang.ClassLoader makeClassLoader(java.lang.ClassLoader parent) throws java.net.MalformedURLException
java.net.MalformedURLException
Copyright © 2009 The Apache Software Foundation