fix fmt

Texera · Jan 14, 2025 · 925553e · 925553e
1 parent b2dc392
commit 925553e
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/core/workflow-operator/src/main/scala/edu/uci/ics/amber/operator/LogicalOp.scala b/core/workflow-operator/src/main/scala/edu/uci/ics/amber/operator/LogicalOp.scala
@@ -63,6 +63,7 @@ import edu.uci.ics.amber.operator.source.sql.asterixdb.AsterixDBSourceOpDesc
 import edu.uci.ics.amber.operator.source.sql.mysql.MySQLSourceOpDesc
 import edu.uci.ics.amber.operator.source.sql.postgresql.PostgreSQLSourceOpDesc
 import edu.uci.ics.amber.operator.split.SplitOpDesc
+import edu.uci.ics.amber.operator.state.DataToStateOpDesc
 import edu.uci.ics.amber.operator.symmetricDifference.SymmetricDifferenceOpDesc
 import edu.uci.ics.amber.operator.typecasting.TypeCastingOpDesc
 import edu.uci.ics.amber.operator.udf.java.JavaUDFOpDesc

diff --git a/...workflow-operator/src/main/scala/edu/uci/ics/amber/operator/state/DataToStateOpExec.scala b/...workflow-operator/src/main/scala/edu/uci/ics/amber/operator/state/DataToStateOpExec.scala
@@ -6,7 +6,8 @@ import edu.uci.ics.amber.core.tuple.{Tuple, TupleLike}
 import edu.uci.ics.amber.util.JSONUtils.objectMapper
 
 class DataToStateOpExec(descString: String) extends OperatorExecutor {
-  private val desc: DataToStateOpDesc = objectMapper.readValue(descString, classOf[DataToStateOpDesc])
+  private val desc: DataToStateOpDesc =
+    objectMapper.readValue(descString, classOf[DataToStateOpDesc])
   private var stateTuple: Option[Tuple] = None
 
   override def processTuple(tuple: Tuple, port: Int): Iterator[TupleLike] = {