io.spring.batch.configuration.JobConfiguration类的使用及代码示例

x33g5p2x  于2022-01-21 转载在 其他  
字(4.9k)|赞(0)|评价(0)|浏览(111)

本文整理了Java中io.spring.batch.configuration.JobConfiguration类的一些代码示例,展示了JobConfiguration类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。JobConfiguration类的具体详情如下:
包路径:io.spring.batch.configuration.JobConfiguration
类名称:JobConfiguration

JobConfiguration介绍

暂无

代码示例

代码示例来源:origin: mminella/LearningSpringBatch

@Bean
  public Job job() throws Exception {
    return jobBuilderFactory.get("job")
        .start(step1())
        .build();
  }
}

代码示例来源:origin: mminella/LearningSpringBatch

@Bean
public Step step1() throws Exception {
  return stepBuilderFactory.get("step1")
      .<Customer, Customer>chunk(10)
      .reader(pagingItemReader())
      .processor(itemProcessor())
      .writer(customerItemWriter())
      .build();
}

代码示例来源:origin: mminella/LearningSpringBatch

@Bean
public Step step1() throws Exception {
  return stepBuilderFactory.get("step1")
      .<Customer, Customer>chunk(10)
      .reader(pagingItemReader())
      .writer(itemWriter())
      .stream(xmlItemWriter())
      .stream(jsonItemWriter())
      .build();
}

代码示例来源:origin: mminella/LearningSpringBatch

@Bean
public TaskletStep step1() {
  return stepBuilderFactory.get("step1")
      .<Customer, Customer>chunk(1000)
      .reader(pagingItemReader())
      .processor(upperCaseItemProcessor())
      .writer(customerItemWriter())
      .build();
}

代码示例来源:origin: mminella/LearningSpringBatch

@Bean
public Step step() {
  return stepBuilderFactory.get("step1")
      .<String, String>chunk(10)
      .reader(itemReader())
      .writer(itemWriter())
      .stream(itemReader())
      .build();
}

代码示例来源:origin: mminella/LearningSpringBatch

@Bean
public Step slaveStep() {
  return stepBuilderFactory.get("slaveStep")
      .<Customer, Customer>chunk(1000)
      .reader(pagingItemReader(null, null))
      .writer(customerItemWriter())
      .build();
}

代码示例来源:origin: mminella/LearningSpringBatch

@Bean
public Job job() throws Exception {
  return jobBuilderFactory.get("job")
      .start(step1())
      .listener((JobExecutionListener) jobExecutionlistener())
      .build();
}

代码示例来源:origin: mminella/LearningSpringBatch

@Bean
  public Job job() {
    return jobBuilderFactory.get("job")
        .start(step1())
        .next(step2())
        .build();
  }
}

代码示例来源:origin: mminella/LearningSpringBatch

@Bean
public Step step1() {
  return stepBuilderFactory.get("step1")
      .<Customer, Customer>chunk(10)
      .reader(customerItemReader())
      .writer(customerItemWriter())
      .build();
}

代码示例来源:origin: mminella/LearningSpringBatch

@Bean
public Step step1() {
  return stepBuilderFactory.get("step1")
      .<Customer, Customer>chunk(10)
      .reader(multiResourceItemReader())
      .writer(customerItemWriter())
      .build();
}

代码示例来源:origin: mminella/LearningSpringBatch

@Bean
public AsyncItemWriter asyncItemWriter() throws Exception {
  AsyncItemWriter<Customer> asyncItemWriter = new AsyncItemWriter<>();
  asyncItemWriter.setDelegate(customerItemWriter());
  asyncItemWriter.afterPropertiesSet();
  return asyncItemWriter;
}

代码示例来源:origin: mminella/LearningSpringBatch

@Bean
public Step step1() throws Exception {
  return stepBuilderFactory.get("step1")
      .chunk(1000)
      .reader(pagingItemReader())
      .processor(asyncItemProcessor())
      .writer(asyncItemWriter())
      .build();
}

代码示例来源:origin: mminella/LearningSpringBatch

@Bean
public Step step1() throws Exception {
  return stepBuilderFactory.get("step1")
      .<String, String>chunk(100)
      .reader(itemReader())
      .writer(itemWriter())
      .listener((ChunkListener) chunkListener())
      .build();
}

代码示例来源:origin: mminella/LearningSpringBatch

@Bean
public AsyncItemProcessor asyncItemProcessor() throws Exception {
  AsyncItemProcessor<Customer, Customer> asyncItemProcessor = new AsyncItemProcessor();
  asyncItemProcessor.setDelegate(itemProcessor());
  asyncItemProcessor.setTaskExecutor(new SimpleAsyncTaskExecutor());
  asyncItemProcessor.afterPropertiesSet();
  return asyncItemProcessor;
}

代码示例来源:origin: mminella/LearningSpringBatch

@Bean
public MultiResourceItemReader<Customer> multiResourceItemReader() {
  MultiResourceItemReader<Customer> reader = new MultiResourceItemReader<>();
  reader.setDelegate(customerItemReader());
  reader.setResources(inputFiles);
  return reader;
}

代码示例来源:origin: mminella/LearningSpringBatch

@Bean
public Step step1() throws Exception {
  return stepBuilderFactory.get("step1")
      .<Customer, Customer>chunk(10)
      .reader(pagingItemReader())
      .writer(customerItemWriter())
      .build();
}

代码示例来源:origin: mminella/LearningSpringBatch

@Bean
public Step step1() {
  return stepBuilderFactory.get("step1")
      .<Customer, Customer>chunk(10)
      .reader(customerItemReader())
      .writer(customerItemWriter())
      .build();
}

代码示例来源:origin: mminella/LearningSpringBatch

@Bean
public Step step() {
  return stepBuilderFactory.get("step")
      .<String, String>chunk(10)
      .reader(itemReader())
      .writer(itemWriter())
      .build();
}

代码示例来源:origin: mminella/LearningSpringBatch

@Bean
@Profile("master")
public Job job() throws Exception {
  return jobBuilderFactory.get("job")
      .start(step1())
      .build();
}

代码示例来源:origin: mminella/LearningSpringBatch

@Bean
public Step step1() throws Exception {
  return stepBuilderFactory.get("step1")
      .<Customer, Customer>chunk(10)
      .reader(pagingItemReader())
      .processor(itemProcessor())
      .writer(customerItemWriter())
      .build();
}

相关文章