@AfterStep public ExitStatus afterStep(StepExecution stepExecution) { final Interval interval = new Interval( stepExecution.getStartTime().getTime(), System.currentTimeMillis()); LOG.debug("Finished step: {} in {}. read = {} write = {} commit = {} rollback = {} filter = {} skip = {}", stepExecution.getStepName(), PeriodFormat.getDefault().print(interval.toPeriod()), stepExecution.getReadCount(), stepExecution.getWriteCount(), stepExecution.getCommitCount(), stepExecution.getRollbackCount(), stepExecution.getFilterCount(), stepExecution.getSkipCount()); return stepExecution.getExitStatus(); }
/** * Dispose the excel object */ @AfterStep public void dispose() { if(excel != null) try{ excel.dispose(); } catch(Exception e){} }
@AfterStep public ExitStatus afterStep(StepExecution stepExecution) { File file = fileService.getById(getServiceContext(), getFileId()); file.setTotalRecordCount(stepExecution.getReadCount() + stepExecution.getReadSkipCount()); fileService.addOrUpdate(getServiceContext(), file); return null; }
@AfterStep public ExitStatus afterStep(StepExecution stepExecution) { log.info("스텝 완료 후 호출됩니다. StepName=[{}], ExitStatus=[{}]", stepExecution.getStepName(), stepExecution.getExitStatus()); return ExitStatus.COMPLETED; }
@AfterStep public void saveStepExecution(final StepExecution stepExecution) { this.key2vcf.values().stream().forEach(V->{try {V.close();}catch(Exception err){}});; stepExecution.getExecutionContext().putString("file", "out"); }
@Override @AfterStep public ExitStatus afterStep(StepExecution stepExecution) { log.info("$$$ after step {}",stepExecution.getStepName()); return null; }
@Override @AfterStep public ExitStatus afterStep(StepExecution stepExecution) { return null; }