Details

    • Type: Sub-task
    • Status: Closed
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 1.22.0
    • Component/s: None

      Description

      Define a builtin TVF: Tumble (data , timecol , dur, [ offset ])

      The return value of Tumble is a relation that includes all columns of data as well as additional event time columns window_start and window_end.

      Examples of TUMBLE TVF are (from https://s.apache.org/streaming-beam-sql ):

      8:21> SELECT * FROM Bid;

      --------------------------

      bidtime price item

      --------------------------

      8:07 $2 A
      8:11 $3 B
      8:05 $4 C
      8:09 $5 D
      8:13 $1 E
      8:17 $6 F

      --------------------------

      8:21> SELECT *
      FROM TABLE Tumble (
      data => TABLE Bid ,
      timecol => DESCRIPTOR ( bidtime ) ,
      dur => INTERVAL '10' MINUTES ,
      offset => INTERVAL '0' MINUTES );

      ------------------------------------------

      window_start window_end bidtime price item

      ------------------------------------------

      8:00 8:10 8:07 $2 A
      8:10 8:20 8:11 $3 B
      8:00 8:10 8:05 $4 C
      8:00 8:10 8:09 $5 D
      8:10 8:20 8:13 $1 E
      8:10 8:20 8:17 $6 F

      ------------------------------------------

      8:21> SELECT MAX ( window_start ) , window_end , SUM ( price )
      FROM TABLE Tumble (
      data => TABLE ( Bid ) ,
      timecol => DESCRIPTOR ( bidtime ) ,
      dur => INTERVAL '10 ' MINUTES )
      GROUP BY wend;

      -------------------------

      window_start window_end price

      -------------------------

      8:00 8:10 $11
      8:10 8:20 $10

      -------------------------

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                amaliujia Rui Wang
                Reporter:
                amaliujia Rui Wang
              • Votes:
                0 Vote for this issue
                Watchers:
                7 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved:

                  Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 19h 20m
                  19h 20m