Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-6810 Add a set of built-in functions to Table API & SQL
  3. FLINK-22737

Add support for CURRENT_WATERMARK to SQL

    XMLWordPrintableJSON

Details

    Description

      With a built-in function returning the current watermark, one could operate on late events without resorting to using the DataStream API.

      Called with zero parameters, this function returns the current watermark for the current row – if there is an event time attribute. Otherwise, it returns NULL. 

      Attachments

        Issue Links

          is related to

          Improvement - An improvement or enhancement to an existing feature or task. FLINK-10031 Support handling late events in Table API & SQL

          • Major - Major loss of function.
          • Open
          links to

          Web Link GitHub Pull Request #16046

          Activity

            People

              airblader Ingo Bürk
              alpinegizmo David Anderson
              Votes:
              0 Vote for this issue
              Watchers:
              9 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: