You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by "Alexey Diomin (JIRA)" <ji...@apache.org> on 2016/12/06 19:15:59 UTC

[jira] [Created] (BEAM-1096) flink streaming side output optimization using SplitStream

Alexey Diomin created BEAM-1096:
-----------------------------------

             Summary: flink streaming side output optimization using SplitStream
                 Key: BEAM-1096
                 URL: https://issues.apache.org/jira/browse/BEAM-1096
             Project: Beam
          Issue Type: Improvement
          Components: runner-flink
    Affects Versions: 0.4.0-incubating
            Reporter: Alexey Diomin
            Priority: Minor


Current implementation:
1) send all events in all output streams
2) filtering streams for necessary tags

Cons: increased cpu usage for serialization all events

Proposed implementation:
1) route event in correct streams based on tag



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)