Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1527#issuecomment-176869415
Hi @wangyangjun,
sorry for the long wait but I think we can get this PR in after some
modifications. I'd like to change the API a bit to separate it from the other
Join implementation since that class is already quite crowded. What I would
propose is to add a method `timeJoin()` on DataStream and a new class
`TimeJoinedStreams` that is similar to `JoinedStreams` but specific to the
two-buffer time join.
Could you also please add support for the Scala API, we try to keep the two
APIs in sync. If you need help with that, please let me know.
---
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.
---
