Re: An update on the DataStream API refactoring WiP

Oh, and of course, support for event time. I might be forgetting more, feel free to add to the list On Fri, Oct 2, 2015 at 2:40 PM, Kostas Tzoumas wrote: > Hi folks, > > Currently, Aljoscha, Stephan, and I are reworking the DataStream API as > discussed before. Things are

Re: An update on the DataStream API refactoring WiP

You made very sensible choices for improving and finalizing the Streaming API. The documentation is much clearer now. By the way, here is the pull request: https://github.com/apache/flink/pull/1208 On Fri, Oct 2, 2015 at 3:02 PM, Stephan Ewen wrote: > I added two comments to

Re: An update on the DataStream API refactoring WiP

right, I meant DataStream On Fri, Oct 2, 2015 at 2:47 PM, Robert Metzger wrote: > I suspect: "- Deletion of "DataSet.forward() and .global()"" is a typo, you > meant DataStream ? > > On Fri, Oct 2, 2015 at 2:44 PM, Kostas Tzoumas > wrote: > > > Oh, and

An update on the DataStream API refactoring WiP

Hi folks, Currently, Aljoscha, Stephan, and I are reworking the DataStream API as discussed before. Things are a bit in-flight right now with several commits and pull requests, and the current master containing code from both the old and the new API. I want to give you an idea of how the new API

Re: An update on the DataStream API refactoring WiP

I added two comments to the pull request that this is based on... On Fri, Oct 2, 2015 at 2:47 PM, Robert Metzger wrote: > I suspect: "- Deletion of "DataSet.forward() and .global()"" is a typo, you > meant DataStream ? > > On Fri, Oct 2, 2015 at 2:44 PM, Kostas Tzoumas