[
https://issues.apache.org/jira/browse/BEAM-10438?focusedWorklogId=505256&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-505256
]
ASF GitHub Bot logged work on BEAM-10438:
-----------------------------------------
Author: ASF GitHub Bot
Created on: 27/Oct/20 14:46
Start Date: 27/Oct/20 14:46
Worklog Time Spent: 10m
Work Description: robinyqiu commented on a change in pull request #12643:
URL: https://github.com/apache/beam/pull/12643#discussion_r512460592
##########
File path:
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/bigquery/BeamBigQuerySqlDialect.java
##########
@@ -87,16 +87,17 @@
.put("$extract_time", "TIME")
.put("$extract_datetime", "DATETIME")
.build();
- public static final String DOUBLE_POSITIVE_INF_FUNCTION =
"double_positive_inf";
- public static final String DOUBLE_NEGATIVE_INF_FUNCTION =
"double_negative_inf";
- public static final String DOUBLE_NAN_FUNCTION = "double_nan";
- private static final Map<String, String> DOUBLE_FUNCTIONS =
+ public static final String DOUBLE_POSITIVE_INF_WRAPPER =
"double_positive_inf";
Review comment:
I agree. I will let this change get in and avoid similar changes in the
future. Sorry for the inconvenience.
##########
File path:
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/SupportedZetaSqlBuiltinFunctions.java
##########
@@ -475,17 +512,22 @@
// FunctionSignatureId.FN_RANGE_BUCKET, // range_bucket(T,
array<T>) -> int64
- // FunctionSignatureId.FN_RAND, // rand() -> double
+ FunctionSignatureId.FN_RAND // rand() -> double
Review comment:
Thanks for catching this! I will disable this for now, and enable it
later once we have a thorough test.
##########
File path:
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/SupportedZetaSqlBuiltinFunctions.java
##########
@@ -277,29 +293,31 @@
FunctionSignatureId.FN_PARSE_DATETIME, // parse_datetime
FunctionSignatureId.FN_PARSE_TIME, // parse_time
FunctionSignatureId.FN_PARSE_TIMESTAMP, // parse_timestamp
+ // FunctionSignatureId.FN_LAST_DAY_DATE, // last_day date
+ // FunctionSignatureId.FN_LAST_DAY_DATETIME, // last_day datetime
// Math functions
- // FunctionSignatureId.FN_ABS_INT64, // abs
- // FunctionSignatureId.FN_ABS_DOUBLE, // abs
- // FunctionSignatureId.FN_ABS_NUMERIC, // abs
+ FunctionSignatureId.FN_ABS_INT64, // abs
Review comment:
Make sense. I will remember to separate different categories of changes
in the future. Thanks for the suggestion!
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
Issue Time Tracking
-------------------
Worklog Id: (was: 505256)
Time Spent: 2h 10m (was: 2h)
> Turn on functions supported by BeamZetaSqlCalcRel
> -------------------------------------------------
>
> Key: BEAM-10438
> URL: https://issues.apache.org/jira/browse/BEAM-10438
> Project: Beam
> Issue Type: New Feature
> Components: dsl-sql-zetasql
> Reporter: Robin Qiu
> Priority: P2
> Time Spent: 2h 10m
> Remaining Estimate: 0h
>
> BeamZetaSqlCalcRel enables many new functions. To support them in Beam
> ZetaSQL they just need to be turned on in the allowlist in
> SqlStdOperatorMappingTable.java.
>
> Functions should be supported if:
> 1) the related types is supported in Beam ZetaSQL, and
> 2) the reference implementation has been open sourced to ZetaSQL
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
