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 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)

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()

dropInstance

public static void dropInstance()

This method is only used by test code to reset state.

init

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

Throws:

IOException

getResourcesDir

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

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