使用CompositeItemWriter和CompositeItemProcessor的Spring Batch
Spring Batch是一个轻量级的批处理框架，用于处理大量的数据。它提供了一套强大的工具和API，使开发人员能够方便地创建可靠的、高性能的批处理应用程序。
CompositeItemWriter和CompositeItemProcessor是Spring Batch中的两个重要组件，用于处理批处理作业中的写入和处理逻辑。
- CompositeItemWriter:
- 概念：CompositeItemWriter是一个ItemWriter的实现类，它允许将多个ItemWriter组合在一起，以便在写入数据时同时将数据写入多个目标。
- 分类：CompositeItemWriter属于ItemWriter接口的实现类，用于将数据写入多个目标。
- 优势：通过使用CompositeItemWriter，可以将数据同时写入多个目标，提高数据的可靠性和一致性。
- 应用场景：适用于需要将数据写入多个目标的场景，例如将数据同时写入数据库和文件系统。
- 推荐的腾讯云相关产品：腾讯云数据库MySQL、腾讯云对象存储COS等。
- 产品介绍链接地址：腾讯云数据库MySQL、腾讯云对象存储COS
- CompositeItemProcessor:
- 概念：CompositeItemProcessor是一个ItemProcessor的实现类，它允许将多个ItemProcessor组合在一起，以便在处理数据时依次应用多个处理逻辑。
- 分类：CompositeItemProcessor属于ItemProcessor接口的实现类，用于处理批处理作业中的数据。
- 优势：通过使用CompositeItemProcessor，可以将多个处理逻辑组合在一起，提高数据处理的灵活性和可扩展性。
- 应用场景：适用于需要依次应用多个处理逻辑的场景，例如数据清洗、数据转换等。
- 推荐的腾讯云相关产品：腾讯云人工智能平台、腾讯云物联网平台等。
- 产品介绍链接地址：腾讯云人工智能平台、腾讯云物联网平台
综上所述，CompositeItemWriter和CompositeItemProcessor是Spring Batch中用于处理批处理作业中写入和处理逻辑的重要组件。它们的使用可以提高数据处理的可靠性、一致性和灵活性。在腾讯云中，可以结合腾讯云的相关产品来实现数据的写入和处理，例如腾讯云数据库MySQL和腾讯云对象存储COS。同时，腾讯云的人工智能平台和物联网平台也可以与CompositeItemProcessor结合使用，实现更复杂的数据处理需求。
相关·内容
我目前有一个Spring作业，只需一个步骤就可以从Oracle读取数据，通过多个Spring处理器(CompositeItemProcessor)传递数据，并将数据写入不同的目的地，如Oracle (CompositeItemWriter)：
<batch:step id="dataTransformationJob">
<batch:tasklet transaction-manager="transactionManager" task-executor="taskExecutor" throttle-limit=&
浏览 3提问于2020-09-02得票数 0
1回答
我正在spring-boot应用程序中使用spring-boot。Spring版本是2.3.3.RELEASE。
我想要达到的目标
我必须使用read a xml file包含数千Transactions和header tag (fileInformation)。对事务执行一些业务逻辑，然后用事务中更新的值将文件写回。我使用StaxEventItemReader读取文件，使用StaxEventItemWriter写入文件。然后，我有两个用于处理业务逻辑的ItemProcessors。Xml文件如下所示：
<?xml version="1.0" encoding="
浏览 6提问于2021-06-09得票数 1
回答已采纳
1回答
我在Spring Boot应用程序中使用Spring Batch。Spring Boot版本为1.3.5.RELEASE。
我正在尝试使用CompositeItemWriter，这样条目列表将首先被WriterOne压缩/压缩，然后被传递到WriterTwo，在那里它们将被写入数据库。
这是我的作者1：
@Component
public class Writer1 implements org.springframework.batch.item.ItemWriter<SimpleObject> {
@Override
public void write(Lis
浏览 3提问于2017-12-25得票数 4
回答已采纳
我用的是spring boot和mybatis MyBatisBatchItemWriter。使用demo将数据(Mysql)写入数据库，当没有问题时。但在我的项目org.springframework.dao.TransientDataAccessResourceException: Cannot change the ExecutorType when there is an existing transaction at org.mybatis.spring.SqlSessionUtils.getSqlSession(SqlSessionUtils.java:91) ~[myba
浏览 0提问于2016-05-09得票数 1
嗨，我正在尝试添加两个编写器到一个spring batch compositeitemwriter中。我收到一个错误，说：
The method setDelegates(List<ItemWriter<? super MyObject>>) in the type CompositeItemWriter<MyObject> is not applicable for the arguments (List<ItemWriter<MyObject>>)
下面是我的代码
public ItemWriter<MyObject>
浏览 2提问于2017-07-28得票数 0
总之，我在使用Spring Batch CompositeItemWriter时遇到了事务回滚问题。Spring batch的版本是2.2.7。
我的配置与这里的帖子相同：
<bean id="compositeItemWriter" class="org.springframework.batch.item.support.CompositeItemWriter">
<property name="delegates">
<list>
<ref bean="fir
浏览 0提问于2015-11-09得票数 1
在Spring批处理中，在作业-request.xml文件中，可以让块的编写器运行一个"compositeItemWriter“，如下所示：
<bean id="compositeItemWriter"
class="org.springframework.batch.item.support.CompositeItemWriter">
<property name="delegates">
<list>
<ref bean="wri
浏览 0提问于2015-11-03得票数 1
回答已采纳
在Spring batch中，我这样配置一个文件写入：
@Bean
public FlatFileItemWriter<MyObject> flatFileItemWriter() throws Exception{
FlatFileItemWriter<MyObject> itemWriter = new FlatFileItemWriter();
// pass through aggregator just calls toString on any item pass in.
itemWriter.setLineAggregator(n
浏览 2提问于2018-06-27得票数 0
1回答
我正在下载一个json文件，内容以数组的形式提供。
我想对子数组的元素进行各种验证(notNull、isNumber等)。
一个是当我使用Spring batch并启用ValidatingItemProcessor和Bean验证时。
但是，我想使用已有的Validator框架编写一个独立的解决方案，但不想验证为bean，而是直接在数组上验证。
我应该如何处理这个问题。
我使用的是Spring框架，所以任何关于它的东西都会很有帮助。
浏览 2提问于2015-11-20得票数 0
我在我的应用程序中使用Spring Batch。我有一个要求，在开始处理行之前，我需要在数据库上执行更新查询。在读取之后，在映射阶段，我根据从dataBase读取的数据填充一个列表，在开始这个过程之前，我需要根据这个列表更新数据库中的一个表。这个查询只需要执行一次，这就是为什么beforeProcess()方法是不相关的，因为每一行都会调用它。
浏览 1提问于2016-01-05得票数 1
我正在为processing large data使用spring batch。
我的问题是我有两个不同的Tasklet，它们是executing one after another。我不能并行运行它，因为第二个微线程对第一个Tasklet有一些依赖。为了节省时间，我想在前几个items被前一个Tasklet processed后立即开始下一个tasklet。因为Spring Batch使用Chunk Oriented处理风格。一个Tasklet的ItemWriter是否可以将已处理项目的块传递给另一个Tasklet的ItemReader、ItemProcessor或ItemWriter以进行
浏览 6提问于2016-07-27得票数 0
回答已采纳
我目前正在编写spring批处理，在其中读取XML数据，处理它，然后将处理器结果作为map<string,object>传递给编写器并实现CompositeItemWriter。下面是所需的输出XML。
<Company att1="value">
<employees>
<employee></employee>
<employee></employee>
<employee></employee>
浏览 3提问于2016-02-22得票数 1
我使用SpringBootv2.6.2和Spring，并得到以下错误：
名称为“”的bean上的 ustom破坏方法'compositeItemWriter‘抛出了一个异常:创建名称为’compositeItemWriter‘的bean时出错:范围' step’对于当前线程没有活动；如果要从单个实例中引用该bean，请考虑为它定义一个作用域代理；嵌套的例外是java.lang.IllegalStateException:没有用于步骤范围的上下文保持器。
MainApp.java
import org.springframework.batch.core.Job;
import
浏览 16提问于2022-01-02得票数 0
我有一个场景，下面的步骤如下：
读者将从表A中得到一个列表A。
处理器处理列表A以返回对象A和MimeMessage。
作者将对象A写入表B，并使用MimeMessage发送邮件。
我可以在上面的场景中使用CompositeItemProcessor和CompositeItemWriter吗？如果是，我如何在步骤配置中设置输出对象，以及如何定义发送邮件的哪个ItemWriter将采用MimeMessage，ItemWriter用于插入数据库将采用对象A。
有什么更好的办法来解决我的问题吗？
浏览 2提问于2019-11-26得票数 0
回答已采纳
在XML文件中，我使用CompositeItemProcessor配置了两个处理器。
<processor>
<beans:bean id="CompositeItemProcessor" class="org.springframework.batch.item.support.CompositeItemProcessor" scope="step">
<beans:property name="delegates">
浏览 1提问于2020-01-06得票数 1
回答已采纳
我正在spring-boot应用程序中使用spring-boot。Spring版本是2.3.3.RELEASE。
我有一个multi-step job，第一步是validates xml file header，然后是chunk oriented step中的read transaction，对每个事务执行一些business logic，然后将其返回到xml文件。在third和最后一步中，当我尝试delete the input file时，它会抛出FileSystemException。
UPDATE：即使在作业完成之后，我也无法删除输入文件。
弹簧批量配置
package c
浏览 2提问于2021-06-27得票数 0
我有我的春天启动和春天批处理应用程序的问题，我分享我的情况有我的层Dao是一个接口抛出NPE (NullPointerException)和它实现，它有注释@Autowired和我做了测试与Junit检查它和工作，但我不知道这是在我的配置作业或CustomItemProccesor的错误，这是我的代码，我希望你能帮助我，请，谢谢。 配置作业： @ComponentScan({"com.company.batch.config","com.company.batch.dao","com.company.batch.mapper","com
浏览 59提问于2020-04-29得票数 0
回答已采纳
我有一个需求，我需要使用两个不同的对象填充两个不同的表。我正在将(列表和列表)包装到CustEmp对象中，但是我不知道如何使用CompositeItemWriter使用独立的数据源来编写它。请帮帮忙 我已经更新了代码，不幸的是，由于某些原因，我无法上传确切的代码。如果不清楚，请让我知道。我在这里找到了一个类似的问题，但无法在作者中找到展开部分：Use Spring Batch to write in different Data Sources RecordsDomain.java public class RecordsDomain{
private List<XYRecords&g
浏览 72提问于2020-11-03得票数 1
关于post How does Spring Batch CompositeItemWriter manage transaction for delegate writers?，对于复合项编写器事务管理，我们不应该像下面这样将数据源包装在事务管理器中吗？如果没有下面的bean定义，事务管理将无法与Oracle和Hikari CP协同工作。不确定帖子中提供的示例是如何进行working..please澄清的 @Bean
public PlatformTransactionManager transactionManager(DataSource dataSource) {
浏览 19提问于2020-10-24得票数 0
回答已采纳
我有一种情况，我必须对2个不同的数据库执行DB操作，如下所示。 stepBuilderFactory.get("some text")
.<POJO,POJO>chunk(200)
.reader(dataReader)
.writer(writeToDB1)
.writer(writeToDB2)
.faultTolerant()
.skipLi
浏览 10提问于2019-01-16得票数 2
在Spring batch中，我的CompositeItemWriter使用多个ItemWriters向多个表中插入记录，但目前这些ItemWriters中的每一个都是批量插入的，如下所示
public class Item{
public List<WarningObject> warnings
public List<ErrorObject> errors
public Long Id;
public String data1;
public String data2;
public String data3;
// getters an
浏览 0提问于2016-02-21得票数 0
1回答
我是Spring batch的新手，在使用Spring batch实现我的业务用例时遇到了问题。
基本上，我是从一个数据库中读取数据，即一个时事通讯的订阅者列表。然后，我需要向每个订阅者发送一封电子邮件，并将数据插入到数据库中，以便知道电子邮件发送给了哪个订阅者。
我使用了一个ItemProcessor实现，它的处理方法返回一个订阅者，并接受一个订阅者作为参数；与这个处理器相关联的编写器的类型是：org.springframework.batch.item.mail.javamail.MimeMessageItemWriter。
问题是，我需要另一个用于数据库插入的编写器(可能使用Compos
浏览 5提问于2011-12-23得票数 0
回答已采纳
我有一个spring批处理应用程序，它将记录填充到表A中。需求的下一步是将表A中的数据分组，并对每个组运行大量的业务验证和差异规则。根据验证规则的输出，数据可能/可能不会写入表B。此过程将是一个夜间批处理作业。
我能想到的3种方法：
使用spring批处理并将规则引擎集成到Itemprocessor中。
使用spring批处理并在多个项中实现验证逻辑
处理器和链子。
编写一个有规则引擎的常规spring应用程序，并实现管理流程的功能。
问题: 1.弹簧批处理支持规则引擎? 2.哪一种方法更好？还是有另一种替代方法？
如有任何建议，将不胜感激。
浏览 5提问于2015-08-27得票数 0
我正在使用Spring，我将在ItemWriter中进行插入，并需要在另一个表中使用插入键进行更新。我如何获得在updateTableB中使用它的密钥？提前谢谢你。
@Bean
public CompositeItemWriter<TableA> distributionCompositeItemWriter() {
CompositeItemWriter<TableA> compositeItemWriter = new CompositeItemWriter<>();
compositeItemWriter.setDelega
浏览 15提问于2022-10-11得票数 0
回答已采纳
我使用的是Spring Batch，我的步骤配置如下：
@Bean
public Step testStep(
JdbcCursorItemReader<TestStep> testStageDataReader,
TestStepProcessor testStepProcessor,
CompositeItemWriter<Writer> testWriter,
PlatformTransactionManager transactionManager,
JobRepository jobReposi
浏览 6提问于2020-06-11得票数 0
使用Spring Batch时，我必须在两个不同的表中编写，但使用相同的ItemReader。
我不知道如何使用一个ItemReader和一个CompositeItemWriter。
下面是JobConfiguration：
<code>A0</code>
项目编写者：
<code>A1</code>
组成两个itemProcessor：
<code>A2</code>
ItemProcessorSurveillance：
<code>A3</code>
和处理器返回的CompositeResult
浏览 33提问于2021-06-14得票数 1
回答已采纳
我有一个包含多个作业(作业A、作业B、作业C等)的Spring Batch项目。当我运行一个特定的作业A时，我得到了作业A的日志，显示了作业B、C、...也被创建了。有没有办法避免在启动作业A时创建其他bean。
我尝试过使用@Lazy注解，但它似乎不起作用。
@Configuration
@EnableBatchProcessing
public class BatchConfiguration {
@Autowired
public JobBuilderFactory jobBuilderFactory;
@Autowired
public StepBu
浏览 0提问于2020-02-22得票数 0
我使用Spring Boot and Spring Batch从源数据库表的一个表中读取数据，并将数据拆分并写入两个目标数据库表。
为此，我选择使用CompositeItemWriter，但CompositeItemWriter<?>只使用一种类型。我想在一个表中写几个字段，把其他字段写到另一个表中。
说:老客户和新客户。
错误：
构造函数CustomerClassifier(JdbcBatchItemWriter，JdbcBatchItemWriter)未定义
ClassifierCompositeItemApplication.java
@EnableBatchProc
浏览 2提问于2020-06-11得票数 1
回答已采纳
我最近提出了这个问题，但我认为我的目标还不够明确。
我有一个由读取器、处理器和写入器组成的步骤。
writer()是一个CompositeItemWriter，由两个JdbcBatchItemWriter组成。在其中一个示例中，我正在写入一个控制表，该表将包含一个row_count列。该值需要来自StepExecution.getReadCount()。
我是Spring Batch的新手，所以我不确定如何添加一个可以将StepExecution包装到实际编写器本身的侦听器。
感谢您的阅读。
浏览 1提问于2018-06-12得票数 0
请提供有关Spring批处理分区从"JdbcBatchItemWriter“范围的建议。目前，我们已经定义为具有30个分区的默认Bean作用域。根据文档，JdbcBatchItemWriter是线程安全的。请注意我们的读者是"STEPSCOPE“
下面是编写器的代码片段
@Bean
public JdbcBatchItemWriter<UnifiedInvoiceDTO> summaryWriter() {
JdbcBatchItemWriter<UnifiedInvoiceDTO> databas
浏览 3提问于2020-06-03得票数 0
回答已采纳
在我的spring batch工作流配置中，我有如下项目编写器： @Bean
@Scope(value = "step", proxyMode = ScopedProxyMode.INTERFACES)
public ItemWriter<Price> skippedItemWriter(@Value("#{stepExecution.executionContext}") ExecutionContext executionContext) {
return new SkippedItemWriter(executionContext);
浏览 29提问于2021-04-13得票数 0
对于目前使用FlatFileItemWriter的作者来说，我正在编写春季批处理。
我希望根据某个字段值将我的输入文件内容写入多个平面文件。Spring批处理是否支持任何类似于default.something的CompositeItemWriter功能？
例如，我的输入文件内容如下所示。
john,35,retail,10000
joe,34,homeloan,20000
Amy,23,retail,2000
现在我想根据第三列编写两个不同的文件，这意味着第1行和第3行应该转到file1，第2行应该转到file2。
我的作者配置是：
<bean id="fileWriter&#
浏览 0提问于2015-04-08得票数 3
回答已采纳
几乎每个spring项目都使用spring-beans.xsd (更准确地说是指它)。但是，如果您查看文件，您将看到它是3.2版，并且没有属性"local“的定义。
更有趣的是，确实定义了“本地”。
另外，由于文件是由于spring.schema而从jar (org/springframework/beans/factory/xml/spring-beans-3.2.xsd)中取出的，所以我认为任何项目都不会有编译或运行时问题。
另一方面，我认为Eclipse的xml验证器只使用internet链接，并显示一个xml错误，更具体地说：
"cvc-complex-type.3.2
浏览 25提问于2014-01-11得票数 21
我正在使用Spring编写多个报告。要求是我将获得记录与BranchId和名称。我需要为每个branchId创建一个文件，并将相应的数据与一些页眉和页脚一起写入该文件。
示例：
Student A = new Student("A",1);
Student B = new Student("B",2);
Student C = new Student("C",1);
Student D = new Student("D",4);
在这种情况下，它应该创建总共3个文件。
file1-
浏览 4提问于2021-05-19得票数 1
回答已采纳
我使用的是Spring 4.0.5和Spring Batch 3.0.1
我有一个这样的简单步骤，它完美地工作：
<step id="myStep" next="nextStep">
<tasklet transaction-manager="myTxManager" task-executor="myTaskExecutor" throttle-limit="10">
<batch:chunk reader="myItemReader" pro
浏览 4提问于2015-03-24得票数 1
在使用Spring Batch ItemProcessor处理一些XML文件之后。ItemProcessor返回的项如下所示：
MetsModsDef
{
int id;
String title;
String path;
Properties identifers;
....
}
现在我需要将这个项目保存到一个数据库中，这样(id，title，path)就可以进入"Work“表
存储在“标识符”字段中的所有属性都会进入一个称为“标识符”的“键/值”-Table中(work，identitytype，identityValue)
我怎么才能得到这个呢？
浏览 0提问于2018-04-04得票数 0
我有一个Person对象，它有一个地址列表。我的Spring批处理应用程序将Person JSON recors转换为Person POJO，并将它们写入数据库。
通常，我会使用JdbcBatchItemWriter，但我看到它在书面上被限制为2个单独的表。我需要写人和地址表。
Hibernate只需一步就可以编写完成，但我在Spring Bathc中看不到类似的功能。
这个问题建议使用CompositeItemWriter，但问题是，我希望我的地址表包含一个名为Person_id的列，以便将地址链接回Person。我不能在两次写入的情况下做到这一点。
有什么建议吗？当然，Batch可以满足更
浏览 2提问于2018-04-10得票数 0
在Spring Batch中，我想对No.正在读取、处理和写入的记录。我知道批处理元数据表中也有相同的功能。根据业务需要，我们需要对DATA_AUDIT表进行审计。
在我的批处理作业中，我基于不同的字段(比如Active Accounts、InActive Accounts、Active Flag等)实现了CompositeItemWriter，在此基础上分离数据并将其写入多个目标表。
这里假设有5000条记录，这5000条记录被分组到数据集，单个记录可以满足不同的业务规则并进入不同的组，这样数据就会增加到5000块中的20000条。
StepListeners只捕捉到了no.在第一个写入者的
浏览 17提问于2020-07-30得票数 0
回答已采纳
1回答
日安，
我有一个Spring批处理，它使用org.springframework.batch.item.support.CompositeItemWriter将数据写入数据库。
以下是我的xml中的编写代码：
<bean id="iReturnCompositeTableWriter" class="org.springframework.batch.item.support.CompositeItemWriter">
<property name="delegates">
浏览 4提问于2019-10-10得票数 0
spring批处理如何标识compositeItemWriter中的提交compositeItemWriter
如果我的commit-interval=50000和我有一个CompositeItemWriter，其中包含了4个不同的作者，每个作者都被传递了一个50000记录列表。事务是否在写入200000 ( 50000 * 4)记录结束时提交？
如果一个itemWriters由于一个exception而失败，那么整个transaction会发生什么？
浏览 3提问于2016-05-19得票数 0
回答已采纳
1回答
我正在使用Spring批处理，我的步骤配置如下：
@Bean
public Step testStep(
JdbcCursorItemReader<TestStep> testStageDataReader,
TestStepProcessor testStepProcessor,
CompositeItemWriter<Writer> testWriter,
PlatformTransactionManager transactionManager,
JobRepository jobRepositor
浏览 5提问于2020-06-11得票数 0
我正尝试在我的Java Bean上实现JSR308验证注释，该Bean在Spring批处理应用程序中使用。Spring Batch提供了一个ValidatingItemProcessor，但我想在进入处理器步骤之前进行验证，所以我决定使用Java。 我认为我能做的就是将注释添加到方法参数中，如果该参数没有通过验证，那么该方法就永远不会被调用。但它并不是这样工作的。显然我还是得先给Validator.validate()打电话。我说的对吗？ 这是我的bean的一个示例，带有自定义注释： public void setValue(@NullOrDecimal String value) {
浏览 28提问于2020-12-03得票数 1
回答已采纳
我正在尝试编写我的批处理项目的集成测试。
我的集成测试定义：
@RunWith(SpringRunner.class)
@SpringBootTest
/* @Autowired
private JobLauncherTestUtils jobLauncherTestUtils;*/
public class BatchApplicationTests {
private static final String EXPECTED_FILE = "src/test/resources/users.csv";
private static final String OUTP
浏览 0提问于2018-09-24得票数 4
这是我的春季配置文件。
<batch:job id="empTxnJob">
<batch:step id="stepOne">
<batch:partition partitioner="partitioner" step="worker" handler="partitionHandler" />
</batch:step>
</batch:job>
<bean id="asyncTaskExecutor
浏览 7提问于2015-06-19得票数 0
回答已采纳
<batch:job id="xyzJob" job-repository="jobRepository"
incrementer="jobParametersIncrementerImpl" restartable="false">
<batch:step id="feeStep">
<batch:tasklet transaction-manager="transactionManager" allow-start-if-comple
浏览 0提问于2018-11-08得票数 0
我有一个Spring应用程序(SpringBoot2.3.5.RELEASE)，它在Spring处理过程中使用JpaRepository将一些自定义日志消息插入数据库。这与开箱即用的Spring批处理表是分开的。当我从ItemProcessorAdapter抛出一个异常时，它似乎被ItemProcessListener onProcessError()方法捕获了。在这个方法中，我执行一个JpaRepository保存()和刷新()。没有记录错误，但是一旦我离开这个方法，JpaRepository就会进行回滚。
，这是正常行为吗？怎样才能绕过它呢？在使用JpaRepository时，是否有一种方
浏览 3提问于2020-11-19得票数 0
回答已采纳
我在试着让job-parameteres-in-to-item-processor-using-spring-batch-annotation.我通过引用下面的链接来实现它；但是对我来说，当我试图在我的处理器类中访问它时，变量(batchRunName)将以null的形式出现。谁能看看它吗。我很确定，我错过了一些小事。
public static void main(String[] args) {
contextObj = new ClassPathXmlApplicationContext(springConfig);
jobObj = (Job) contextObj.
浏览 0提问于2019-01-10得票数 0
回答已采纳
我正在处理的春季批处理程序是从一个表中读取数据。它使用的是‘org.springframework.batch.item.database.JdbcCursorItemReader’itemReader。此前的计划是修改表并添加PROCESSED_INDICATOR标志，并将其预先填充为“未决”状态。一旦记录被处理，写入器将将PROCESSED_INDICATOR标志的状态更新为“processed”。这是为了支持重新启动。例如，如果批处理获取了100万条记录并在150万条记录中死亡，那么当我重新启动该批时，它应该从我停止的地方开始。但不幸的是，管理层没有批准这一解决方案。我正在挖掘使项目阅读
浏览 1提问于2019-01-16得票数 1
我在重新启动本地分区批处理时出现问题。我把RuntimeException扔到第101处理项目上。作业失败，但是出了问题，因为在重新启动时，作业将从第150项继续(而不是从第100项开始)。
这是xml-conf
<bean id="taskExecutor" class="org.springframework.scheduling.commonj.WorkManagerTaskExecutor" >
<property name="workManagerName" value="springWorkManag
浏览 1提问于2014-08-11得票数 0
回答已采纳
我正在使用Spring编写一个Spring批处理，并且我需要根据条件编写两个不同的表，因此我试图使用CompositeItemWriter，但是当我调用该批处理时，不会调用写入器。
这是我的职务配置类。
@Configuration
public class JobConfiguration {
...
...
...
@Bean
public JdbcCursorItemReader<Notification> reader() {
JdbcCursorItemReader<Notification> rea
浏览 0提问于2018-07-20得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储活动推荐
腾讯云开发者
