@Configuration public class SimpleYarnRemoteBatchConfiguration extends java.lang.Object
| Constructor and Description |
|---|
SimpleYarnRemoteBatchConfiguration() |
| Modifier and Type | Method and Description |
|---|---|
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() |
@Bean public JobBuilderFactory jobBuilders() throws java.lang.Exception
java.lang.Exception@Bean public StepBuilderFactory stepBuilders() throws java.lang.Exception
java.lang.Exception@Bean public PlatformTransactionManager transactionManager() throws java.lang.Exception
java.lang.Exception@Bean public StepLocator stepLocator()
@Bean public JobRepository jobRepository()
@Bean public JobExplorer jobExplorer()
@Bean public DirectChannel directChannel()
@Bean public QueueChannel queueChannel()
@Bean public org.springframework.yarn.integration.ip.mind.MindRpcSerializer mindRpcSerializer()
@Bean public TcpNetClientConnectionFactory tcpNetClientConnectionFactory()
@Bean public TcpOutboundGateway tcpOutboundGateway()
@Bean public ConsumerEndpointFactoryBean consumerEndpointFactoryBean()
@Bean(name="yarnAmserviceClient") public org.springframework.yarn.integration.ip.mind.AppmasterMindScOperations appmasterServiceClient()
@Bean public com.fasterxml.jackson.databind.ObjectMapper objectMapper()
@Bean(name="yarnIntegrationConversionService") public ConversionService conversionService()
@Bean public org.springframework.yarn.integration.convert.ConverterRegistrar converterRegistrar()