@BeanpublicJoborderJob()throwsException{returnjobBuilderFactory.get("orderJob").incrementer(newRunIdIncrementer()).listener(listener()).flow(orderStep()).end().build();}@BeanpublicSteporderStep()throwsException{returnstepBuilderFactory.get("orderStep").chunk(1000).reader(orderReader()).processor
我发现MongoItemReader有一个奇怪的问题。这是我的步骤配置:privateStepaddMnpInformation()throwsException{returnstepBuilders.get("addMnpInformation").chunk(50).reader(stagedCdrReader()).processor(addMnpProcessor()).writer(stagedCdrWriter()).build();}这是读者@BeanpublicMongoItemReaderstagedCdrReader()throwsException{MongoIt
一些需求是如何改变的,我必须在setQuery()中使用聚合查询而不是基本查询。这可能吗?请建议我该怎么做?我的聚合查询已准备就绪,但不确定如何在springbatch中使用它publicItemReadersearchMongoItemReader()throwsException,UnexpectedInputException,ParseException,NonTransientResourceException{MongoItemReadermongoItemReader=newMongoItemReader();mongoItemReader.setTemplate(myM
我有一个使用MongoDB数据库为MySQL数据库提供数据的SpringBoot批处理。该程序正在处理我大约一半的数据库,但我的日志中只有大约200个错误。BATCH_STEP_EXECUTION表让我知道过程进展顺利(状态已完成)并显示READ_COUNT为5692,尽管我在数据库中有11800个文档。我是否忘记了配置中的某些内容以防止不遍历整个数据库?这是我的配置类:@Configuration@EnableBatchProcessing@Import(PersistenceConfig.class)publicclassBatchConfiguration{@AutowiredM
我有一个使用MongoDB数据库为MySQL数据库提供数据的SpringBoot批处理。该程序正在处理我大约一半的数据库,但我的日志中只有大约200个错误。BATCH_STEP_EXECUTION表让我知道过程进展顺利(状态已完成)并显示READ_COUNT为5692,尽管我在数据库中有11800个文档。我是否忘记了配置中的某些内容以防止不遍历整个数据库?这是我的配置类:@Configuration@EnableBatchProcessing@Import(PersistenceConfig.class)publicclassBatchConfiguration{@AutowiredM