You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@calcite.apache.org by "Pablo Estrada (Jira)" <ji...@apache.org> on 2019/11/04 04:16:00 UTC
[jira] [Commented] (CALCITE-3472) SESSION_END returns same value as
SESSION_START
[ https://issues.apache.org/jira/browse/CALCITE-3472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16966395#comment-16966395 ]
Pablo Estrada commented on CALCITE-3472:
----------------------------------------
[~apilloud] could you take a look? : )
> 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
>
> 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)