org.apache.reef.runtime.yarn.client.uploader

Class JobFolder

java.lang.Object

org.apache.reef.runtime.yarn.client.uploader.JobFolder

public final class JobFolder
extends Object

Helper class that represents a folder on the destination filesystem.

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.hadoop.yarn.api.records.LocalResource	getLocalResourceForPath(org.apache.hadoop.fs.Path jarPath, org.apache.hadoop.yarn.api.records.LocalResourceType type) Creates a LocalResource instance for the JAR file referenced by the given Path.
org.apache.hadoop.fs.Path	getPath()
org.apache.hadoop.fs.Path	upload(File localFile) Uploads the given file to the DFS.
org.apache.hadoop.yarn.api.records.LocalResource	uploadAsLocalResource(File localFile, org.apache.hadoop.yarn.api.records.LocalResourceType type) Shortcut to first upload the file and then form a LocalResource for the YARN submission.

Methods inherited from class java.lang.Object

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

Method Detail

upload

public org.apache.hadoop.fs.Path upload(File localFile)
                                 throws IOException

Uploads the given file to the DFS.

Parameters:

localFile -

Returns:

the Path representing the file on the DFS.

Throws:

IOException

uploadAsLocalResource

public org.apache.hadoop.yarn.api.records.LocalResource uploadAsLocalResource(File localFile,
                                                                     org.apache.hadoop.yarn.api.records.LocalResourceType type)
                                                                       throws IOException

Shortcut to first upload the file and then form a LocalResource for the YARN submission.

Parameters:

localFile -

Returns:

Throws:

IOException

getLocalResourceForPath

public org.apache.hadoop.yarn.api.records.LocalResource getLocalResourceForPath(org.apache.hadoop.fs.Path jarPath,
                                                                       org.apache.hadoop.yarn.api.records.LocalResourceType type)
                                                                         throws IOException

Creates a LocalResource instance for the JAR file referenced by the given Path.

Throws:

IOException

getPath

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

Returns:

the Path on the DFS represented by this object.