From 94612951188c6264b1346843635a1a8be8340b67 Mon Sep 17 00:00:00 2001
From: Yicong Huang <17627829+Yicong-Huang@users.noreply.github.com>
Date: Thu, 19 Dec 2024 10:41:53 -0800
Subject: [PATCH] remove sink desc

---
 .../edu/uci/ics/texera/workflow/SchemaPropagationSpec.scala  | 3 +--
 .../scala/edu/uci/ics/amber/operator/sink/SinkOpDesc.scala   | 5 -----
 2 files changed, 1 insertion(+), 7 deletions(-)
 delete mode 100644 core/workflow-operator/src/main/scala/edu/uci/ics/amber/operator/sink/SinkOpDesc.scala

diff --git a/core/amber/src/test/scala/edu/uci/ics/texera/workflow/SchemaPropagationSpec.scala b/core/amber/src/test/scala/edu/uci/ics/texera/workflow/SchemaPropagationSpec.scala
index c680177e28c..cb77ae266aa 100644
--- a/core/amber/src/test/scala/edu/uci/ics/texera/workflow/SchemaPropagationSpec.scala
+++ b/core/amber/src/test/scala/edu/uci/ics/texera/workflow/SchemaPropagationSpec.scala
@@ -4,7 +4,6 @@ import edu.uci.ics.amber.core.tuple.{AttributeType, Schema}
 import edu.uci.ics.amber.core.workflow.{PhysicalOp, WorkflowContext}
 import edu.uci.ics.amber.operator.LogicalOp
 import edu.uci.ics.amber.operator.metadata.OperatorInfo
-import edu.uci.ics.amber.operator.sink.SinkOpDesc
 import edu.uci.ics.amber.operator.source.SourceOperatorDescriptor
 import edu.uci.ics.amber.virtualidentity.{ExecutionIdentity, OperatorIdentity, WorkflowIdentity}
 import edu.uci.ics.amber.workflow.{InputPort, OutputPort, PortIdentity}
@@ -24,7 +23,7 @@ class SchemaPropagationSpec extends AnyFlatSpec with BeforeAndAfter {
       OperatorInfo("", "", "", List(InputPort()), List(OutputPort()))
   }
 
-  private class TempTestSinkOpDesc extends SinkOpDesc {
+  private class TempTestSinkOpDesc extends LogicalOp {
     override def getPhysicalOp(
         workflowId: WorkflowIdentity,
         executionId: ExecutionIdentity
diff --git a/core/workflow-operator/src/main/scala/edu/uci/ics/amber/operator/sink/SinkOpDesc.scala b/core/workflow-operator/src/main/scala/edu/uci/ics/amber/operator/sink/SinkOpDesc.scala
deleted file mode 100644
index da190bcb7e4..00000000000
--- a/core/workflow-operator/src/main/scala/edu/uci/ics/amber/operator/sink/SinkOpDesc.scala
+++ /dev/null
@@ -1,5 +0,0 @@
-package edu.uci.ics.amber.operator.sink
-
-import edu.uci.ics.amber.operator.LogicalOp
-
-abstract class SinkOpDesc extends LogicalOp