Details

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

      Description

      Hopping windows place intervals of a fixed size evenly spaced across event time. Most importantly, in the most common use a given event time timestamp will generally fall into more than one window.
      The table-valued function Hop may produce zero, one, or multiple rows corresponding to each row of input. Hop takes four required parameters and one optional parameter. All parameters are analogous to those for Tumble except for hopsize, which specifies the duration between the starting points (and endpoints) of the hopping windows, allowing for overlapping windows (hopsize < dur, common) or gaps in the data (hopsize > dur, rarely useful).

      Hop (data , timecol , dur, hopsize)
      

      The return value of Hop is a relation that includes all columns of data as well as additional event time columns wstart and wend. Here is an example (from https://s.apache.org/streaming-beam-sql ):

      SELECT *
            FROM Hop (
              data    => TABLE Bids ,
              timecol => DESCRIPTOR ( bidtime ) ,
              dur     => INTERVAL '10' MINUTES ,
              hopsize => INTERVAL '5' MINUTES );
      
      ------------------------------------------
      | wstart | wend | bidtime | price | item |
      ------------------------------------------
      | 8:00   | 8:10 | 8:07    | $2    | A    |
      | 8:05   | 8:15 | 8:07    | $2    | A    |
      | 8:05   | 8:15 | 8:11    | $3    | B    |
      | 8:10   | 8:20 | 8:11    | $3    | B    |
      | 8:00   | 8:10 | 8:05    | $4    | C    |
      | 8:05   | 8:15 | 8:05    | $4    | C    |
      | 8:00   | 8:10 | 8:09    | $5    | D    |
      | 8:05   | 8:15 | 8:09    | $5    | D    |
      | 8:05   | 8:15 | 8:13    | $1    | E    |
      | 8:10   | 8:20 | 8:13    | $1    | E    |
      | 8:10   | 8:20 | 8:17    | $6    | F    |
      | 8:15   | 8:25 | 8:17    | $6    | F    |
      ------------------------------------------
      
      

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                amaliujia Rui Wang
                Reporter:
                amaliujia Rui Wang
              • Votes:
                0 Vote for this issue
                Watchers:
                6 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 - 20h 10m
                  20h 10m