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

Update mode in structured streaming

    XMLWordPrintableJSON

Details

    • New Feature
    • Status: Resolved
    • Critical
    • Resolution: Fixed
    • None
    • 2.1.1, 2.2.0
    • Structured Streaming
    • None

    Description

      We have this internal, but we should nail down the semantics and expose it to users. The idea of update mode is that any tuple that changes will be emitted. Open questions:

      • do we need to reason about the keys for a given stream? For things like the foreach sink its up to the user. However, for more end to end use cases such as a JDBC sink, we need to know which row downstream is being updated.
      • okay to not support files?

      Attachments

        Activity

          People

            tdas Tathagata Das
            marmbrus Michael Armbrust
            Votes:
            1 Vote for this issue
            Watchers:
            11 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: