Hi, guys: I propose a design to enhance Stream Operator API for Batch’s requirements. This is also the Flink’s goal that Batch is a special case of Streaming. This proposal mainly contains two changes to operator api:
1. Allow "StreamOperator" can choose which input to read; 2. Notify "StreamOperator" that an input has ended. This proposal was discussed with Piotr Nowojski, Kostas Kloudas, Haibo Sun offlline. It will be great to hear the feed backs and suggestions from the community. Please kindly share your comments and suggestions. Best GuoWei Ma. Enhance Operator API to Support Dynamically Sel... <https://docs.google.com/document/d/10k5pQm3SkMiK5Zn1iFDqhQnzjQTLF0Vtcbc8poB4_c8/edit?usp=drive_web>
