Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/659#issuecomment-102333346
Yes, I was aware of that new test. :smile: The PollingSourceFunction I
didn't implement because I think this is orthogonal to this work.
For the operators, I think it's not a problem because I think they refer to
different concepts. The TwoInputOperator is a physical operator that happens to
have two inputs. The CoStreamMap is a higher level concept that implements a
Map over two connected streams. And it just so happens that this concept can be
implemented using the "physical" two input operator.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
