|
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 LocalResource
s 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 |