This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a commit to branch 3200-migration-to-new-data-processor-api
in repository https://gitbox.apache.org/repos/asf/streampipes.git
The following commit(s) were added to
refs/heads/3200-migration-to-new-data-processor-api by this push:
new 849600befe refactor(#3200): Mark StreamPipesDataProcessor and
StreamPipesDataSink as deprecated
849600befe is described below
commit 849600befe9bdc139ee9cb81fefffe0fdf5b2303
Author: Philipp Zehnder <[email protected]>
AuthorDate: Wed Jun 11 09:50:13 2025 +0200
refactor(#3200): Mark StreamPipesDataProcessor and StreamPipesDataSink as
deprecated
---
.../apache/streampipes/wrapper/standalone/StreamPipesDataProcessor.java | 2 +-
.../org/apache/streampipes/wrapper/standalone/StreamPipesDataSink.java | 1 +
2 files changed, 2 insertions(+), 1 deletion(-)
diff --git
a/streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/StreamPipesDataProcessor.java
b/streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/StreamPipesDataProcessor.java
index d326066667..e07c821706 100644
---
a/streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/StreamPipesDataProcessor.java
+++
b/streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/StreamPipesDataProcessor.java
@@ -27,9 +27,9 @@ import
org.apache.streampipes.model.graph.DataProcessorDescription;
import org.apache.streampipes.sdk.builder.processor.DataProcessorConfiguration;
import org.apache.streampipes.wrapper.params.compat.ProcessorParams;
+@Deprecated(since = "0.98.0", forRemoval = true)
public abstract class StreamPipesDataProcessor
implements IStreamPipesDataProcessor {
-
@Override
public void onPipelineStarted(IDataProcessorParameters params,
SpOutputCollector collector,
diff --git
a/streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/StreamPipesDataSink.java
b/streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/StreamPipesDataSink.java
index aed7a4223c..82be1f9236 100644
---
a/streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/StreamPipesDataSink.java
+++
b/streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/StreamPipesDataSink.java
@@ -26,6 +26,7 @@ import org.apache.streampipes.model.graph.DataSinkDescription;
import org.apache.streampipes.sdk.builder.sink.DataSinkConfiguration;
import org.apache.streampipes.wrapper.params.compat.SinkParams;
+@Deprecated(since = "0.98.0", forRemoval = true)
public abstract class StreamPipesDataSink implements IStreamPipesDataSink {
@Override
