org.springframework.yarn.batch.config

Class SimpleYarnRemoteBatchConfiguration

java.lang.Object

org.springframework.yarn.batch.config.SimpleYarnRemoteBatchConfiguration

@Configuration
public class SimpleYarnRemoteBatchConfiguration
extends java.lang.Object

Annotation based batch configuration for Yarn Container.

Author:

Janne Valkealahti

Constructor Summary

Constructors

Constructor and Description
SimpleYarnRemoteBatchConfiguration()

Method Summary

Methods

Modifier and Type	Method and Description
AppmasterMindScOperations	appmasterServiceClient()
org.springframework.integration.config.ConsumerEndpointFactoryBean	consumerEndpointFactoryBean()
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()
MindHolderToObjectConverter	mindHolderToObjectConverter()
MindObjectToHolderConverter	mindObjectToHolderConverter()
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()

mindObjectToHolderConverter

@Bean
@IntegrationConverter
public MindObjectToHolderConverter mindObjectToHolderConverter()

mindHolderToObjectConverter

@Bean
@IntegrationConverter
public MindHolderToObjectConverter mindHolderToObjectConverter()