You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by xi...@apache.org on 2023/07/12 22:11:04 UTC
[pinot] branch master updated: Adding alias for Transform function type registry (#11094)
This is an automated email from the ASF dual-hosted git repository.
xiangfu 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 4e1c8fc94f Adding alias for Transform function type registry (#11094)
4e1c8fc94f is described below
commit 4e1c8fc94f405c4a2e06ac8db22f778d0a885598
Author: Xiang Fu <xi...@gmail.com>
AuthorDate: Wed Jul 12 15:10:58 2023 -0700
Adding alias for Transform function type registry (#11094)
---
.github/workflows/scripts/.pinot_quickstart.sh | 12 ++++++++++--
.../apache/pinot/common/function/TransformFunctionType.java | 10 +++++-----
2 files changed, 15 insertions(+), 7 deletions(-)
diff --git a/.github/workflows/scripts/.pinot_quickstart.sh b/.github/workflows/scripts/.pinot_quickstart.sh
index e04450a051..d78f647c0c 100755
--- a/.github/workflows/scripts/.pinot_quickstart.sh
+++ b/.github/workflows/scripts/.pinot_quickstart.sh
@@ -159,6 +159,8 @@ do
sleep 2
done
+PASS=0
+
# Validate V2 query count(*) result
for i in $(seq 1 150)
do
@@ -173,13 +175,15 @@ do
sleep 2
done
+PASS=0
+
# Validate V2 join query results
for i in $(seq 1 150)
do
QUERY_RES=`curl -X POST --header 'Accept: application/json' -d '{"sql":"SET useMultistageEngine=true;SELECT a.playerName, a.teamID, b.teamName FROM baseballStats_OFFLINE AS a JOIN dimBaseballTeams_OFFLINE AS b ON a.teamID = b.teamID LIMIT 10","trace":false}' http://localhost:8099/query/sql`
if [ $? -eq 0 ]; then
RES_0=`echo "${QUERY_RES}" | jq '.resultTable.rows[0][0]'`
- if [[ "${RES_0}" = "David Allan" ]]; then
+ if [[ "${RES_0}" = "\"David Allan\"" ]]; then
PASS=1
break
fi
@@ -218,6 +222,8 @@ do
sleep 2
done
+PASS=0
+
# Validate V2 query count(*) result
for i in $(seq 1 150)
do
@@ -232,13 +238,15 @@ do
sleep 2
done
+PASS=0
+
# Validate V2 join query results
for i in $(seq 1 150)
do
QUERY_RES=`curl -X POST --header 'Accept: application/json' -d '{"sql":"SET useMultistageEngine=true;SELECT a.playerName, a.teamID, b.teamName FROM baseballStats_OFFLINE AS a JOIN dimBaseballTeams_OFFLINE AS b ON a.teamID = b.teamID LIMIT 10","trace":false}' http://localhost:8000/query/sql`
if [ $? -eq 0 ]; then
RES_0=`echo "${QUERY_RES}" | jq '.resultTable.rows[0][0]'`
- if [[ "${RES_0}" = "David Allan" ]]; then
+ if [[ ${RES_0} = "\"David Allan\"" ]]; then
PASS=1
break
fi
diff --git a/pinot-common/src/main/java/org/apache/pinot/common/function/TransformFunctionType.java b/pinot-common/src/main/java/org/apache/pinot/common/function/TransformFunctionType.java
index 5a262ff299..f6351474bd 100644
--- a/pinot-common/src/main/java/org/apache/pinot/common/function/TransformFunctionType.java
+++ b/pinot-common/src/main/java/org/apache/pinot/common/function/TransformFunctionType.java
@@ -93,14 +93,14 @@ public enum TransformFunctionType {
ReturnTypes.cascade(opBinding -> positionalReturnTypeInferenceFromStringLiteral(opBinding, 2,
SqlTypeName.VARCHAR), SqlTypeTransforms.FORCE_NULLABLE),
OperandTypes.family(ImmutableList.of(SqlTypeFamily.ANY, SqlTypeFamily.CHARACTER, SqlTypeFamily.CHARACTER,
- SqlTypeFamily.CHARACTER), ordinal -> ordinal > 2)),
+ SqlTypeFamily.CHARACTER), ordinal -> ordinal > 2), "json_extract_scalar"),
JSONEXTRACTKEY("jsonExtractKey", ReturnTypes.TO_ARRAY,
- OperandTypes.family(ImmutableList.of(SqlTypeFamily.ANY, SqlTypeFamily.CHARACTER))),
+ OperandTypes.family(ImmutableList.of(SqlTypeFamily.ANY, SqlTypeFamily.CHARACTER)), "json_extract_key"),
// date time functions
- TIMECONVERT("timeConvert"),
- DATETIMECONVERT("dateTimeConvert"),
- DATETRUNC("dateTrunc"),
+ TIMECONVERT("timeConvert", "time_convert"),
+ DATETIMECONVERT("dateTimeConvert", "date_time_convert"),
+ DATETRUNC("dateTrunc", "datetrunc"),
YEAR("year"),
YEAR_OF_WEEK("yearOfWeek", "yow"),
QUARTER("quarter"),
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org