flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Aljoscha Krettek <aljos...@apache.org>
Subject Re: Question about DataStream class hierarchy
Date Wed, 29 Jul 2015 06:11:18 GMT
Right now it's mostly under-the-hood changes but you can look at the
progress here: https://github.com/aljoscha/flink/tree/stream-api-rework

The commit is going to change, so if you do put your work on top of it you
might have to rebase.

On Wed, 29 Jul 2015 at 07:26 Matthias J. Sax <mjsax@informatik.hu-berlin.de>
wrote:

> My current work depends on a clean design of those. Otherwise, my own
> code would get very messy. I would like to apply some changes in my own
> PR (not opened yet). Do you thinks this is feasible? I don't want get in
> a messy state. What kind of changes are you going to apply in FLINK-2398?
>
> -Matthias
>
>
> On 07/28/2015 10:30 PM, Aljoscha Krettek wrote:
> > Yes, very good points. I think we will be fixing these when we do the API
> > cleanups that we discussed on the wiki design docs. In fact, the work I'm
> > doing on https://issues.apache.org/jira/browse/FLINK-2398 can be seen as
> > preparation for making these changes possible/easier.
> >
> > On Tue, 28 Jul 2015 at 21:56 Matthias J. Sax <
> mjsax@informatik.hu-berlin.de>
> > wrote:
> >
> >> Hi,
> >>
> >> I am a little bit confused about the class hierarchy of DataStream. It
> >> has three subclasses: KeyedDataStream, SingleOutputStreamOperator, and
> >> SplitDataStream.
> >>
> >> 1) Why is the name "SingleOutputStreamOperator" (why OPERATOR ??)
> >>
> >> 2) Is it correct, that a SplitDataStream emit multiple logical output
> >> streams, while SingleOutputStreamOperator and KeyedDataStream emit a
> >> single logical output stream?
> >>    => If yes, why is a KeyedDataStream not a subclass of
> >> SingleOutputStreamOperator ?
> >>
> >> 3)
> >>   a) Why does only SingleOutputStreamOperator has method
> name()/getName()?
> >>   b) Why does only SingleOutputStreamOperator has method
> setParallelism()?
> >>   c) Should those methods be members of DataStream instead?
> >>
> >>
> >>
> >> -Matthias
> >>
> >>
> >
>
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message