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

Methods

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,LocalResource>	addTezResources(java.util.Set<java.net.URI> resources)
static TezResourceManager	getInstance()
org.apache.hadoop.fs.Path	getStagingDir()
java.util.Map<java.lang.String,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()

init

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

Throws:

java.io.IOException

getStagingDir

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

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,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,LocalResource> getTezResources(java.util.Set<java.lang.String> resourceNames)
                                                              throws java.lang.Exception

Throws:

java.lang.Exception