|
Spring for Apache Hadoop | ||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||
public interface ResourceLocalizer
Interface for resource localizer implementation. This loosely
follows requirements for Yarn's file distribution of
LocalResource instances.
| Method Summary | |
|---|---|
boolean |
clean()
Cleans all leftovers what has been created during the distribute process. |
void |
distribute()
If underlying implementation needs to do operations on hdfs filesystem or any other preparation work, calling of this method should make implementation ready to return resources from getResources()
command. |
java.util.Map<java.lang.String,org.apache.hadoop.yarn.api.records.LocalResource> |
getResources()
Gets a map of LocalResource instances. |
void |
setStagingDirectory(org.apache.hadoop.fs.Path stagingDirectory)
Sets the staging directory. |
void |
setStagingId(java.lang.String stagingId)
Sets the staging id. |
| Method Detail |
|---|
java.util.Map<java.lang.String,org.apache.hadoop.yarn.api.records.LocalResource> getResources()
LocalResource instances. Underlying
instances of LocalResources needs to be fully
initialised including resource size and timestamp.
LocalResource instancesvoid distribute()
getResources()
command.
void setStagingDirectory(org.apache.hadoop.fs.Path stagingDirectory)
stagingDirectory - the new staging directoryvoid setStagingId(java.lang.String stagingId)
Path
set in setStagingDirectory(Path) to post fix unique
runtime staging path. If not set simultaneous instances of
same application may override files.
stagingId - the new staging idboolean clean()
|
Spring for Apache Hadoop | ||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||