org.aksw.facete2.web.main

Class SparqlExportJobConfig

java.lang.Object

org.aksw.facete2.web.main.SparqlExportJobConfig

@Configuration
@EnableBatchProcessing
@Import(value=SparqlServiceFactoryConfig.class)
public class SparqlExportJobConfig
extends Object

Source: http://robbypelssers.blogspot.de/2013/09/spring-batch-demo.html NOTE DataSource must contain the spring batch schema .addScript("classpath:org/springframework/batch/core/schema-drop-hsqldb.sql") .addScript("classpath:org/springframework/batch/core/schema-hsqldb.sql")

Author:

raven

Field Summary

Fields

Modifier and Type	Field and Description
static String	JOBPARAM_DEFAULT_GRAPH_URIS
static String	JOBPARAM_QUERY_STRING
static String	JOBPARAM_SERVICE_URI Attention: You have to name these beans jobBuilders and stepbuilders respectively.
static String	JOBPARAM_TARGET_RESOURCE

Constructor Summary

Constructors

Constructor and Description
SparqlExportJobConfig()

Method Summary

Methods

Modifier and Type	Method and Description
org.springframework.batch.core.Step	dataCountStep(com.hp.hpl.jena.query.Query query, org.aksw.jena_sparql_api.core.QueryExecutionFactory sparqlService)
org.springframework.batch.core.Step	dataFetchStep()
org.springframework.batch.core.explore.support.JobExplorerFactoryBean	jobExplorer(DataSource dataSource)
org.springframework.batch.core.launch.JobLauncher	jobLauncher(org.springframework.batch.core.repository.JobRepository jobRepository)
org.springframework.batch.core.launch.JobOperator	jobOperator(org.springframework.batch.core.explore.JobExplorer jobExplorer, org.springframework.batch.core.launch.JobLauncher jobLauncher, org.springframework.batch.core.repository.JobRepository jobRepository, org.springframework.batch.core.configuration.ListableJobLocator jobRegistry)
org.springframework.batch.item.file.transform.LineAggregator<com.hp.hpl.jena.sparql.engine.binding.Binding>	lineAggregator(com.hp.hpl.jena.query.Query query)
org.springframework.batch.item.ItemProcessor<com.hp.hpl.jena.sparql.engine.binding.Binding,com.hp.hpl.jena.sparql.engine.binding.Binding>	processor()
com.hp.hpl.jena.query.Query	query(String queryString)
SparqlPagingItemReader<com.hp.hpl.jena.sparql.engine.binding.Binding>	reader(com.hp.hpl.jena.query.Query query, org.aksw.jena_sparql_api.core.QueryExecutionFactory sparqlService, String queryString)
org.springframework.batch.core.Job	sparqlExportJob()
org.aksw.jena_sparql_api.core.QueryExecutionFactory	sparqlService(String serviceUri, String defaultGraphUris)
org.springframework.core.task.TaskExecutor	taskExecutor()
static String	toXmlStringBinding(com.hp.hpl.jena.sparql.engine.binding.Binding binding, Collection<String> varNames)
static String	toXmlStringBindingItem(String varName, com.hp.hpl.jena.graph.Node node)
static String	toXmlStringBlank(com.hp.hpl.jena.graph.Node node)
static String	toXmlStringLiteral(com.hp.hpl.jena.graph.Node node)
static String	toXmlStringNode(com.hp.hpl.jena.graph.Node node)
static String	toXmlStringUri(com.hp.hpl.jena.graph.Node node)
org.springframework.batch.item.file.ResourceAwareItemWriterItemStream<com.hp.hpl.jena.sparql.engine.binding.Binding>	writer(com.hp.hpl.jena.query.Query query, String targetResource)

Methods inherited from class java.lang.Object

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

Field Detail

JOBPARAM_SERVICE_URI

public static final String JOBPARAM_SERVICE_URI

Attention: You have to name these beans jobBuilders and stepbuilders respectively. See http://docs.spring.io/spring-batch/reference/html/configureJob.html

See Also:

Constant Field Values

JOBPARAM_DEFAULT_GRAPH_URIS

public static final String JOBPARAM_DEFAULT_GRAPH_URIS

See Also:

Constant Field Values

