This is an automated email from the ASF dual-hosted git repository.
jackie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
The following commit(s) were added to refs/heads/master by this push:
new e47169cd81 Fix function call return type for IN / NOT IN created from
SEARCH in the multistage engine (#14128)
e47169cd81 is described below
commit e47169cd81c5781c3567ad71739e52257d9b8096
Author: Yash Mayya <[email protected]>
AuthorDate: Sat Oct 5 11:51:49 2024 +0530
Fix function call return type for IN / NOT IN created from SEARCH in the
multistage engine (#14128)
---
.../pinot/query/planner/logical/RexExpressionUtils.java | 12 ++++++------
1 file changed, 6 insertions(+), 6 deletions(-)
diff --git
a/pinot-query-planner/src/main/java/org/apache/pinot/query/planner/logical/RexExpressionUtils.java
b/pinot-query-planner/src/main/java/org/apache/pinot/query/planner/logical/RexExpressionUtils.java
index b82b5106e1..b23e12f224 100644
---
a/pinot-query-planner/src/main/java/org/apache/pinot/query/planner/logical/RexExpressionUtils.java
+++
b/pinot-query-planner/src/main/java/org/apache/pinot/query/planner/logical/RexExpressionUtils.java
@@ -87,8 +87,8 @@ public class RexExpressionUtils {
String functionName = rexExpression.getFunctionName();
SqlIdentifier sqlIdentifier = new SqlIdentifier(functionName,
SqlParserPos.ZERO);
ArrayList<SqlOperator> operators = new ArrayList<>();
-
builder.getCluster().getRexBuilder().getOpTab().lookupOperatorOverloads(sqlIdentifier,
null, SqlSyntax.FUNCTION,
- operators, SqlNameMatchers.liberal());
+ builder.getCluster().getRexBuilder().getOpTab()
+ .lookupOperatorOverloads(sqlIdentifier, null, SqlSyntax.FUNCTION,
operators, SqlNameMatchers.liberal());
if (operators.isEmpty()) {
throw new IllegalArgumentException("No operator found for function: " +
functionName);
@@ -177,8 +177,8 @@ public class RexExpressionUtils {
String functionName = functionCall.getFunctionName();
SqlIdentifier sqlIdentifier = new SqlIdentifier(functionName,
SqlParserPos.ZERO);
ArrayList<SqlOperator> operators = new ArrayList<>();
- cluster.getRexBuilder().getOpTab().lookupOperatorOverloads(sqlIdentifier,
null, SqlSyntax.FUNCTION,
- operators, SqlNameMatchers.liberal());
+ cluster.getRexBuilder().getOpTab()
+ .lookupOperatorOverloads(sqlIdentifier, null, SqlSyntax.FUNCTION,
operators, SqlNameMatchers.liberal());
ArrayList<SqlAggFunction> aggFunctions = new ArrayList<>(operators.size());
for (SqlOperator operator : operators) {
@@ -322,10 +322,10 @@ public class RexExpressionUtils {
Sarg sarg = rexLiteral.getValueAs(Sarg.class);
assert sarg != null;
if (sarg.isPoints()) {
- return new RexExpression.FunctionCall(dataType, SqlKind.IN.name(),
+ return new RexExpression.FunctionCall(ColumnDataType.BOOLEAN,
SqlKind.IN.name(),
toFunctionOperands(rexInputRef, sarg.rangeSet.asRanges(), dataType));
} else if (sarg.isComplementedPoints()) {
- return new RexExpression.FunctionCall(dataType, SqlKind.NOT_IN.name(),
+ return new RexExpression.FunctionCall(ColumnDataType.BOOLEAN,
SqlKind.NOT_IN.name(),
toFunctionOperands(rexInputRef,
sarg.rangeSet.complement().asRanges(), dataType));
} else {
Set<Range> ranges = sarg.rangeSet.asRanges();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
