This is an automated email from the ASF dual-hosted git repository.
linxinyuan pushed a commit to branch xinyuan-cm-for-loop
in repository https://gitbox.apache.org/repos/asf/texera.git
The following commit(s) were added to refs/heads/xinyuan-cm-for-loop by this
push:
new 9048c40cea fix fmt
9048c40cea is described below
commit 9048c40cea48f207d0ad748256e3a2035e68b044
Author: Xinyuan Lin <[email protected]>
AuthorDate: Wed Jan 21 18:55:26 2026 -0800
fix fmt
---
.../worker/promisehandlers/EndIterationHandler.scala | 10 +++++-----
.../worker/promisehandlers/NextIterationHandler.scala | 10 +++++-----
.../org/apache/amber/operator/loop/LoopEndOpExec.scala | 8 --------
.../{ => texera}/amber/operator/loop/LoopEndOpDesc.scala | 12 ++++++------
.../apache/texera/amber/operator/loop/LoopEndOpExec.scala | 8 ++++++++
.../{ => texera}/amber/operator/loop/LoopStartOpDesc.scala | 14 +++++++-------
.../{ => texera}/amber/operator/loop/LoopStartOpExec.scala | 8 ++++----
7 files changed, 35 insertions(+), 35 deletions(-)
diff --git
a/amber/src/main/scala/org/apache/texera/amber/engine/architecture/worker/promisehandlers/EndIterationHandler.scala
b/amber/src/main/scala/org/apache/texera/amber/engine/architecture/worker/promisehandlers/EndIterationHandler.scala
index def9be74ba..592b3fb5e1 100644
---
a/amber/src/main/scala/org/apache/texera/amber/engine/architecture/worker/promisehandlers/EndIterationHandler.scala
+++
b/amber/src/main/scala/org/apache/texera/amber/engine/architecture/worker/promisehandlers/EndIterationHandler.scala
@@ -17,17 +17,17 @@
* under the License.
*/
-package org.apache.amber.engine.architecture.worker.promisehandlers
+package org.apache.texera.amber.engine.architecture.worker.promisehandlers
-import org.apache.amber.engine.architecture.rpc.controlcommands.{
+import org.apache.texera.amber.engine.architecture.rpc.controlcommands.{
AsyncRPCContext,
EmptyRequest,
EndIterationRequest
}
-import
org.apache.amber.engine.architecture.worker.DataProcessorRPCHandlerInitializer
+import
org.apache.texera.amber.engine.architecture.worker.DataProcessorRPCHandlerInitializer
import com.twitter.util.Future
-import org.apache.amber.engine.architecture.rpc.controlreturns.EmptyReturn
-import org.apache.amber.operator.loop.LoopEndOpExec
+import
org.apache.texera.amber.engine.architecture.rpc.controlreturns.EmptyReturn
+import org.apache.texera.amber.operator.loop.LoopEndOpExec
trait EndIterationHandler {
this: DataProcessorRPCHandlerInitializer =>
diff --git
a/amber/src/main/scala/org/apache/texera/amber/engine/architecture/worker/promisehandlers/NextIterationHandler.scala
b/amber/src/main/scala/org/apache/texera/amber/engine/architecture/worker/promisehandlers/NextIterationHandler.scala
index d4f6bdffba..366d9a2ab7 100644
---
a/amber/src/main/scala/org/apache/texera/amber/engine/architecture/worker/promisehandlers/NextIterationHandler.scala
+++
b/amber/src/main/scala/org/apache/texera/amber/engine/architecture/worker/promisehandlers/NextIterationHandler.scala
@@ -17,13 +17,13 @@
* under the License.
*/
-package org.apache.amber.engine.architecture.worker.promisehandlers
+package org.apache.texera.amber.engine.architecture.worker.promisehandlers
import com.twitter.util.Future
-import
org.apache.amber.engine.architecture.rpc.controlcommands.{AsyncRPCContext,
EmptyRequest}
-import org.apache.amber.engine.architecture.rpc.controlreturns.EmptyReturn
-import
org.apache.amber.engine.architecture.worker.DataProcessorRPCHandlerInitializer
-import org.apache.amber.operator.loop.LoopStartOpExec
+import
org.apache.texera.amber.engine.architecture.rpc.controlcommands.{AsyncRPCContext,
EmptyRequest}
+import
org.apache.texera.amber.engine.architecture.rpc.controlreturns.EmptyReturn
+import
org.apache.texera.amber.engine.architecture.worker.DataProcessorRPCHandlerInitializer
+import org.apache.texera.amber.operator.loop.LoopStartOpExec
trait NextIterationHandler {
this: DataProcessorRPCHandlerInitializer =>
diff --git
a/common/workflow-operator/src/main/scala/org/apache/amber/operator/loop/LoopEndOpExec.scala
b/common/workflow-operator/src/main/scala/org/apache/amber/operator/loop/LoopEndOpExec.scala
deleted file mode 100644
index 90a4d7dc75..0000000000
---
a/common/workflow-operator/src/main/scala/org/apache/amber/operator/loop/LoopEndOpExec.scala
+++ /dev/null
@@ -1,8 +0,0 @@
-package org.apache.amber.operator.loop
-
-import org.apache.amber.core.executor.OperatorExecutor
-import org.apache.amber.core.tuple.{Tuple, TupleLike}
-
-class LoopEndOpExec extends OperatorExecutor {
- override def processTuple(tuple: Tuple, port: Int): Iterator[TupleLike] =
Iterator(tuple)
-}
diff --git
a/common/workflow-operator/src/main/scala/org/apache/amber/operator/loop/LoopEndOpDesc.scala
b/common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/loop/LoopEndOpDesc.scala
similarity index 78%
rename from
common/workflow-operator/src/main/scala/org/apache/amber/operator/loop/LoopEndOpDesc.scala
rename to
common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/loop/LoopEndOpDesc.scala
index 50decd9068..0657c6ce42 100644
---
a/common/workflow-operator/src/main/scala/org/apache/amber/operator/loop/LoopEndOpDesc.scala
+++
b/common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/loop/LoopEndOpDesc.scala
@@ -17,13 +17,13 @@
* under the License.
*/
-package org.apache.amber.operator.loop
+package org.apache.texera.amber.operator.loop
-import org.apache.amber.core.executor.OpExecWithClassName
-import org.apache.amber.core.virtualidentity.{ExecutionIdentity,
WorkflowIdentity}
-import org.apache.amber.core.workflow.{InputPort, OutputPort, PhysicalOp}
-import org.apache.amber.operator.LogicalOp
-import org.apache.amber.operator.metadata.{OperatorGroupConstants,
OperatorInfo}
+import org.apache.texera.amber.core.executor.OpExecWithClassName
+import org.apache.texera.amber.core.virtualidentity.{ExecutionIdentity,
WorkflowIdentity}
+import org.apache.texera.amber.core.workflow.{InputPort, OutputPort,
PhysicalOp}
+import org.apache.texera.amber.operator.LogicalOp
+import org.apache.texera.amber.operator.metadata.{OperatorGroupConstants,
OperatorInfo}
class LoopEndOpDesc extends LogicalOp {
override def getPhysicalOp(
diff --git
a/common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/loop/LoopEndOpExec.scala
b/common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/loop/LoopEndOpExec.scala
new file mode 100644
index 0000000000..60f18cd5fc
--- /dev/null
+++
b/common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/loop/LoopEndOpExec.scala
@@ -0,0 +1,8 @@
+package org.apache.texera.amber.operator.loop
+
+import org.apache.texera.amber.core.executor.OperatorExecutor
+import org.apache.texera.amber.core.tuple.{Tuple, TupleLike}
+
+class LoopEndOpExec extends OperatorExecutor {
+ override def processTuple(tuple: Tuple, port: Int): Iterator[TupleLike] =
Iterator(tuple)
+}
diff --git
a/common/workflow-operator/src/main/scala/org/apache/amber/operator/loop/LoopStartOpDesc.scala
b/common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/loop/LoopStartOpDesc.scala
similarity index 79%
rename from
common/workflow-operator/src/main/scala/org/apache/amber/operator/loop/LoopStartOpDesc.scala
rename to
common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/loop/LoopStartOpDesc.scala
index f01ce52646..fa52f68278 100644
---
a/common/workflow-operator/src/main/scala/org/apache/amber/operator/loop/LoopStartOpDesc.scala
+++
b/common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/loop/LoopStartOpDesc.scala
@@ -17,16 +17,16 @@
* under the License.
*/
-package org.apache.amber.operator.loop
+package org.apache.texera.amber.operator.loop
import com.fasterxml.jackson.annotation.JsonProperty
import com.kjetland.jackson.jsonSchema.annotations.JsonSchemaTitle
-import org.apache.amber.core.executor.OpExecWithClassName
-import org.apache.amber.core.virtualidentity.{ExecutionIdentity,
WorkflowIdentity}
-import org.apache.amber.core.workflow.{InputPort, OutputPort, PhysicalOp}
-import org.apache.amber.operator.LogicalOp
-import org.apache.amber.operator.metadata.{OperatorGroupConstants,
OperatorInfo}
-import org.apache.amber.util.JSONUtils.objectMapper
+import org.apache.texera.amber.core.executor.OpExecWithClassName
+import org.apache.texera.amber.core.virtualidentity.{ExecutionIdentity,
WorkflowIdentity}
+import org.apache.texera.amber.core.workflow.{InputPort, OutputPort,
PhysicalOp}
+import org.apache.texera.amber.operator.LogicalOp
+import org.apache.texera.amber.operator.metadata.{OperatorGroupConstants,
OperatorInfo}
+import org.apache.texera.amber.util.JSONUtils.objectMapper
class LoopStartOpDesc extends LogicalOp {
diff --git
a/common/workflow-operator/src/main/scala/org/apache/amber/operator/loop/LoopStartOpExec.scala
b/common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/loop/LoopStartOpExec.scala
similarity index 86%
rename from
common/workflow-operator/src/main/scala/org/apache/amber/operator/loop/LoopStartOpExec.scala
rename to
common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/loop/LoopStartOpExec.scala
index 24ce3c0c0d..68c5bcc0e3 100644
---
a/common/workflow-operator/src/main/scala/org/apache/amber/operator/loop/LoopStartOpExec.scala
+++
b/common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/loop/LoopStartOpExec.scala
@@ -17,11 +17,11 @@
* under the License.
*/
-package org.apache.amber.operator.loop
+package org.apache.texera.amber.operator.loop
-import org.apache.amber.core.executor.OperatorExecutor
-import org.apache.amber.core.tuple.{Tuple, TupleLike}
-import org.apache.amber.util.JSONUtils.objectMapper
+import org.apache.texera.amber.core.executor.OperatorExecutor
+import org.apache.texera.amber.core.tuple.{Tuple, TupleLike}
+import org.apache.texera.amber.util.JSONUtils.objectMapper
import scala.collection.mutable
