public final class YarnAppmasterBuilder extends AbstractConfiguredAnnotationBuilder<YarnAppmaster,YarnAppmasterConfigurer,YarnAppmasterBuilder> implements YarnAppmasterConfigurer
| コンストラクターと説明 |
|---|
YarnAppmasterBuilder() |
YarnAppmasterBuilder(ObjectPostProcessor<java.lang.Object> objectPostProcessor) |
| 修飾子と型 | メソッドと説明 |
|---|---|
YarnAppmasterBuilder | appmasterClass(java.lang.Class<? extends YarnAppmaster> clazz)YarnAppmaster クラスを指定します。 |
YarnAppmasterBuilder | appmasterClass(java.lang.String clazz) 完全修飾クラス名として YarnAppmaster を指定します。 |
void | configuration(org.apache.hadoop.conf.Configuration configuration) |
YarnAppmasterBuilder | containerCommands(java.lang.String[] commands) コンテナーを起動するために使用されるコマンドの生の配列を指定します。 |
YarnAppmasterBuilder | containerCommands(java.lang.String id, java.lang.String[] commands) コンテナーを起動するために使用されるコマンドの生の配列を指定します。 |
protected YarnAppmaster | performBuild() サブクラスはこのメソッドを実装して、返されるオブジェクトを構築する必要があります。 |
void | setContainerAllocator(ContainerAllocator containerAllocator) |
void | setEnvironment(java.util.Map<java.lang.String,java.lang.String> environment) |
void | setEnvironments(java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.String>> environments) |
void | setResourceLocalizer(ResourceLocalizer resourceLocalizer) |
MasterContainerAllocatorConfigurer | withContainerAllocator()Appmaster のコンテナーアロケータを指定します。 |
MasterContainerRunnerConfigurer | withContainerRunner()Appmaster のコンテナーランナーを指定します。 |
apply, apply, beforeConfigureMains, beforeConfigurePosts, beforeInit, doBuild, getConfigurer, getConfigurers, getOrApply, getOrBuild, getSharedObject, getSharedObjects, objectPostProcessor, postProcess, removeConfigurer, removeConfigurers, setSharedObjectbuild, getObjectpublic YarnAppmasterBuilder()
public YarnAppmasterBuilder(ObjectPostProcessor<java.lang.Object> objectPostProcessor)
protected YarnAppmaster performBuild() throws java.lang.Exception
AbstractConfiguredAnnotationBuilderAbstractConfiguredAnnotationBuilder<YarnAppmaster, YarnAppmasterConfigurer, YarnAppmasterBuilder> の performBuild java.lang.Exception - エラー時 public MasterContainerRunnerConfigurer withContainerRunner() throws java.lang.Exception
YarnAppmasterConfigurerDefaultMasterContainerRunnerConfigurer を現在のビルダーに適用します。
public void configure(YarnAppmasterConfigure master) throws Exception {
Properties properties = new Properties();
properties.setProperty("foo1", "bar1");
master
.withContainerRunner()
.arguments(properties)
.argument("foo2", "bar2");
}
<util:properties id="arguments"> <prop key="foo1">bar1</prop> <prop key="foo2">bar2</prop> </util:properties> <yarn:master> <yarn:container-runner arguments="arguments"/> </yarn:master>
YarnAppmasterConfigurer 内の withContainerRunner MasterContainerRunnerConfigurerjava.lang.Exception - 例外 public MasterContainerAllocatorConfigurer withContainerAllocator() throws java.lang.Exception
YarnAppmasterConfigurerDefaultMasterContainerAllocatorConfigurer を現在のビルダーに適用します。
public void configure(YarnAppmasterConfigure master) throws Exception {
master
.withContainerAllocator()
.priority(0)
.virtualCores(1)
.memory(1024);
}
<yarn:master> <yarn:container-allocator priority="0" virtualcores="1" memory="1024"/> </yarn:master>
YarnAppmasterConfigurer 内の withContainerAllocator MasterContainerAllocatorConfigurerjava.lang.Exception - 例外 public void configuration(org.apache.hadoop.conf.Configuration configuration)
public void setResourceLocalizer(ResourceLocalizer resourceLocalizer)
public void setContainerAllocator(ContainerAllocator containerAllocator)
public void setEnvironment(java.util.Map<java.lang.String,java.lang.String> environment)
public void setEnvironments(java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.String>> environments)
public YarnAppmasterBuilder appmasterClass(java.lang.Class<? extends YarnAppmaster> clazz)
YarnAppmasterConfigurerYarnAppmaster クラスを指定します。
public void configure(YarnAppmasterConfigure master) throws Exception {
master
.appmasterClass(MyYarnAppmaster.class);
}
<yarn:master appmaster-class="com.example.MyYarnAppmaster"/>
YarnAppmasterConfigurer 内の appmasterClass clazz - Yarn アプリマスタークラス YarnAppmasterConfigurerpublic YarnAppmasterBuilder appmasterClass(java.lang.String clazz)
YarnAppmasterConfigurerYarnAppmaster を指定します。
public void configure(YarnAppmasterConfigure master) throws Exception {
master
.appmasterClass(MyYarnAppmaster.class);
}
YarnAppmasterConfigurer 内の appmasterClass clazz - Yarn アプリマスタークラス YarnAppmasterConfigurerpublic YarnAppmasterBuilder containerCommands(java.lang.String[] commands)
YarnAppmasterConfigurer
public void configure(YarnAppmasterConfigure master) throws Exception {
master
.containerCommands("date", "1><LOG_DIR>/Container.stdout", "2><LOG_DIR>/Container.stderr");
}
<yarn:master>
<yarn:container-command>
<![CDATA[
date
1><LOG_DIR>/Container.stdout
2><LOG_DIR>/Container.stderr
]]>
</yarn:container-command>
</yarn:master>
YarnAppmasterConfigurer 内の containerCommands commands - Yarn コンテナーコマンド YarnAppmasterConfigurerpublic YarnAppmasterBuilder containerCommands(java.lang.String id, java.lang.String[] commands)
YarnAppmasterConfigurerYarnAppmasterConfigurer 内の containerCommands id - コマンド識別子 commands - Yarn コンテナーコマンド YarnAppmasterConfigurerYarnAppmasterConfigurer.containerCommands(String[])