[
https://issues.apache.org/jira/browse/CALCITE-3472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Julian Hyde resolved CALCITE-3472.
----------------------------------
Fix Version/s: 1.22.0
Resolution: Duplicate
I agree; it is a duplicate. Closing.
> SESSION_END returns same value as SESSION_START
> -----------------------------------------------
>
> Key: CALCITE-3472
> URL: https://issues.apache.org/jira/browse/CALCITE-3472
> Project: Calcite
> Issue Type: Improvement
> Components: stream
> Reporter: Pablo Estrada
> Priority: Major
> Fix For: 1.22.0
>
>
> We've found that the session_end function seems to be returning the same
> values as session_start. Furthermore, it seems that they may have the same
> implementation, though I'm not fully familiar with the code:
>
> [https://github.com/apache/calcite/blob/d7946a94adfd2e788f5d324910944dd65dab11ee/core/src/main/java/org/apache/calcite/sql2rel/AuxiliaryConverter.java#L50-L68]
>
> An example with Beam SQL:
>
> 0: BeamSQL> SELECT
> SESSION_START(scores_stream.event_time, INTERVAL '1' SECOND),
> SESSION_END(scores_stream.event_time, INTERVAL '1' SECOND),
> scores_stream.team,
> SUM(scores_stream.score),
> COUNT(*)
> FROM
> scores_stream
> GROUP BY scores_stream.team,
> SESSION(scores_stream.event_time, INTERVAL '1' SECOND) LIMIT 3;SELECT
> . . . . . > SESSION_START(scores_stream.event_time, INTERVAL '1' SECOND),
> . . . . . > SESSION_END(scores_stream.event_time, INTERVAL '1' SECOND),
> . . . . . > scores_stream.team,
> . . . . . > SUM(scores_stream.score),
> . . . . . > COUNT(*)
> . . . . . > FROM
> . . . . . > scores_stream
> . . . . . > GROUP BY scores_stream.team,
> . . . . . >
> T 3; SESSION(scores_stream.event_time, INTERVAL '1' SECOND) LIMI
> +--------+--------+------+------------+---------------------+
> | EXPR$0 | EXPR$1 | team | EXPR$3 | EXPR$4 |
> +--------+--------+------+------------+---------------------+
> | 2019-11-04 04:11:38 | 2019-11-04 04:11:38 | blue | 420 | 7 |
> | 2019-11-04 04:11:38 | 2019-11-04 04:11:38 | red | 960 | 18 |
> | 2019-11-04 04:11:42 | 2019-11-04 04:11:42 | blue | 452 | 11 |
> +--------+--------+------+------------+---------------------+
> 3 rows selected (9.197 seconds)
> 0: BeamSQL>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
