@Configuration public class SimpleYarnBatchConfiguration extends Object
| Constructor and Description |
|---|
SimpleYarnBatchConfiguration() |
| Modifier and Type | Method and Description |
|---|---|
org.springframework.yarn.am.AppmasterService |
appmasterService() |
ConversionService |
conversionService() |
org.springframework.yarn.integration.convert.ConverterRegistrar |
converterRegistrar() |
org.springframework.yarn.integration.support.DefaultPortExposingTcpSocketSupport |
defaultPortExposingTcpSocketSupport() |
DirectChannel |
directChannel() |
JobExplorer |
jobExplorer() |
JobRepositoryService |
jobRepositoryService() |
org.springframework.yarn.integration.ip.mind.MindRpcSerializer |
mindRpcSerializer() |
com.fasterxml.jackson.databind.ObjectMapper |
objectMapper() |
TcpInboundGateway |
tcpInboundGateway() |
TcpNetServerConnectionFactory |
tcpNetServerConnectionFactory() |
org.springframework.yarn.event.YarnEventPublisher |
yarnEventPublisher() |
@Bean public org.springframework.yarn.event.YarnEventPublisher yarnEventPublisher()
@Bean public JobRepositoryService jobRepositoryService() throws Exception
Exception@Bean public JobExplorer jobExplorer() throws Exception
Exception@Bean public com.fasterxml.jackson.databind.ObjectMapper objectMapper()
@Bean(name="yarnIntegrationConversionService") public ConversionService conversionService()
@Bean public org.springframework.yarn.integration.convert.ConverterRegistrar converterRegistrar()
@Bean public DirectChannel directChannel()
@Bean public org.springframework.yarn.integration.ip.mind.MindRpcSerializer mindRpcSerializer()
@Bean public org.springframework.yarn.integration.support.DefaultPortExposingTcpSocketSupport defaultPortExposingTcpSocketSupport()
@Bean public TcpNetServerConnectionFactory tcpNetServerConnectionFactory()
@Bean public TcpInboundGateway tcpInboundGateway()