refactor: remove legacy type definition

apache · Oct 27, 2023 · 542d632 · 542d632
1 parent 1b1b4c0
commit 542d632
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/.../src/main/java/org/apache/streampipes/wrapper/distributed/runtime/DistributedRuntime.java b/.../src/main/java/org/apache/streampipes/wrapper/distributed/runtime/DistributedRuntime.java
@@ -43,7 +43,7 @@ public abstract class DistributedRuntime<
     PeT extends IStreamPipesPipelineElement<?>,
     IvT extends InvocableStreamPipesEntity,
     RcT extends RuntimeContext,
-    ExT extends IParameterExtractor<IvT>,
+    ExT extends IParameterExtractor,
     PepT extends IPipelineElementParameters<IvT, ExT>>
     extends PipelineElementRuntime<PeT, IvT, RcT, ExT, PepT>
     implements IStreamPipesRuntime<PeT, IvT> {

diff --git a/...mpipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/FlinkRuntime.java b/...mpipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/FlinkRuntime.java
@@ -69,7 +69,7 @@ public abstract class FlinkRuntime<
     PeT extends IStreamPipesPipelineElement<?>,
     IvT extends InvocableStreamPipesEntity,
     RcT extends RuntimeContext,
-    ExT extends IParameterExtractor<IvT>,
+    ExT extends IParameterExtractor,
     PepT extends IPipelineElementParameters<IvT, ExT>,
     FpT extends IFlinkProgram>
     extends DistributedRuntime<PeT, IvT, RcT, ExT, PepT>

diff --git a/...kafka-streams/src/main/java/org/apache/streampipes/wrapper/kafka/KafkaStreamsRuntime.java b/...kafka-streams/src/main/java/org/apache/streampipes/wrapper/kafka/KafkaStreamsRuntime.java
@@ -39,7 +39,7 @@ public abstract class KafkaStreamsRuntime<
     PeT extends IStreamPipesPipelineElement<?>,
     IvT extends InvocableStreamPipesEntity,
     RcT extends RuntimeContext,
-    ExT extends IParameterExtractor<IvT>,
+    ExT extends IParameterExtractor,
     PepT extends IPipelineElementParameters<IvT, ExT>>
     extends DistributedRuntime<PeT, IvT, RcT, ExT, PepT>
     implements IStreamPipesRuntime<PeT, IvT> {