Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

check for latest rewrite place

This commit is contained in:
Zoltan Haindrich 2023-10-04 10:01:41 +00:00
parent bd55afd407
commit 5cf1e2c1ca
2 changed files with 17 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
sql/src/main/java/org/apache/druid/sql/calcite/aggregation/builtin/EarliestLatestAnySqlAggregator.java
View File

@ -340,5 +340,14 @@ public class EarliestLatestAnySqlAggregator implements SqlAggregator
Optionality.FORBIDDEN
);
}
public org.apache.calcite.sql.SqlNode rewriteCall(org.apache.calcite.sql.validate.SqlValidator validator, org.apache.calcite.sql.SqlCall call)
{
// I think the best chance would be to to try to rewrite it here
// biggest question is kinda like which is the time column
// look inside SqlCoalesceFunction for a sample how a rewrite is done around here
return call;
}
}
}

8
sql/src/main/java/org/apache/druid/sql/calcite/aggregation/builtin/EarliestLatestBySqlAggregator.java
View File

@ -25,12 +25,15 @@ import org.apache.calcite.rex.RexBuilder;
import org.apache.calcite.rex.RexLiteral;
import org.apache.calcite.rex.RexNode;
import org.apache.calcite.sql.SqlAggFunction;
import org.apache.calcite.sql.SqlCall;
import org.apache.calcite.sql.SqlFunctionCategory;
import org.apache.calcite.sql.SqlKind;
import org.apache.calcite.sql.SqlNode;
import org.apache.calcite.sql.type.InferTypes;
import org.apache.calcite.sql.type.OperandTypes;
import org.apache.calcite.sql.type.SqlReturnTypeInference;
import org.apache.calcite.sql.type.SqlTypeFamily;
import org.apache.calcite.sql.validate.SqlValidator;
import org.apache.calcite.util.Optionality;
import org.apache.druid.java.util.common.IAE;
import org.apache.druid.java.util.common.ISE;
@ -204,5 +207,10 @@ public class EarliestLatestBySqlAggregator implements SqlAggregator
Optionality.FORBIDDEN
);
}
@Override
public SqlNode rewriteCall(SqlValidator validator, SqlCall call)
{
return super.rewriteCall(validator, call);
}
}
}