[ 
https://issues.apache.org/jira/browse/FLINK-1869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14496299#comment-14496299
 ] 

Akshay Dixit commented on FLINK-1869:
-------------------------------------

Hi, I'd like to take a crack at this issue if no one else is working on it.

>From what I've managed to understand, making StreamDiscretizer operators 
>extend ChainableStreamOperator would enable them to be stacked on top of each 
>other and the policy of the resulting stacked discretizer would be a union of 
>the two policies. Is that it? 

Also, simply changing the StreamDiscretizer to extend ChainableStreamOperator  
instead of StreamOperator doesn't break any tests. I'd like some pointers on 
what would be needed to changed further so that it actually functions in they 
way it is desired.

> Make StreamDiscretizers chainable
> ---------------------------------
>
>                 Key: FLINK-1869
>                 URL: https://issues.apache.org/jira/browse/FLINK-1869
>             Project: Flink
>          Issue Type: Improvement
>          Components: Streaming
>            Reporter: Gyula Fora
>
> Currently the different StreamDiscretizer operators (StreamDiscretizer, 
> GroupedStreamDiscretizer, GroupedActiveDiscretizer) are non-chainable.



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

Reply via email to