WindowedStream vs AllWindowedStream

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

WindowedStream vs AllWindowedStream

Radu Prodan
Hi all,

I have question about the differences between WindowedStream and AllWindowedStream. From the definition I see that WindowedStream are partitioned based on key but for AllWindowedStream this is not the case.

So, what comes to my mind is, why WindowedStream is not the special case of AllWindowedStream? or why those classes are completely separated, and  not extending from one another?

Radu
Reply | Threaded
Open this post in threaded view
|

Re: WindowedStream vs AllWindowedStream

Aljoscha Krettek
They are different classes because the signature of their apply method is different. If one were the subclass, it would be possible to call apply with the wrong signature.

On Thu, 28 Apr 2016 at 12:25 Radu Prodan <[hidden email]> wrote:
Hi all,

I have question about the differences between WindowedStream and AllWindowedStream. From the definition I see that WindowedStream are partitioned based on key but for AllWindowedStream this is not the case.

So, what comes to my mind is, why WindowedStream is not the special case of AllWindowedStream? or why those classes are completely separated, and  not extending from one another?

Radu