Uploaded image for project: 'Spark'
  1. Spark
  2. SPARK-10816 EventTime based sessionization (session window)
  3. SPARK-34888

Introduce UpdatingSessionIterator adjusting session information on elements

    XMLWordPrintableJSON

Details

    Description

      This issue tracks effort on introducing UpdatingSessionIterator, which analyzes neighbor elements and adjust session information on elements.

      This issue also introduces UpdatingSessionExec which is the physical node on leveraging UpdatingSessionIterator to sort the input rows and updates session information on input rows.

      Attachments

        Activity

          People

            kabhwan Jungtaek Lim
            kabhwan Jungtaek Lim
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: