Java 类org.springframework.batch.core.configuration.annotation.StepScope 实例源码

项目：oma-riista-web 文件：InnofactorImportConfig.java

@Bean
@StepScope
@Qualifier(STEP_NAME)
public FlatFileItemReader<InnofactorImportFileLine> innofactorReader(
        @Value("#{jobParameters['inputFile']}") String inputFile) {

    FlatFileItemReader<InnofactorImportFileLine> reader = new FlatFileItemReader<>();

    reader.setEncoding(StandardCharsets.UTF_8.name());
    reader.setLineMapper(innofactorImportLineMapper());
    reader.setStrict(true);
    reader.setResource(new FileSystemResource(inputFile));
    reader.setLinesToSkip(0);
    reader.setBufferedReaderFactory(bufferedReaderFactory);

    return reader;
}

项目：java-remote-partitioning 文件：JobConfiguration.java

@Bean
@StepScope
public JdbcBatchItemWriter<Customer> customerItemWriter() {
    JdbcBatchItemWriter<Customer> itemWriter = new JdbcBatchItemWriter<>();

    itemWriter.setDataSource(this.dataSource);
    itemWriter.setSql("INSERT INTO NEW_CUSTOMER VALUES (:id, :firstName, :lastName, :birthdate)");
    itemWriter.setItemSqlParameterSourceProvider(new BeanPropertyItemSqlParameterSourceProvider());
    itemWriter.afterPropertiesSet();

    return itemWriter;
}

项目：signature-processing 文件：BatchConfig.java

/**
 * @return reader of signatures from transcript files in inbox directory
 */
@Bean
@StepScope
public MultiResourceItemReader<Signature> transcriptSignatureItemReader() {

    /* Get transcript resources */
    Resource[] resources = listIdsStore()
        .stream()
        . <Resource> map(listId ->
                new FileSystemResource(INBOX_DIR + listId + ".txt"))
        .toArray(size -> new Resource[size]);

    /* Create MultiResourceItemReader */
    MultiResourceItemReader<Signature> multiResourceReader =
            new MultiResourceItemReader<>();
    multiResourceReader.setResources(resources);
    multiResourceReader.setDelegate(trascriptSignatureReader());

    return multiResourceReader;
}

项目：building-microservices 文件：BatchConfiguration.java

@Bean
@StepScope
FlatFileItemReader<Person> flatFileItemReader(@Value("#{jobParameters[file]}") File file) {
    FlatFileItemReader<Person> r = new FlatFileItemReader<>();
    r.setResource(new FileSystemResource(file));
    r.setLineMapper(new DefaultLineMapper<Person>() {
        {
            this.setLineTokenizer(new DelimitedLineTokenizer(",") {
                {
                    this.setNames(new String[]{"first", "last", "email"});
                }
            });
            this.setFieldSetMapper(new BeanWrapperFieldSetMapper<Person>() {
                {
                    this.setTargetType(Person.class);
                }
            });
        }
    });
    return r;
}

项目：springone-2015 文件：BatchHive2Configuration.java

@Bean
@StepScope
ItemReader<Map<String, Object>> hdfsFileReader(HdfsResourceLoader resourceLoader, LineMapper<Map<String, Object>> lineMapper) throws IOException {
    MultiResourceItemReader<Map<String, Object>> multiReader = new MultiResourceItemReader<>();
    Resource[] resources = resourceLoader.getResources("/demo/influencers/*");
    multiReader.setResources(resources);    
    FlatFileItemReader<Map<String, Object>> itemReader = new FlatFileItemReader<>();
    itemReader.setLineMapper(lineMapper);
    multiReader.setDelegate(itemReader);
    return multiReader;
}

项目：commercetools-sunrise-data 文件：OrdersImportJobConfiguration.java

@Bean
@StepScope
protected OrderImportItemReader orderReader(@Value("#{jobParameters['resource']}") final Resource orderCsvResource) {

    FlatFileItemReader flatFileItemReader = new FlatFileItemReader<>();
    flatFileItemReader.setLineMapper(new DefaultLineMapper<OrderCsvLineValue>() {{
        setLineTokenizer(new DelimitedLineTokenizer() {{
            setNames(ORDER_CSV_HEADER_NAMES);

        }});
        setFieldSetMapper(new BeanWrapperFieldSetMapper<OrderCsvLineValue>() {{
            setTargetType(OrderCsvLineValue.class);
        }});
    }});
    flatFileItemReader.setLinesToSkip(1);
    flatFileItemReader.setResource(orderCsvResource);

    SingleItemPeekableItemReader singleItemPeekableItemReader = new SingleItemPeekableItemReader();
    singleItemPeekableItemReader.setDelegate(flatFileItemReader);

    OrderImportItemReader reader = new OrderImportItemReader();
    reader.setDelegate(singleItemPeekableItemReader);

    return reader;
}

项目：yona-server 文件：SendSystemMessageBatchJob.java

@Bean(name = "sendSystemMessageJobUserAnonymizedProcessor", destroyMethod = "")
@StepScope
private ItemProcessor<UUID, MessageDestination> userAnonymizedProcessor()
{
    return new ItemProcessor<UUID, MessageDestination>() {
        @Value("#{jobParameters['messageText']}")
        private String messageText;

        @Override
        public MessageDestination process(UUID userAnonymizedId) throws Exception
        {
            logger.debug("Processing user anonymized with id {}", userAnonymizedId);
            UserAnonymizedDto userAnonymized = userAnonymizedService.getUserAnonymized(userAnonymizedId);

            MessageDestination messageDestination = messageDestinationRepository
                    .findOne(userAnonymized.getAnonymousDestination().getId());
            messageDestination.send(SystemMessage.createInstance(messageText));

            return messageDestination;
        }
    };
}

项目：spring-batch-tools 文件：TestJobConfig.java

@Bean
@StepScope
public ItemReader<String> itemReader() {
    final List<String> items = IntStream.range(0, 1000).mapToObj(String::valueOf).collect(toList());

    return new ListItemReader<String>(items);
}

项目：javaconfig-ftw 文件：BatchConfiguration.java

/**
 * maps CSV data into rows of fields, which are then
 * mapped to Customer.class instances based on conventions:
 * <p/>
 * <CODE>col 1 => firstName => customer.setFirstName(String)</CODE>
 */
@Bean(name = readCsvFileIntoTableStepReader)
@StepScope
public FlatFileItemReader<Customer> reader(@Value("#{jobParameters['input.file']}") Resource resource) throws Exception {

    log.debug(String.format("building FlatFileItemReader to read in the file %s", resource.getFile().getAbsolutePath()));

    FlatFileItemReader<Customer> csvFileReader = new FlatFileItemReader<Customer>();
    csvFileReader.setResource(resource);

    DelimitedLineTokenizer delimitedLineTokenizer = new DelimitedLineTokenizer(DelimitedLineTokenizer.DELIMITER_COMMA);
    delimitedLineTokenizer.setNames(new String[]{"lastName", "firstName"});

    BeanWrapperFieldSetMapper<Customer> beanWrapperFieldSetMapper = new BeanWrapperFieldSetMapper<Customer>();
    beanWrapperFieldSetMapper.setTargetType(Customer.class);

    DefaultLineMapper<Customer> defaultLineMapper = new DefaultLineMapper<Customer>();
    defaultLineMapper.setLineTokenizer(delimitedLineTokenizer);
    defaultLineMapper.setFieldSetMapper(beanWrapperFieldSetMapper);

    csvFileReader.setLineMapper(defaultLineMapper);
    return csvFileReader;
}

项目：spring-batch-experiments 文件：SkipConfiguration.java

@Bean
@StepScope
public FlatFileItemReader<Product> productReader(@Value("#{jobParameters['inputFile']}") String inputFile) {

    DelimitedLineTokenizer tokenizer = new DelimitedLineTokenizer(",");
    tokenizer.setNames(new String[] { "PRODUCT_ID", "NAME", "DESCRIPTION", "PRICE" });

    DefaultLineMapper<Product> lineMapper = new DefaultLineMapper<Product>();
    lineMapper.setLineTokenizer(tokenizer);
    lineMapper.setFieldSetMapper(new ProductFieldSetMapper());

    FlatFileItemReader<Product> reader = new FlatFileItemReader<Product>();

    try {
        reader.setResource(new FileSystemResource(ResourceUtils.getFile(inputFile)));
    } catch (FileNotFoundException e) {
        log.error("파일을 찾을 수 없습니다. inputFile=" + inputFile, e);
        throw new RuntimeException(e);
    }
    reader.setLinesToSkip(1);
    reader.setLineMapper(lineMapper);

    return reader;
}

项目：oma-riista-web 文件：LHHuntingClubBatchConfig.java

@Bean
@StepScope
@Qualifier(IMPORT_STEP)
public FlatFileItemReader<LHHuntingClubCSVRow> lhClubImportReader(
        @Value("#{jobExecutionContext['inputFile']}") String inputFile) {
    final FlatFileItemReader<LHHuntingClubCSVRow> reader = new FlatFileItemReader<>();

    reader.setEncoding(StandardCharsets.ISO_8859_1.name());
    reader.setLineMapper(inputLineMapper());
    reader.setStrict(true);
    reader.setResource(new FileSystemResource(inputFile));
    reader.setLinesToSkip(1);

    return reader;
}

项目：oma-riista-web 文件：InnofactorImportConfig.java

@Bean
@StepScope
@Qualifier(STEP_NAME)
public MetsastajaRekisteriPersonItemWriter innofactorWriter(
        @Value("#{jobParameters['importTimestamp']}") long importTimestamp) {
    return new MetsastajaRekisteriPersonItemWriter(importService, importTimestamp);
}

项目：java-remote-partitioning 文件：JobConfiguration.java

@Bean
@StepScope
public JdbcPagingItemReader<Customer> pagingItemReader(
        @Value("#{stepExecutionContext['minValue']}")Long minValue,
        @Value("#{stepExecutionContext['maxValue']}")Long maxValue) {
    System.out.println("reading " + minValue + " to " + maxValue);
    JdbcPagingItemReader<Customer> reader = new JdbcPagingItemReader<>();

    reader.setDataSource(this.dataSource);
    reader.setFetchSize(1000);
    reader.setRowMapper(new CustomerRowMapper());

    MySqlPagingQueryProvider queryProvider = new MySqlPagingQueryProvider();
    queryProvider.setSelectClause("id, firstName, lastName, birthdate");
    queryProvider.setFromClause("from customer");
    queryProvider.setWhereClause("where id >= " + minValue + " and id <= " + maxValue);

    Map<String, Order> sortKeys = new HashMap<>(1);

    sortKeys.put("id", Order.ASCENDING);

    queryProvider.setSortKeys(sortKeys);

    reader.setQueryProvider(queryProvider);

    return reader;
}

项目：springBatchBootJavaConfigkata 文件：JobConfig.java

@Bean
@StepScope
public ItemReader<String> firstReader(@Value("#{jobParameters[message]}") String text) {
    log.info("+++ r-r-r  {} ", text);
  return new ListItemReader<>(Lists.newArrayList(text));
}

项目：jplantuml 文件：PlantUmlConfig.java

@Bean
@StepScope
public ItemProcessor<Path, NamedBytes> processor(@Value("#{jobParameters[globalParams]}") String globalParams) {
    CompositeItemProcessor<Path, NamedBytes> processors = new CompositeItemProcessor<>();
    FileContentItemProcessor fileContentProcessor = new FileContentItemProcessor();
    GlobalParametersEnricherProcessor paramsEnricherProcessor = new GlobalParametersEnricherProcessor(globalParams);
    FileExtensionStripperProcessor fileExtensionStripperProcessor = new FileExtensionStripperProcessor();
    PlantUmlItemProcessor plantUmlProcessor = new PlantUmlItemProcessor(settings);
    processors.setDelegates(Arrays.asList(fileContentProcessor, paramsEnricherProcessor, fileExtensionStripperProcessor,
        plantUmlProcessor));
    return processors;
}

项目：yona-server 文件：ActivityAggregationBatchJob.java

@Bean(name = "activityAggregationJobDayActivityReader", destroyMethod = "")
@StepScope
public ItemReader<Long> dayActivityReader()
{
    return intervalActivityIdReader(Date.valueOf(
            TimeUtil.getStartOfDay(DEFAULT_TIME_ZONE, ZonedDateTime.now(DEFAULT_TIME_ZONE)).minusDays(1).toLocalDate()),
            DayActivity.class, DAY_ACTIVITY_CHUNK_SIZE);
}

项目：yona-server 文件：ActivityAggregationBatchJob.java

@Bean(name = "activityAggregationJobWeekActivityReader", destroyMethod = "")
@StepScope
public ItemReader<Long> weekActivityReader()
{
    return intervalActivityIdReader(Date.valueOf(
            TimeUtil.getStartOfWeek(DEFAULT_TIME_ZONE, ZonedDateTime.now(DEFAULT_TIME_ZONE)).minusWeeks(1).toLocalDate()),
            WeekActivity.class, WEEK_ACTIVITY_CHUNK_SIZE);
}

项目：spring-cloud-task 文件：JobConfiguration.java

@Bean
@StepScope
public Tasklet workerTasklet(
        final @Value("#{stepExecutionContext['partitionNumber']}")Integer partitionNumber) {

    return new Tasklet() {
        @Override
        public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) throws Exception {
            System.out.println("This tasklet ran partition: " + partitionNumber);

            return RepeatStatus.FINISHED;
        }
    };
}