[FLINK-33422] Move Calc restore tests

yhjhoo · Nov 30, 2023 · 091389e · 091389e
1 parent 88509e2
commit 091389e
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 5 deletions.
diff --git a/...nodes/exec/testutils/CalcRestoreTest.java → ...an/nodes/exec/stream/CalcRestoreTest.java b/...nodes/exec/testutils/CalcRestoreTest.java → ...an/nodes/exec/stream/CalcRestoreTest.java
@@ -16,9 +16,9 @@
  * limitations under the License.
  */
 
-package org.apache.flink.table.planner.plan.nodes.exec.testutils;
+package org.apache.flink.table.planner.plan.nodes.exec.stream;
 
-import org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecCalc;
+import org.apache.flink.table.planner.plan.nodes.exec.testutils.RestoreTestBase;
 import org.apache.flink.table.test.program.TableTestProgram;
 
 import java.util.Arrays;

diff --git a/...odes/exec/testutils/CalcTestPrograms.java → ...n/nodes/exec/stream/CalcTestPrograms.java b/...odes/exec/testutils/CalcTestPrograms.java → ...n/nodes/exec/stream/CalcTestPrograms.java
@@ -16,9 +16,8 @@
  * limitations under the License.
  */
 
-package org.apache.flink.table.planner.plan.nodes.exec.testutils;
+package org.apache.flink.table.planner.plan.nodes.exec.stream;
 
-import org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecCalc;
 import org.apache.flink.table.planner.runtime.utils.JavaUserDefinedScalarFunctions.JavaFunc0;
 import org.apache.flink.table.planner.runtime.utils.JavaUserDefinedScalarFunctions.JavaFunc1;
 import org.apache.flink.table.planner.runtime.utils.JavaUserDefinedScalarFunctions.JavaFunc2;
@@ -31,7 +30,10 @@
 
 import java.time.LocalDateTime;
 
-/** {@link TableTestProgram} definitions for testing {@link StreamExecCalc}. */
+/**
+ * {@link TableTestProgram} definitions for testing {@link
+ * org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecCalc}.
+ */
 public class CalcTestPrograms {
 
     static final TableTestProgram SIMPLE_CALC =