public final class YarnResourceLocalizerBuilder extends AbstractConfiguredAnnotationBuilder<ResourceLocalizer,YarnResourceLocalizerConfigurer,YarnResourceLocalizerBuilder> implements YarnResourceLocalizerConfigurer
コンストラクターと説明 |
---|
YarnResourceLocalizerBuilder() 新しい yarn リソースローカライザービルダーをインスタンス化します。 |
apply, apply, beforeConfigureMains, beforeConfigurePosts, beforeInit, doBuild, getConfigurer, getConfigurers, getOrApply, getOrBuild, getSharedObject, getSharedObjects, objectPostProcessor, postProcess, removeConfigurer, removeConfigurers, setSharedObject
build, getObject
public YarnResourceLocalizerBuilder()
protected ResourceLocalizer performBuild() throws java.lang.Exception
AbstractConfiguredAnnotationBuilder
AbstractConfiguredAnnotationBuilder<ResourceLocalizer, YarnResourceLocalizerConfigurer, YarnResourceLocalizerBuilder>
の performBuild
java.lang.Exception
- エラー時 public LocalResourcesCopyConfigurer withCopy() throws java.lang.Exception
YarnResourceLocalizerConfigurer
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>
YarnResourceLocalizerConfigurer
の withCopy
LocalResourcesCopyConfigurer
java.lang.Exception
- エラーが発生した場合 public LocalResourcesHdfsConfigurer withHdfs() throws java.lang.Exception
YarnResourceLocalizerConfigurer
DefaultLocalResourcesHdfsConfigurer
を使用して、構成オプションをプロパティとして指定します。public void configure(YarnResourceLocalizerConfigure localizer) throws Exception { localizer .withHdfs() .hdfs("/tmp/foo.jar"); }
<yarn:localresources> <:hdfs path="/tmp/foo.jar" staging="false"/> </yarn:localresources>
YarnResourceLocalizerConfigurer
の withHdfs
LocalResourcesHdfsConfigurer
java.lang.Exception
- エラーが発生した場合 public LocalResourcesHdfsConfigurer withHdfs(java.lang.String id) throws java.lang.Exception
YarnResourceLocalizerConfigurer
DefaultLocalResourcesHdfsConfigurer
を使用して、構成オプションをプロパティとして指定します。YarnResourceLocalizerConfigurer
の withHdfs
id
- 識別子 LocalResourcesHdfsConfigurer
java.lang.Exception
- エラーが発生した場合 YarnResourceLocalizerConfigurer.withHdfs()
public YarnResourceLocalizerConfigurer stagingDirectory(java.lang.String stagingDirectory)
YarnResourceLocalizerConfigurer
YarnResourceLocalizerConfigurer
の stagingDirectory
stagingDirectory
- ステージングディレクトリ YarnResourceLocalizerConfigurer
public void configuration(org.apache.hadoop.conf.Configuration configuration)
public YarnResourceLocalizerConfigurer defaultLocalResourceType(org.apache.hadoop.yarn.api.records.LocalResourceType type)
public YarnResourceLocalizerConfigurer defaultLocalResourceVisibility(org.apache.hadoop.yarn.api.records.LocalResourceVisibility visibility)
public void setCopyEntries(java.util.Collection<LocalResourcesFactoryBean.CopyEntry> copyEntries)
public void setHdfsEntries(java.util.Collection<LocalResourcesFactoryBean.TransferEntry> transferEntries)
public void setHdfsEntries(java.lang.String id, java.util.Collection<LocalResourcesFactoryBean.TransferEntry> transferEntries)
public void setRawCopyEntries(java.util.Collection<LocalResourcesFactoryBean.RawCopyEntry> rawEntries)