@Configuration public class SpringYarnConfiguration extends org.springframework.data.hadoop.config.common.annotation.AbstractAnnotationConfiguration<SpringYarnConfigBuilder,SpringYarnConfigs>
SpringYarnConfigBuilder to create SpringYarnConfigs
holding all relevant configurations for Spring Yarn. It then exports the
necessary beans. Customisations can be made to SpringYarnConfigBuilder by
extending SpringYarnConfigurerAdapter and exposing it as a
Configuration or implementing SpringYarnConfigurer and
exposing it as a Configuration. This configuration is imported when
using EnableYarn.EnableYarn,
SpringYarnConfigBuilder| Modifier and Type | Field and Description |
|---|---|
protected SpringYarnConfigBuilder |
builder |
| Constructor and Description |
|---|
SpringYarnConfiguration() |
| Modifier and Type | Method and Description |
|---|---|
void |
maySetConfigurationFromContext()
Sets a configuration from an
ApplicationContext if one and
only one configuration of type org.apache.hadoop.conf.Configuration
or YarnConfiguration is found. |
protected void |
onConfigurers(List<org.springframework.data.hadoop.config.common.annotation.AnnotationConfigurer<SpringYarnConfigs,SpringYarnConfigBuilder>> configurers) |
void |
setImportMetadata(AnnotationMetadata importMetadata) |
YarnConfiguration |
yarnConfiguration() |
Map<String,String> |
yarnEnvironment() |
YarnEventPublisher |
yarnEventPublisher() |
ResourceLocalizer |
yarnLocalresources() |
protected SpringYarnConfigBuilder builder
@Bean(name="yarnEventPublisher") public YarnEventPublisher yarnEventPublisher()
@Bean(name={"yarnConfiguration","hadoopConfiguration"}) public YarnConfiguration yarnConfiguration() throws Exception
Exceptionpublic void maySetConfigurationFromContext()
ApplicationContext if one and
only one configuration of type org.apache.hadoop.conf.Configuration
or YarnConfiguration is found. This is an indication that someone
injected hadoop configuration before we get to this point in spring javaconfig.@Bean(name="yarnLocalresources") @DependsOn(value="yarnConfiguration") public ResourceLocalizer yarnLocalresources() throws Exception
Exception@Bean(name="yarnEnvironment") @DependsOn(value="yarnConfiguration") public Map<String,String> yarnEnvironment() throws Exception
Exceptionprotected void onConfigurers(List<org.springframework.data.hadoop.config.common.annotation.AnnotationConfigurer<SpringYarnConfigs,SpringYarnConfigBuilder>> configurers) throws Exception
onConfigurers in class org.springframework.data.hadoop.config.common.annotation.AbstractAnnotationConfiguration<SpringYarnConfigBuilder,SpringYarnConfigs>Exceptionpublic void setImportMetadata(AnnotationMetadata importMetadata)
setImportMetadata in interface ImportAwaresetImportMetadata in class org.springframework.data.hadoop.config.common.annotation.AbstractAnnotationConfiguration<SpringYarnConfigBuilder,SpringYarnConfigs>