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

Class TezResourceManager

java.lang.Object

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

public class TezResourceManager
extends java.lang.Object

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
TezResourceManager()

Method Summary

Modifier and Type	Method and Description
void	addTezResource(java.lang.String resourceName, org.apache.hadoop.fs.Path remoteFsPath)
org.apache.hadoop.fs.Path	addTezResource(java.net.URI uri)
java.util.Map<java.lang.String,org.apache.hadoop.yarn.api.records.LocalResource>	addTezResources(java.util.Set<java.net.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()
java.util.Map<java.lang.String,org.apache.hadoop.yarn.api.records.LocalResource>	getTezResources(java.util.Set<java.lang.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 java.util.Map<java.lang.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 java.io.IOException

Throws:

java.io.IOException

getResourcesDir

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

addTezResource

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

Throws:

java.io.IOException

addTezResource

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

Throws:

java.io.IOException

addTezResources

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

Throws:

java.lang.Exception

getTezResources

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

Throws:

java.lang.Exception