diff --git a/spring-batch-plus/src/main/java/com/navercorp/spring/batch/plus/step/adapter/ItemProcessorAdapter.java b/spring-batch-plus/src/main/java/com/navercorp/spring/batch/plus/step/adapter/ItemProcessorAdapter.java index 3a61f1f5..96f3701b 100644 --- a/spring-batch-plus/src/main/java/com/navercorp/spring/batch/plus/step/adapter/ItemProcessorAdapter.java +++ b/spring-batch-plus/src/main/java/com/navercorp/spring/batch/plus/step/adapter/ItemProcessorAdapter.java @@ -48,9 +48,8 @@ protected ItemProcessorAdapter(ItemProcessorDelegate delegate) { this.delegate = Objects.requireNonNull(delegate, "Delegate processor must not be null"); } - @SuppressWarnings("NullableProblems") @Override - public O process(I item) { + public O process(@NonNull I item) { return this.delegate.process(item); } } diff --git a/spring-batch-plus/src/main/java/com/navercorp/spring/batch/plus/step/adapter/ItemStreamFluxReaderAdapter.java b/spring-batch-plus/src/main/java/com/navercorp/spring/batch/plus/step/adapter/ItemStreamFluxReaderAdapter.java index 7c21aa47..373612a2 100644 --- a/spring-batch-plus/src/main/java/com/navercorp/spring/batch/plus/step/adapter/ItemStreamFluxReaderAdapter.java +++ b/spring-batch-plus/src/main/java/com/navercorp/spring/batch/plus/step/adapter/ItemStreamFluxReaderAdapter.java @@ -58,9 +58,8 @@ protected ItemStreamFluxReaderAdapter(ItemStreamFluxReaderDelegate delegate) this.delegate = Objects.requireNonNull(delegate, "Delegate reader must not be null"); } - @SuppressWarnings("NullableProblems") @Override - public void open(ExecutionContext executionContext) { + public void open(@NonNull ExecutionContext executionContext) { this.delegate.onOpenRead(executionContext); this.flux = this.delegate.readFlux(executionContext); } @@ -75,9 +74,8 @@ public T read() { } } - @SuppressWarnings("NullableProblems") @Override - public void update(ExecutionContext executionContext) { + public void update(@NonNull ExecutionContext executionContext) { this.delegate.onUpdateRead(executionContext); } diff --git a/spring-batch-plus/src/main/java/com/navercorp/spring/batch/plus/step/adapter/ItemStreamIterableReaderAdapter.java b/spring-batch-plus/src/main/java/com/navercorp/spring/batch/plus/step/adapter/ItemStreamIterableReaderAdapter.java index aa8c38ec..253a1f4c 100644 --- a/spring-batch-plus/src/main/java/com/navercorp/spring/batch/plus/step/adapter/ItemStreamIterableReaderAdapter.java +++ b/spring-batch-plus/src/main/java/com/navercorp/spring/batch/plus/step/adapter/ItemStreamIterableReaderAdapter.java @@ -54,9 +54,8 @@ protected ItemStreamIterableReaderAdapter(ItemStreamIterableReaderDelegate de this.delegate = Objects.requireNonNull(delegate, "Delegate reader must not be null"); } - @SuppressWarnings("NullableProblems") @Override - public void open(ExecutionContext executionContext) { + public void open(@NonNull ExecutionContext executionContext) { this.delegate.onOpenRead(executionContext); this.iterable = this.delegate.readIterable(executionContext); } @@ -71,9 +70,8 @@ public T read() { } } - @SuppressWarnings("NullableProblems") @Override - public void update(ExecutionContext executionContext) { + public void update(@NonNull ExecutionContext executionContext) { this.delegate.onUpdateRead(executionContext); } diff --git a/spring-batch-plus/src/main/java/com/navercorp/spring/batch/plus/step/adapter/ItemStreamIteratorReaderAdapter.java b/spring-batch-plus/src/main/java/com/navercorp/spring/batch/plus/step/adapter/ItemStreamIteratorReaderAdapter.java index c9a1d842..803f9f86 100644 --- a/spring-batch-plus/src/main/java/com/navercorp/spring/batch/plus/step/adapter/ItemStreamIteratorReaderAdapter.java +++ b/spring-batch-plus/src/main/java/com/navercorp/spring/batch/plus/step/adapter/ItemStreamIteratorReaderAdapter.java @@ -51,9 +51,8 @@ protected ItemStreamIteratorReaderAdapter(ItemStreamIteratorReaderDelegate de this.delegate = Objects.requireNonNull(delegate, "Delegate reader must not be null"); } - @SuppressWarnings("NullableProblems") @Override - public void open(ExecutionContext executionContext) { + public void open(@NonNull ExecutionContext executionContext) { this.delegate.onOpenRead(executionContext); this.iterator = this.delegate.readIterator(executionContext); } @@ -68,9 +67,8 @@ public T read() { } } - @SuppressWarnings("NullableProblems") @Override - public void update(ExecutionContext executionContext) { + public void update(@NonNull ExecutionContext executionContext) { this.delegate.onUpdateRead(executionContext); } diff --git a/spring-batch-plus/src/main/java/com/navercorp/spring/batch/plus/step/adapter/ItemStreamSimpleReaderAdapter.java b/spring-batch-plus/src/main/java/com/navercorp/spring/batch/plus/step/adapter/ItemStreamSimpleReaderAdapter.java index 2a6a52dd..b3378d33 100644 --- a/spring-batch-plus/src/main/java/com/navercorp/spring/batch/plus/step/adapter/ItemStreamSimpleReaderAdapter.java +++ b/spring-batch-plus/src/main/java/com/navercorp/spring/batch/plus/step/adapter/ItemStreamSimpleReaderAdapter.java @@ -48,9 +48,8 @@ protected ItemStreamSimpleReaderAdapter(ItemStreamSimpleReaderDelegate delega this.delegate = Objects.requireNonNull(delegate, "Delegate reader must not be null"); } - @SuppressWarnings("NullableProblems") @Override - public void open(ExecutionContext executionContext) { + public void open(@NonNull ExecutionContext executionContext) { this.delegate.onOpenRead(executionContext); } @@ -59,9 +58,8 @@ public T read() { return this.delegate.read(); } - @SuppressWarnings("NullableProblems") @Override - public void update(ExecutionContext executionContext) { + public void update(@NonNull ExecutionContext executionContext) { this.delegate.onUpdateRead(executionContext); } diff --git a/spring-batch-plus/src/main/java/com/navercorp/spring/batch/plus/step/adapter/ItemStreamWriterAdapter.java b/spring-batch-plus/src/main/java/com/navercorp/spring/batch/plus/step/adapter/ItemStreamWriterAdapter.java index 3445367e..89e72bc5 100644 --- a/spring-batch-plus/src/main/java/com/navercorp/spring/batch/plus/step/adapter/ItemStreamWriterAdapter.java +++ b/spring-batch-plus/src/main/java/com/navercorp/spring/batch/plus/step/adapter/ItemStreamWriterAdapter.java @@ -49,21 +49,18 @@ protected ItemStreamWriterAdapter(ItemStreamWriterDelegate delegate) { this.delegate = Objects.requireNonNull(delegate, "Delegate writer must not be null"); } - @SuppressWarnings("NullableProblems") @Override - public void open(ExecutionContext executionContext) { + public void open(@NonNull ExecutionContext executionContext) { this.delegate.onOpenWrite(executionContext); } - @SuppressWarnings("NullableProblems") @Override - public void write(Chunk chunk) { + public void write(@NonNull Chunk chunk) { this.delegate.write(chunk); } - @SuppressWarnings("NullableProblems") @Override - public void update(ExecutionContext executionContext) { + public void update(@NonNull ExecutionContext executionContext) { this.delegate.onUpdateWrite(executionContext); } diff --git a/spring-batch-plus/src/main/java/com/navercorp/spring/batch/plus/step/adapter/StepScopeItemStreamReader.java b/spring-batch-plus/src/main/java/com/navercorp/spring/batch/plus/step/adapter/StepScopeItemStreamReader.java index b82b0d84..b50c31b8 100644 --- a/spring-batch-plus/src/main/java/com/navercorp/spring/batch/plus/step/adapter/StepScopeItemStreamReader.java +++ b/spring-batch-plus/src/main/java/com/navercorp/spring/batch/plus/step/adapter/StepScopeItemStreamReader.java @@ -30,6 +30,7 @@ import org.springframework.batch.item.ExecutionContext; import org.springframework.batch.item.ItemStreamException; import org.springframework.batch.item.ItemStreamReader; +import org.springframework.lang.NonNull; /** * A {@link StepScope} bound proxy implementation. @@ -60,9 +61,8 @@ protected StepScopeItemStreamReader(Supplier> readerGenerato this.delegateSupplier = Objects.requireNonNull(readerGenerator, "Reader generator must not be null"); } - @SuppressWarnings("NullableProblems") @Override - public void open(ExecutionContext executionContext) throws ItemStreamException { + public void open(@NonNull ExecutionContext executionContext) throws ItemStreamException { getDelegate().open(executionContext); } @@ -71,9 +71,8 @@ public T read() throws Exception { return getDelegate().read(); } - @SuppressWarnings("NullableProblems") @Override - public void update(ExecutionContext executionContext) throws ItemStreamException { + public void update(@NonNull ExecutionContext executionContext) throws ItemStreamException { getDelegate().update(executionContext); }