|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||
public interface YarnResourceLocalizerConfigurer
Interface for YarnResourceLocalizerBuilder used from
a SpringYarnConfigurerAdapter.
Typically configuration is used as shown below.
@Configuration
@EnableYarn
static class Config extends SpringYarnConfigurerAdapter {
@Override
public void configure(YarnResourceLocalizerConfigure localizer) throws Exception {
localizer
.withCopy()
.copy("foo.jar", "/tmp", true)
.and()
.withHdfs()
.hdfs("/tmp/foo.jar");
}
}
| Method Summary | |
|---|---|
YarnResourceLocalizerConfigurer |
stagingDirectory(String stagingDirectory)
|
LocalResourcesCopyConfigurer |
withCopy()
Specify configuration options as properties with a DefaultLocalResourcesCopyConfigurer. |
LocalResourcesHdfsConfigurer |
withHdfs()
Specify configuration options as properties with a DefaultLocalResourcesCopyConfigurer. |
| Method Detail |
|---|
LocalResourcesCopyConfigurer withCopy()
throws Exception
DefaultLocalResourcesCopyConfigurer.
public void configure(YarnResourceLocalizerConfigure localizer) throws Exception {
localizer
.withCopy()
.copy("foo.jar", "/tmp", true);
}
<yarn:localresources> <:hdfs path="/tmp/foo.jar" staging="false"/> </yarn:localresources>
LocalResourcesCopyConfigurer for chaining
Exception - if error occurred
LocalResourcesHdfsConfigurer withHdfs()
throws Exception
DefaultLocalResourcesCopyConfigurer.
public void configure(YarnResourceLocalizerConfigure localizer) throws Exception {
localizer
.withHdfs()
.hdfs("/tmp/foo.jar");
}
<yarn:localresources> <:hdfs path="/tmp/foo.jar" staging="false"/> </yarn:localresources>
LocalResourcesCopyConfigurer for chaining
Exception - if error occurred
YarnResourceLocalizerConfigurer stagingDirectory(String stagingDirectory)
throws Exception
Exception
|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||