org.springframework.yarn.batch.config
Class SimpleYarnBatchConfiguration

java.lang.Object
  org.springframework.yarn.batch.config.SimpleYarnBatchConfiguration

@Configuration
public class SimpleYarnBatchConfiguration
extends java.lang.Object

Constructor Summary

SimpleYarnBatchConfiguration()

Method Summary

AppmasterService	appmasterService()
org.springframework.core.convert.ConversionService	conversionService()
ConverterRegistrar	converterRegistrar()
DefaultPortExposingTcpSocketSupport	defaultPortExposingTcpSocketSupport()
org.springframework.integration.channel.DirectChannel	directChannel()
org.springframework.batch.core.explore.JobExplorer	jobExplorer()
JobRepositoryService	jobRepositoryService()
MindRpcSerializer	mindRpcSerializer()
com.fasterxml.jackson.databind.ObjectMapper	objectMapper()
org.springframework.integration.ip.tcp.TcpInboundGateway	tcpInboundGateway()
org.springframework.integration.ip.tcp.connection.TcpNetServerConnectionFactory	tcpNetServerConnectionFactory()
YarnEventPublisher	yarnEventPublisher()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SimpleYarnBatchConfiguration

public SimpleYarnBatchConfiguration()

Method Detail

yarnEventPublisher

@Bean
public YarnEventPublisher yarnEventPublisher()

jobRepositoryService

@Bean
public JobRepositoryService jobRepositoryService()
                                          throws java.lang.Exception

Throws:

java.lang.Exception

jobExplorer

@Bean
public org.springframework.batch.core.explore.JobExplorer jobExplorer()
                                                               throws java.lang.Exception

Throws:

java.lang.Exception

objectMapper

@Bean
public com.fasterxml.jackson.databind.ObjectMapper objectMapper()

conversionService

@Bean(name="yarnIntegrationConversionService")
public org.springframework.core.convert.ConversionService conversionService()

converterRegistrar

@Bean
public ConverterRegistrar converterRegistrar()

directChannel

@Bean
public org.springframework.integration.channel.DirectChannel directChannel()

mindRpcSerializer

@Bean
public MindRpcSerializer mindRpcSerializer()

defaultPortExposingTcpSocketSupport

@Bean
public DefaultPortExposingTcpSocketSupport defaultPortExposingTcpSocketSupport()

tcpNetServerConnectionFactory

@Bean
public org.springframework.integration.ip.tcp.connection.TcpNetServerConnectionFactory tcpNetServerConnectionFactory()

tcpInboundGateway

@Bean
public org.springframework.integration.ip.tcp.TcpInboundGateway tcpInboundGateway()

appmasterService

@Bean(name="yarnAmservice")
public AppmasterService appmasterService()
                                  throws java.lang.Exception

Throws:

java.lang.Exception