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

Initial State without state reader implementation for State API v2.

    XMLWordPrintableJSON

Details

    Description

      This PR adds support for users to provide a Dataframe that can be used to instantiate state for the query in the first batch for arbitrary state API v2.

      Note that populating the initial state will only happen for the first batch of the new streaming query. Trying to re-initialize state for the same grouping key will result in an error.

      Attachments

        Issue Links

          Activity

            People

              jing.zhan Jing Zhan
              jing.zhan Jing Zhan
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: