Uploaded image for project: 'Spark'
  1. Spark
  2. SPARK-22565

Session-based windowing

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Resolved
    • Major
    • Resolution: Incomplete
    • 2.2.0
    • None
    • Structured Streaming

    Description

      I came across a requirement to support session-based windowing. for example, user activity comes in from kafka, we want to create window per user session (if the time gap of activity from the same user exceeds the predefined value, a new window will be created).

      I noticed that Flink does support this kind of support, any plan/schedule for spark for this?

      Attachments

        1. screenshot-1.png
          404 kB
          Yuanjian Li

        Issue Links

          duplicates

          New Feature - A new feature of the product, which has yet to be developed. SPARK-10816 EventTime based sessionization (session window)

          • Major - Major loss of function.
          • Resolved

          Activity

            People

              Unassigned Unassigned
              richardxin168 Richard Xin
              Votes:
              0 Vote for this issue
              Watchers:
              5 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: