org.springframework.yarn.batch.config
Class SimpleYarnRemoteBatchConfiguration
java.lang.Object
org.springframework.yarn.batch.config.SimpleYarnRemoteBatchConfiguration
@Configuration
public class SimpleYarnRemoteBatchConfiguration
- extends Object
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
SimpleYarnRemoteBatchConfiguration
public SimpleYarnRemoteBatchConfiguration()
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()