org.springframework.yarn.batch.config
Class SimpleYarnBatchConfiguration
java.lang.Object
org.springframework.yarn.batch.config.SimpleYarnBatchConfiguration
@Configuration
public class SimpleYarnBatchConfiguration
- extends Object
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
SimpleYarnBatchConfiguration
public SimpleYarnBatchConfiguration()
yarnEventPublisher
@Bean
public org.springframework.yarn.event.YarnEventPublisher yarnEventPublisher()
jobRepositoryService
@Bean
public JobRepositoryService jobRepositoryService()
throws Exception
- Throws:
Exception
jobExplorer
@Bean
public JobExplorer jobExplorer()
throws Exception
- Throws:
Exception
objectMapper
@Bean
public com.fasterxml.jackson.databind.ObjectMapper objectMapper()
conversionService
@Bean(name="yarnIntegrationConversionService")
public ConversionService conversionService()
converterRegistrar
@Bean
public org.springframework.yarn.integration.convert.ConverterRegistrar converterRegistrar()
directChannel
@Bean
public DirectChannel directChannel()
mindRpcSerializer
@Bean
public org.springframework.yarn.integration.ip.mind.MindRpcSerializer mindRpcSerializer()
defaultPortExposingTcpSocketSupport
@Bean
public org.springframework.yarn.integration.support.DefaultPortExposingTcpSocketSupport defaultPortExposingTcpSocketSupport()
tcpNetServerConnectionFactory
@Bean
public TcpNetServerConnectionFactory tcpNetServerConnectionFactory()
tcpInboundGateway
@Bean
public TcpInboundGateway tcpInboundGateway()
appmasterService
@Bean(name="yarnAmservice")
public org.springframework.yarn.am.AppmasterService appmasterService()
throws Exception
- Throws:
Exception