org.springframework.yarn.batch.config
Class SimpleYarnRemoteBatchConfiguration

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

@Configuration
public class SimpleYarnRemoteBatchConfiguration
extends Object


Constructor Summary
SimpleYarnRemoteBatchConfiguration()
           
 
Method Summary
 org.springframework.yarn.integration.ip.mind.AppmasterMindScOperations appmasterServiceClient()
           
 ConsumerEndpointFactoryBean consumerEndpointFactoryBean()
           
 ConversionService conversionService()
           
 org.springframework.yarn.integration.convert.ConverterRegistrar converterRegistrar()
           
 DirectChannel directChannel()
           
 JobBuilderFactory jobBuilders()
           
 JobExplorer jobExplorer()
           
 JobRepository jobRepository()
           
 org.springframework.yarn.integration.ip.mind.MindRpcSerializer mindRpcSerializer()
           
 com.fasterxml.jackson.databind.ObjectMapper objectMapper()
           
 QueueChannel queueChannel()
           
 StepBuilderFactory stepBuilders()
           
 StepLocator stepLocator()
           
 TcpNetClientConnectionFactory tcpNetClientConnectionFactory()
           
 TcpOutboundGateway tcpOutboundGateway()
           
 PlatformTransactionManager transactionManager()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

SimpleYarnRemoteBatchConfiguration

public SimpleYarnRemoteBatchConfiguration()
Method Detail

jobBuilders

@Bean
public JobBuilderFactory jobBuilders()
                              throws Exception
Throws:
Exception

stepBuilders

@Bean
public StepBuilderFactory stepBuilders()
                                throws Exception
Throws:
Exception

transactionManager

@Bean
public PlatformTransactionManager transactionManager()
                                              throws Exception
Throws:
Exception

stepLocator

@Bean
public StepLocator stepLocator()

jobRepository

@Bean
public JobRepository jobRepository()

jobExplorer

@Bean
public JobExplorer jobExplorer()

directChannel

@Bean
public DirectChannel directChannel()

queueChannel

@Bean
public QueueChannel queueChannel()

mindRpcSerializer

@Bean
public org.springframework.yarn.integration.ip.mind.MindRpcSerializer mindRpcSerializer()

tcpNetClientConnectionFactory

@Bean
public TcpNetClientConnectionFactory tcpNetClientConnectionFactory()

tcpOutboundGateway

@Bean
public TcpOutboundGateway tcpOutboundGateway()

consumerEndpointFactoryBean

@Bean
public ConsumerEndpointFactoryBean consumerEndpointFactoryBean()

appmasterServiceClient

@Bean(name="yarnAmserviceClient")
public org.springframework.yarn.integration.ip.mind.AppmasterMindScOperations appmasterServiceClient()

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()