This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a commit to branch
3994-remove-deprecated-classes-streampipesdataprocessor-streampipesdatasink
in repository https://gitbox.apache.org/repos/asf/streampipes.git
The following commit(s) were added to
refs/heads/3994-remove-deprecated-classes-streampipesdataprocessor-streampipesdatasink
by this push:
new 28d8fc6d81 refactor: Remove deprecated classes
28d8fc6d81 is described below
commit 28d8fc6d81a1233db42ef2fe4c9ad091b905a8db
Author: Philipp Zehnder <[email protected]>
AuthorDate: Fri Nov 28 16:11:38 2025 +0100
refactor: Remove deprecated classes
---
.../standalone/StreamPipesDataProcessor.java | 69 ---------------------
.../wrapper/standalone/StreamPipesDataSink.java | 71 ----------------------
2 files changed, 140 deletions(-)
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
deleted file mode 100644
index e07c821706..0000000000
---
a/streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/StreamPipesDataProcessor.java
+++ /dev/null
@@ -1,69 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- *
- */
-package org.apache.streampipes.wrapper.standalone;
-
-import org.apache.streampipes.commons.exceptions.SpRuntimeException;
-import org.apache.streampipes.extensions.api.pe.IStreamPipesDataProcessor;
-import
org.apache.streampipes.extensions.api.pe.config.IDataProcessorConfiguration;
-import
org.apache.streampipes.extensions.api.pe.context.EventProcessorRuntimeContext;
-import org.apache.streampipes.extensions.api.pe.param.IDataProcessorParameters;
-import org.apache.streampipes.extensions.api.pe.routing.SpOutputCollector;
-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,
- EventProcessorRuntimeContext runtimeContext) {
- ProcessorParams parameters = new ProcessorParams(params);
- this.onInvocation(parameters, collector, runtimeContext);
- }
-
- @Override
- public IDataProcessorConfiguration declareConfig() {
- return DataProcessorConfiguration.create(
- () -> {
- try {
- return this.getClass().newInstance();
- } catch (InstantiationException e) {
- throw new RuntimeException(e);
- } catch (IllegalAccessException e) {
- throw new RuntimeException(e);
- }
- },
- declareModel()
- );
- }
-
- @Override
- public void onPipelineStopped() {
- this.onDetach();
- }
-
- public abstract DataProcessorDescription declareModel();
-
- public abstract void onInvocation(ProcessorParams parameters,
- SpOutputCollector spOutputCollector,
- EventProcessorRuntimeContext
runtimeContext) throws SpRuntimeException;
-
- public abstract void onDetach();
-}
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
deleted file mode 100644
index 82be1f9236..0000000000
---
a/streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/StreamPipesDataSink.java
+++ /dev/null
@@ -1,71 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- *
- */
-package org.apache.streampipes.wrapper.standalone;
-
-import org.apache.streampipes.commons.exceptions.SpRuntimeException;
-import org.apache.streampipes.extensions.api.pe.IStreamPipesDataSink;
-import org.apache.streampipes.extensions.api.pe.config.IDataSinkConfiguration;
-import
org.apache.streampipes.extensions.api.pe.context.EventSinkRuntimeContext;
-import org.apache.streampipes.extensions.api.pe.param.IDataSinkParameters;
-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
- public void onPipelineStarted(
- IDataSinkParameters params,
- EventSinkRuntimeContext runtimeContext
- ) {
- SinkParams parameters = new SinkParams(params);
- this.onInvocation(parameters, runtimeContext);
- }
-
- @Override
- public IDataSinkConfiguration declareConfig() {
- return DataSinkConfiguration.create(
- () -> {
- try {
- return this.getClass()
- .newInstance();
- } catch (InstantiationException e) {
- throw new RuntimeException(e);
- } catch (IllegalAccessException e) {
- throw new RuntimeException(e);
- }
- },
- declareModel()
- );
- }
-
- @Override
- public void onPipelineStopped() {
- this.onDetach();
- }
-
- public abstract DataSinkDescription declareModel();
-
- public abstract void onInvocation(
- SinkParams parameters,
- EventSinkRuntimeContext runtimeContext
- ) throws SpRuntimeException;
-
- public abstract void onDetach();
-}
