org.springframework.yarn.batch.config
Class SimpleYarnRemoteBatchConfiguration

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

@Configuration
public class SimpleYarnRemoteBatchConfiguration
extends java.lang.Object

Constructor Summary

SimpleYarnRemoteBatchConfiguration()

Method Summary

AppmasterMindScOperations	appmasterServiceClient()
org.springframework.integration.config.ConsumerEndpointFactoryBean	consumerEndpointFactoryBean()
org.springframework.core.convert.ConversionService	conversionService()
ConverterRegistrar	converterRegistrar()
org.springframework.integration.channel.DirectChannel	directChannel()
org.springframework.batch.core.configuration.annotation.JobBuilderFactory	jobBuilders()
org.springframework.batch.core.explore.JobExplorer	jobExplorer()
org.springframework.batch.core.repository.JobRepository	jobRepository()
MindRpcSerializer	mindRpcSerializer()
com.fasterxml.jackson.databind.ObjectMapper	objectMapper()
org.springframework.integration.channel.QueueChannel	queueChannel()
org.springframework.batch.core.configuration.annotation.StepBuilderFactory	stepBuilders()
org.springframework.batch.core.step.StepLocator	stepLocator()
org.springframework.integration.ip.tcp.connection.TcpNetClientConnectionFactory	tcpNetClientConnectionFactory()
org.springframework.integration.ip.tcp.TcpOutboundGateway	tcpOutboundGateway()
org.springframework.transaction.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 org.springframework.batch.core.configuration.annotation.JobBuilderFactory jobBuilders()
                                                                                      throws java.lang.Exception

Throws:

java.lang.Exception

stepBuilders

@Bean
public org.springframework.batch.core.configuration.annotation.StepBuilderFactory stepBuilders()
                                                                                        throws java.lang.Exception

Throws:

java.lang.Exception

transactionManager

@Bean
public org.springframework.transaction.PlatformTransactionManager transactionManager()
                                                                              throws java.lang.Exception

Throws:

java.lang.Exception

stepLocator

@Bean
public org.springframework.batch.core.step.StepLocator stepLocator()

jobRepository

@Bean
public org.springframework.batch.core.repository.JobRepository jobRepository()

jobExplorer

@Bean
public org.springframework.batch.core.explore.JobExplorer jobExplorer()

directChannel

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

queueChannel

@Bean
public org.springframework.integration.channel.QueueChannel queueChannel()

mindRpcSerializer

@Bean
public MindRpcSerializer mindRpcSerializer()

tcpNetClientConnectionFactory

@Bean
public org.springframework.integration.ip.tcp.connection.TcpNetClientConnectionFactory tcpNetClientConnectionFactory()

tcpOutboundGateway

@Bean
public org.springframework.integration.ip.tcp.TcpOutboundGateway tcpOutboundGateway()

consumerEndpointFactoryBean

@Bean
public org.springframework.integration.config.ConsumerEndpointFactoryBean consumerEndpointFactoryBean()

appmasterServiceClient

@Bean(name="yarnAmserviceClient")
public AppmasterMindScOperations appmasterServiceClient()

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