org.apache.pig.backend.hadoop.executionengine.tez

Class TezResourceManager

java.lang.Object

org.apache.pig.backend.hadoop.executionengine.tez.TezResourceManager

public class TezResourceManager
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
Map<String,org.apache.hadoop.fs.Path>	resources

Constructor Summary

Constructors

Constructor and Description
TezResourceManager()

Method Summary

Methods

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 TezResourceManager	getInstance()
org.apache.hadoop.fs.Path	getStagingDir()
Map<String,org.apache.hadoop.yarn.api.records.LocalResource>	getTezResources(Set<String> resourceNames)
void	init(PigContext pigContext, org.apache.hadoop.conf.Configuration conf)

Methods inherited from class java.lang.Object

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

Field Detail

resources

public Map<String,org.apache.hadoop.fs.Path> resources

Constructor Detail

TezResourceManager

public TezResourceManager()

Method Detail

getInstance

public static TezResourceManager getInstance()

init

public void init(PigContext pigContext,
        org.apache.hadoop.conf.Configuration conf)
          throws IOException

Throws:

IOException

getStagingDir

public org.apache.hadoop.fs.Path getStagingDir()

addTezResource

public org.apache.hadoop.fs.Path addTezResource(URI uri)
                                         throws IOException

Throws:

IOException

addTezResource

public void addTezResource(String resourceName,
                  org.apache.hadoop.fs.Path remoteFsPath)
                    throws IOException

Throws:

IOException

addTezResources

public Map<String,org.apache.hadoop.yarn.api.records.LocalResource> addTezResources(Set<URI> resources)
                                                                             throws Exception

Throws:

Exception

getTezResources

public Map<String,org.apache.hadoop.yarn.api.records.LocalResource> getTezResources(Set<String> resourceNames)
                                                                             throws Exception

Throws:

Exception