Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-12208

Introduce Sort & TemporalSort & SortLimit & Limit operators for blink streaming runtime

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Closed
    • Major
    • Resolution: Fixed
    • None
    • 1.9.0
    • Table SQL / Runtime
    • None

    Description

      Support translation from StreamExecSort / TemporalSort / SortLimit/ Limit to StreamTransformation.
      1. StreamExecSort handles query which requires sort on non-time fields, which caches all inputs elements, sorts all cached elements when the bounded-stream is finished, outputs sorted elements one by one then.
      Notes: it's only used for testing with bounded source now. If a query is converted to this node in product environment, an exception will be thrown.
      2. StreamExecTemporalSort handles query which requires sort on EventTime/ ProcTime fields
      3. StreamExecLimit could handles query which only takes `limit` elements from offset.
      Notes: StreamExecLimit could only support take limited elements currently, that is, `fetch` must be present in query.
      4. StreamExecSortLimit handles query which not only requires sort, but also only takes `limit` elements from offset.
      Notes: StreamExecSortLimit could only support take limited elements currently, that is, `fetch` must be present in query.

      Attachments

        Issue Links

          Activity

            People

              jingzhang Jing Zhang
              jingzhang Jing Zhang
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: