public class TaskDistributedCacheManager extends 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.限定符和类型 | 方法和说明 |
---|---|
List<String> |
getClassPaths()
Retrieves class paths (as local references) to add.
|
ClassLoader |
makeClassLoader(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(Configuration taskConf,
String publicCacheSubdir,
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(Configuration taskConf, String publicCacheSubdir, String privateCacheSubdir) throws IOException
JobLocalizer
.
It is the caller's responsibility to re-write the task configuration XML
file, if necessary.IOException
public List<String> getClassPaths() throws IOException
IOException
public void release() throws IOException
TrackerDistributedCacheManager
.IOException
public void setSizes(long[] sizes) throws IOException
IOException
public ClassLoader makeClassLoader(ClassLoader parent) throws MalformedURLException
Copyright © 2009 The Apache Software Foundation