org.springframework.yarn.batch.config
Class SimpleYarnBatchConfiguration

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

@Configuration
public class SimpleYarnBatchConfiguration
extends Object


Constructor Summary
SimpleYarnBatchConfiguration()
           
 
Method Summary
 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()
           
 
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 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