[detectionpipeline] simplify Operator interface (#1778)

startreedata · Jan 27, 2025 · 821842e · 821842e
1 parent 88cbac7
commit 821842e
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 21 deletions.
diff --git a/...deye-detectionpipeline/src/main/java/ai/startree/thirdeye/detectionpipeline/Operator.java b/...deye-detectionpipeline/src/main/java/ai/startree/thirdeye/detectionpipeline/Operator.java
@@ -26,22 +26,12 @@ void execute()
 
   String getOperatorName();
 
-  void setProperty(String key, Object value);
-
-
   /**
    * Set keyed input
-   * @param key
-   * @param input
    */
+  @SuppressWarnings("unused") // used in enterprise TE
   void setInput(String key, OperatorResult input);
 
-  /**
-   * Get keyed output
-   * @param key
-   */
-  OperatorResult getOutput(String key);
-
   /**
    * Get all keyed outputs
    */

diff --git a/.../main/java/ai/startree/thirdeye/detectionpipeline/operator/DetectionPipelineOperator.java b/.../main/java/ai/startree/thirdeye/detectionpipeline/operator/DetectionPipelineOperator.java
@@ -94,16 +94,6 @@ protected void setOutput(String key, final OperatorResult output) {
     resultMap.put(key, output);
   }
 
-  @Override
-  public void setProperty(final String key, final Object value) {
-    planNode.getParams().putValue(key, value);
-  }
-
-  @Override
-  public OperatorResult getOutput(final String key) {
-    return resultMap.get(key);
-  }
-
   @Override
   public Map<String, OperatorResult> getOutputs() {
     return resultMap;