org.springframework.yarn.batch.config

Class SimpleYarnBatchConfiguration

java.lang.Object

org.springframework.yarn.batch.config.SimpleYarnBatchConfiguration

@Configuration
public class SimpleYarnBatchConfiguration
extends java.lang.Object

Annotation based batch configuration for Yarn Appmaster.

Author:

Janne Valkealahti

Constructor Summary

Constructors

Constructor and Description
SimpleYarnBatchConfiguration()

Method Summary

Methods

Modifier and Type	Method and Description
AppmasterService	appmasterService()
DefaultPortExposingTcpSocketSupport	defaultPortExposingTcpSocketSupport()
org.springframework.integration.channel.DirectChannel	directChannel()
org.springframework.batch.core.explore.JobExplorer	jobExplorer()
JobRepositoryService	jobRepositoryService()
MindHolderToObjectConverter	mindHolderToObjectConverter()
MindObjectToHolderConverter	mindObjectToHolderConverter()
MindRpcSerializer	mindRpcSerializer()
com.fasterxml.jackson.databind.ObjectMapper	objectMapper()
org.springframework.integration.ip.tcp.TcpInboundGateway	tcpInboundGateway()
org.springframework.integration.ip.tcp.connection.TcpNetServerConnectionFactory	tcpNetServerConnectionFactory()
YarnEventPublisher	yarnEventPublisher()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SimpleYarnBatchConfiguration

public SimpleYarnBatchConfiguration()

Method Detail

yarnEventPublisher

@Bean
public YarnEventPublisher yarnEventPublisher()

jobRepositoryService

@Bean
public JobRepositoryService jobRepositoryService()
                                          throws java.lang.Exception

Throws:

java.lang.Exception

jobExplorer

@Bean
public org.springframework.batch.core.explore.JobExplorer jobExplorer()
                                                               throws java.lang.Exception

Throws:

java.lang.Exception

objectMapper

@Bean
public com.fasterxml.jackson.databind.ObjectMapper objectMapper()

mindObjectToHolderConverter

@Bean
@IntegrationConverter
public MindObjectToHolderConverter mindObjectToHolderConverter()

mindHolderToObjectConverter

@Bean
@IntegrationConverter
public MindHolderToObjectConverter mindHolderToObjectConverter()

directChannel

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

mindRpcSerializer

@Bean
public MindRpcSerializer mindRpcSerializer()

defaultPortExposingTcpSocketSupport

@Bean
public DefaultPortExposingTcpSocketSupport defaultPortExposingTcpSocketSupport()

tcpNetServerConnectionFactory

@Bean
public org.springframework.integration.ip.tcp.connection.TcpNetServerConnectionFactory tcpNetServerConnectionFactory()

tcpInboundGateway

@Bean
public org.springframework.integration.ip.tcp.TcpInboundGateway tcpInboundGateway()

appmasterService

@Bean(name="yarnAmservice")
public AppmasterService appmasterService()
                                  throws java.lang.Exception

Throws:

java.lang.Exception