JOBPARAM_QUERY_STRING

public static final String JOBPARAM_QUERY_STRING

See Also:

Constant Field Values

JOBPARAM_TARGET_RESOURCE

public static final String JOBPARAM_TARGET_RESOURCE

See Also:

Constant Field Values

Constructor Detail

SparqlExportJobConfig

public SparqlExportJobConfig()

Method Detail

jobExplorer

@Bean
@Autowired
public org.springframework.batch.core.explore.support.JobExplorerFactoryBean jobExplorer(DataSource dataSource)

jobOperator

@Bean
@Autowired
public org.springframework.batch.core.launch.JobOperator jobOperator(org.springframework.batch.core.explore.JobExplorer jobExplorer,
                                                                           org.springframework.batch.core.launch.JobLauncher jobLauncher,
                                                                           org.springframework.batch.core.repository.JobRepository jobRepository,
                                                                           org.springframework.batch.core.configuration.ListableJobLocator jobRegistry)

taskExecutor

@Bean
public org.springframework.core.task.TaskExecutor taskExecutor()

jobLauncher

@Bean
@Autowired
public org.springframework.batch.core.launch.JobLauncher jobLauncher(org.springframework.batch.core.repository.JobRepository jobRepository)

sparqlExportJob

@Bean
public org.springframework.batch.core.Job sparqlExportJob()

query

@Bean
@JobScope
public com.hp.hpl.jena.query.Query query(@Value(value="#{jobParameters[queryString]}")
                                              String queryString)

sparqlService

@Bean
@JobScope
public org.aksw.jena_sparql_api.core.QueryExecutionFactory sparqlService(@Value(value="#{jobParameters[serviceUri]}")
                                                                              String serviceUri,
                                                                              @Value(value="#{jobParameters[defaultGraphUris]}")
                                                                              String defaultGraphUris)

dataCountStep

@Bean
@JobScope
@Autowired
public org.springframework.batch.core.Step dataCountStep(com.hp.hpl.jena.query.Query query,
                                                                        org.aksw.jena_sparql_api.core.QueryExecutionFactory sparqlService)

dataFetchStep

@Bean
public org.springframework.batch.core.Step dataFetchStep()

reader

@Bean
@StepScope
@Autowired
public SparqlPagingItemReader<com.hp.hpl.jena.sparql.engine.binding.Binding> reader(com.hp.hpl.jena.query.Query query,
                                                                                                    org.aksw.jena_sparql_api.core.QueryExecutionFactory sparqlService,
                                                                                                    @Value(value="#{jobParameters[queryString]}")
                                                                                                    String queryString)

writer

@Bean
@StepScope
@Autowired
public org.springframework.batch.item.file.ResourceAwareItemWriterItemStream<com.hp.hpl.jena.sparql.engine.binding.Binding> writer(com.hp.hpl.jena.query.Query query,
                                                                                                                                                   @Value(value="#{jobParameters[targetResource]}")
                                                                                                                                                   String targetResource)

lineAggregator

@Bean
@StepScope
@Autowired
public org.springframework.batch.item.file.transform.LineAggregator<com.hp.hpl.jena.sparql.engine.binding.Binding> lineAggregator(com.hp.hpl.jena.query.Query query)

processor

@Bean
@StepScope
@Autowired
public org.springframework.batch.item.ItemProcessor<com.hp.hpl.jena.sparql.engine.binding.Binding,com.hp.hpl.jena.sparql.engine.binding.Binding> processor()

toXmlStringBinding

public static String toXmlStringBinding(com.hp.hpl.jena.sparql.engine.binding.Binding binding,
                        Collection<String> varNames)

toXmlStringBindingItem

public static String toXmlStringBindingItem(String varName,
                            com.hp.hpl.jena.graph.Node node)

toXmlStringNode

public static String toXmlStringNode(com.hp.hpl.jena.graph.Node node)

toXmlStringLiteral

public static String toXmlStringLiteral(com.hp.hpl.jena.graph.Node node)

toXmlStringBlank

public static String toXmlStringBlank(com.hp.hpl.jena.graph.Node node)

toXmlStringUri

public static String toXmlStringUri(com.hp.hpl.jena.graph.Node node)