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

Add support for named streams in Storm compatibility layer

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Closed
    • Major
    • Resolution: Fixed
    • None
    • 0.10.0
    • flink-contrib
    • None

    Description

      Currently, the layer only works on single stream and ignores stream names, ie, each stream is treated as "default" stream. The declaration of multiple output streams is ignored (all tuples are emitted to the same stream). If multiple input streams are consumed all tuples are merged into a single stream.

      This feature allows operators to declare multiple (named) output streams and emit tuples to different stream. Furthermore, it enables Bolts to distinguish incoming tuples from different streams by stream name (Storm tuple meta information).

      Attachments

        Activity

          People

            mjsax Matthias J. Sax
            mjsax Matthias J. Sax
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: