public class TezResourceManager extends Object
Modifier and Type | Field and Description |
---|---|
Map<String,org.apache.hadoop.fs.Path> |
resources |
Constructor and Description |
---|
TezResourceManager() |
Modifier and Type | Method and Description |
---|---|
void |
addTezResource(String resourceName,
org.apache.hadoop.fs.Path remoteFsPath) |
org.apache.hadoop.fs.Path |
addTezResource(URI uri) |
Map<String,org.apache.hadoop.yarn.api.records.LocalResource> |
addTezResources(Set<URI> resources) |
static void |
dropInstance()
This method is only used by test code to reset state.
|
static TezResourceManager |
getInstance() |
org.apache.hadoop.fs.Path |
getResourcesDir() |
Map<String,org.apache.hadoop.yarn.api.records.LocalResource> |
getTezResources(Set<String> resourceNames) |
void |
init(PigContext pigContext,
org.apache.hadoop.conf.Configuration conf) |
public static TezResourceManager getInstance()
public static void dropInstance()
public void init(PigContext pigContext, org.apache.hadoop.conf.Configuration conf) throws IOException
IOException
public org.apache.hadoop.fs.Path getResourcesDir()
public org.apache.hadoop.fs.Path addTezResource(URI uri) throws IOException
IOException
public void addTezResource(String resourceName, org.apache.hadoop.fs.Path remoteFsPath) throws IOException
IOException
public Map<String,org.apache.hadoop.yarn.api.records.LocalResource> addTezResources(Set<URI> resources) throws Exception
Exception
Copyright © 2007-2017 The Apache Software Foundation