Skip to content

Commit 0b1b889

Browse files
authored
refactor(#3200): Mark StreamPipesDataProcessor and StreamPipesDataSink as deprecated (#3666)
1 parent 6e90a99 commit 0b1b889

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/StreamPipesDataProcessor.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,9 +27,9 @@
2727
import org.apache.streampipes.sdk.builder.processor.DataProcessorConfiguration;
2828
import org.apache.streampipes.wrapper.params.compat.ProcessorParams;
2929

30+
@Deprecated(since = "0.98.0", forRemoval = true)
3031
public abstract class StreamPipesDataProcessor
3132
implements IStreamPipesDataProcessor {
32-
3333
@Override
3434
public void onPipelineStarted(IDataProcessorParameters params,
3535
SpOutputCollector collector,

streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/StreamPipesDataSink.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,7 @@
2626
import org.apache.streampipes.sdk.builder.sink.DataSinkConfiguration;
2727
import org.apache.streampipes.wrapper.params.compat.SinkParams;
2828

29+
@Deprecated(since = "0.98.0", forRemoval = true)
2930
public abstract class StreamPipesDataSink implements IStreamPipesDataSink {
3031

3132
@Override

0 commit comments

Comments
 (0)