Skip to content

Commit d7c1a9a

Browse files
committed
remove useless change
Signed-off-by: xinyual <xinyual@amazon.com>
1 parent 0e43eb9 commit d7c1a9a

3 files changed

Lines changed: 0 additions & 37 deletions

File tree

core/src/main/java/org/opensearch/sql/ast/AbstractNodeVisitor.java

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,6 @@
2222
import org.opensearch.sql.ast.expression.HighlightFunction;
2323
import org.opensearch.sql.ast.expression.In;
2424
import org.opensearch.sql.ast.expression.Interval;
25-
import org.opensearch.sql.ast.expression.LambdaFunction;
2625
import org.opensearch.sql.ast.expression.Let;
2726
import org.opensearch.sql.ast.expression.Literal;
2827
import org.opensearch.sql.ast.expression.Map;
@@ -229,10 +228,6 @@ public T visitLet(Let node, C context) {
229228
return visitChildren(node, context);
230229
}
231230

232-
public T visitLambdaFunction(LambdaFunction node, C context) {
233-
return visitChildren(node, context);
234-
}
235-
236231
public T visitSort(Sort node, C context) {
237232
return visitChildren(node, context);
238233
}

core/src/main/java/org/opensearch/sql/calcite/CalcitePlanContext.java

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -8,16 +8,13 @@
88
import static org.opensearch.sql.calcite.utils.OpenSearchTypeFactory.TYPE_FACTORY;
99

1010
import java.sql.Connection;
11-
import java.util.HashMap;
1211
import java.util.List;
13-
import java.util.Map;
1412
import java.util.Optional;
1513
import java.util.Stack;
1614
import java.util.function.BiFunction;
1715
import lombok.Getter;
1816
import lombok.Setter;
1917
import org.apache.calcite.rex.RexCorrelVariable;
20-
import org.apache.calcite.rex.RexLambdaRef;
2118
import org.apache.calcite.rex.RexNode;
2219
import org.apache.calcite.tools.FrameworkConfig;
2320
import org.apache.calcite.tools.RelBuilder;
@@ -34,7 +31,6 @@ public class CalcitePlanContext {
3431
public final ExtendedRexBuilder rexBuilder;
3532
public final FunctionProperties functionProperties;
3633
public final QueryType queryType;
37-
@Getter public Map<String, RexLambdaRef> temparolInputmap;
3834

3935
@Getter @Setter private boolean isResolvingJoinCondition = false;
4036
@Getter @Setter private boolean isResolvingSubquery = false;
@@ -57,11 +53,6 @@ private CalcitePlanContext(FrameworkConfig config, QueryType queryType) {
5753
this.relBuilder = CalciteToolsHelper.create(config, TYPE_FACTORY, connection);
5854
this.rexBuilder = new ExtendedRexBuilder(relBuilder.getRexBuilder());
5955
this.functionProperties = new FunctionProperties(QueryType.PPL);
60-
this.temparolInputmap = new HashMap<>();
61-
}
62-
63-
public void putTemparolInputmap(String name, RexLambdaRef input) {
64-
this.temparolInputmap.put(name, input);
6556
}
6657

6758
public RexNode resolveJoinCondition(

core/src/main/java/org/opensearch/sql/calcite/CalciteRexNodeVisitor.java

Lines changed: 0 additions & 23 deletions
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,6 @@
4141
import org.opensearch.sql.ast.expression.Function;
4242
import org.opensearch.sql.ast.expression.In;
4343
import org.opensearch.sql.ast.expression.Interval;
44-
import org.opensearch.sql.ast.expression.LambdaFunction;
4544
import org.opensearch.sql.ast.expression.Let;
4645
import org.opensearch.sql.ast.expression.Literal;
4746
import org.opensearch.sql.ast.expression.Not;
@@ -340,28 +339,6 @@ public RexNode visitLet(Let node, CalcitePlanContext context) {
340339
return context.relBuilder.alias(expr, node.getVar().getField().toString());
341340
}
342341

343-
@Override
344-
public RexNode visitLambdaFunction(LambdaFunction node, CalcitePlanContext context) {
345-
List<QualifiedName> names = node.getFuncArgs();
346-
List<RexLambdaRef> args = new ArrayList<>();
347-
for (int i = 0; i < names.size(); i++) {
348-
context.putTemparolInputmap(
349-
names.get(i).toString(),
350-
new RexLambdaRef(
351-
i,
352-
names.get(i).toString(),
353-
context.rexBuilder.getTypeFactory().createSqlType(SqlTypeName.ANY)));
354-
args.add(
355-
new RexLambdaRef(
356-
i,
357-
names.get(i).toString(),
358-
context.rexBuilder.getTypeFactory().createSqlType(SqlTypeName.ANY)));
359-
}
360-
RexNode body = node.getFunction().accept(this, context);
361-
RexNode lambdaNode = context.rexBuilder.makeLambdaCall(body, args);
362-
return lambdaNode;
363-
}
364-
365342
@Override
366343
public RexNode visitFunction(Function node, CalcitePlanContext context) {
367344
List<RexNode> arguments =

0 commit comments

Comments
 (0)