public final class YarnResourceLocalizerBuilder extends org.springframework.data.hadoop.config.common.annotation.AbstractConfiguredAnnotationBuilder<ResourceLocalizer,YarnResourceLocalizerConfigurer,YarnResourceLocalizerBuilder> implements YarnResourceLocalizerConfigurer
AnnotationBuilder for ResourceLocalizer.| Constructor and Description |
|---|
YarnResourceLocalizerBuilder()
Instantiates a new yarn resource localizer builder.
|
apply, apply, beforeConfigureMains, beforeConfigurePosts, beforeInit, doBuild, getConfigurer, getConfigurers, getOrApply, getOrBuild, getSharedObject, getSharedObjects, objectPostProcessor, postProcess, removeConfigurer, removeConfigurers, setSharedObjectpublic YarnResourceLocalizerBuilder()
protected ResourceLocalizer performBuild() throws Exception
performBuild in class org.springframework.data.hadoop.config.common.annotation.AbstractConfiguredAnnotationBuilder<ResourceLocalizer,YarnResourceLocalizerConfigurer,YarnResourceLocalizerBuilder>Exceptionpublic LocalResourcesCopyConfigurer withCopy() throws Exception
YarnResourceLocalizerConfigurerDefaultLocalResourcesCopyConfigurer.
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>
withCopy in interface YarnResourceLocalizerConfigurerLocalResourcesCopyConfigurer for chainingException - if error occurredpublic LocalResourcesHdfsConfigurer withHdfs() throws Exception
YarnResourceLocalizerConfigurerDefaultLocalResourcesHdfsConfigurer.
public void configure(YarnResourceLocalizerConfigure localizer) throws Exception {
localizer
.withHdfs()
.hdfs("/tmp/foo.jar");
}
<yarn:localresources> <:hdfs path="/tmp/foo.jar" staging="false"/> </yarn:localresources>
withHdfs in interface YarnResourceLocalizerConfigurerLocalResourcesHdfsConfigurer for chainingException - if error occurredpublic LocalResourcesHdfsConfigurer withHdfs(String id) throws Exception
YarnResourceLocalizerConfigurerDefaultLocalResourcesHdfsConfigurer
with an identifier.withHdfs in interface YarnResourceLocalizerConfigurerid - the identifierLocalResourcesHdfsConfigurer for chainingException - if error occurredYarnResourceLocalizerConfigurer.withHdfs()public YarnResourceLocalizerConfigurer stagingDirectory(String stagingDirectory)
YarnResourceLocalizerConfigurerstagingDirectory in interface YarnResourceLocalizerConfigurerstagingDirectory - the staging directoryYarnResourceLocalizerConfigurer for chainingpublic void configuration(Configuration configuration)
public YarnResourceLocalizerConfigurer defaultLocalResourceType(LocalResourceType type)
public YarnResourceLocalizerConfigurer defaultLocalResourceVisibility(LocalResourceVisibility visibility)
public void setCopyEntries(Collection<LocalResourcesFactoryBean.CopyEntry> copyEntries)
public void setHdfsEntries(Collection<LocalResourcesFactoryBean.TransferEntry> transferEntries)
public void setHdfsEntries(String id, Collection<LocalResourcesFactoryBean.TransferEntry> transferEntries)
public void setRawCopyEntries(Collection<LocalResourcesFactoryBean.RawCopyEntry> rawEntries)