You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by Chen Qin <cq...@uber.com> on 2016/12/13 07:16:58 UTC
Minor Cleanup of StreamGraphGeneator
Hi There,
I am thinking of doing a minor refactor of StreamGraphGenerator.
There are some transforms share same logic that can potentially reusable.
Also, long list of if else seems hard to read, might better off abstract
interface & offer default implementation.
Bonus point would be allow configuration overwrite of this "transformer"
with job level customized implementation.
Any suggestions?
Thanks,
Chen