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();
-}