Update Flink classes

snuyanzin · Jan 31, 2024 · 5a195af · 5a195af
1 parent fe25ac0
commit 5a195af
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/...nner/src/main/scala/org/apache/flink/table/planner/calcite/FlinkLogicalRelFactories.scala b/...nner/src/main/scala/org/apache/flink/table/planner/calcite/FlinkLogicalRelFactories.scala
@@ -79,11 +79,12 @@ object FlinkLogicalRelFactories {
 
   /** Implementation of [[ProjectFactory]] that returns a [[FlinkLogicalCalc]]. */
   class ProjectFactoryImpl extends ProjectFactory {
-    def createProject(
+    override def createProject(
         input: RelNode,
         hints: util.List[RelHint],
         childExprs: util.List[_ <: RexNode],
-        fieldNames: util.List[_ <: String]): RelNode = {
+        fieldNames: util.List[_ <: String],
+        variablesSet: util.Set[CorrelationId]): RelNode = {
       val rexBuilder = input.getCluster.getRexBuilder
       val inputRowType = input.getRowType
       val programBuilder = new RexProgramBuilder(inputRowType, rexBuilder)