[
https://issues.apache.org/jira/browse/FLINK-1345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi resolved FLINK-1345.
-----------------------------------
Resolution: Implemented
Implemented via 26535c4...7dbb55e.
> Add operator chaining to the streaming runtime
> -----------------------------------------------
>
> Key: FLINK-1345
> URL: https://issues.apache.org/jira/browse/FLINK-1345
> Project: Flink
> Issue Type: Improvement
> Components: Streaming
> Reporter: Gyula Fora
> Assignee: Gyula Fora
> Priority: Minor
>
> Operator chaining should be added as a runtime optimisation to the streaming
> system as well.
> A straightforward way to implement this is to add a new
> ChainableStreamInvokable class which also implements the collector interface.
> Operators like map, filter ... should extend this class.
> After this the jobgraphbuilder should analyze the invokables to determine if
> chaining should be used: check if the invokable is a ChainableInvokable and
> all connections are forward with the same parallelism.
> The chained invokables should then be passed as collectors to the previous
> ones as in the batch runtime.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
