OPEN - BATCH-803: Add non-buffering ChunkOrientedTasklet (or option in existing one) plus flag for factory bean
moved read counting inside the read loop and removed unused incrementReadCount(int) method
This commit is contained in:
@@ -59,13 +59,6 @@ public class StepContribution {
|
||||
readCount++;
|
||||
}
|
||||
|
||||
/**
|
||||
* Increment the counter for the number of items read.
|
||||
*/
|
||||
public void incrementReadCount(int count) {
|
||||
readCount += count;
|
||||
}
|
||||
|
||||
/**
|
||||
* Increment the counter for the number of items written.
|
||||
*/
|
||||
|
||||
@@ -135,6 +135,7 @@ public class ChunkOrientedTasklet<T, S> implements Tasklet {
|
||||
return ExitStatus.FINISHED;
|
||||
}
|
||||
inputs.add(item);
|
||||
contribution.incrementReadCount();
|
||||
return ExitStatus.CONTINUABLE;
|
||||
}
|
||||
});
|
||||
@@ -143,8 +144,6 @@ public class ChunkOrientedTasklet<T, S> implements Tasklet {
|
||||
if (inputs.isEmpty()) {
|
||||
return result;
|
||||
}
|
||||
|
||||
contribution.incrementReadCount(inputs.size());
|
||||
|
||||
storeInputs(attributes, inputs);
|
||||
|
||||
|
||||
Reference in New Issue
Block a user