Skip to content

Commit 0bef3e6

Browse files
committed
[FLINK-38820] Move ptf rule to rule folder
1 parent 2260c11 commit 0bef3e6

File tree

2 files changed

+4
-2
lines changed

2 files changed

+4
-2
lines changed

flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamPhysicalProcessTableFunctionRule.java renamed to flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/physical/stream/StreamPhysicalProcessTableFunctionRule.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,14 +16,16 @@
1616
* limitations under the License.
1717
*/
1818

19-
package org.apache.flink.table.planner.plan.nodes.physical.stream;
19+
package org.apache.flink.table.planner.plan.rules.physical.stream;
2020

2121
import org.apache.flink.table.functions.FunctionDefinition;
2222
import org.apache.flink.table.functions.FunctionKind;
2323
import org.apache.flink.table.planner.calcite.RexTableArgCall;
2424
import org.apache.flink.table.planner.functions.bridging.BridgingSqlFunction;
2525
import org.apache.flink.table.planner.plan.nodes.FlinkConventions;
2626
import org.apache.flink.table.planner.plan.nodes.logical.FlinkLogicalTableFunctionScan;
27+
import org.apache.flink.table.planner.plan.nodes.physical.stream.StreamPhysicalMLPredictTableFunctionRule;
28+
import org.apache.flink.table.planner.plan.nodes.physical.stream.StreamPhysicalProcessTableFunction;
2729
import org.apache.flink.table.planner.plan.trait.FlinkRelDistribution;
2830
import org.apache.flink.table.planner.utils.ShortcutUtils;
2931

flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/rules/FlinkStreamRuleSets.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@
1818
package org.apache.flink.table.planner.plan.rules
1919

2020
import org.apache.flink.table.planner.plan.nodes.logical._
21-
import org.apache.flink.table.planner.plan.nodes.physical.stream.{StreamPhysicalMLPredictTableFunctionRule, StreamPhysicalProcessTableFunctionRule}
21+
import org.apache.flink.table.planner.plan.nodes.physical.stream.StreamPhysicalMLPredictTableFunctionRule
2222
import org.apache.flink.table.planner.plan.rules.logical.{JoinToMultiJoinRule, _}
2323
import org.apache.flink.table.planner.plan.rules.physical.FlinkExpandConversionRule
2424
import org.apache.flink.table.planner.plan.rules.physical.common.PhysicalVectorSearchTableFunctionRule

0 commit comments

Comments
 (0)