You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by nsengupta <se...@gmail.com> on 2016/05/13 13:06:41 UTC
Availability of OrderedKeyedDataStream
Hello Flinksters,
Have you decided to do away with the 'OrderedKeyedDataStream' type
altogether? I didn't find it in the API documents
<https://ci.apache.org/projects/flink/flink-docs-release-1.0/api/java/> .
It is mentioned and elaborated here
<https://cwiki.apache.org/confluence/display/FLINK/Streams+and+Operations+on+Streams>
and I think it can be a good fit for an UseCase I am trying to implement.
Could someone please confirm? If it exists but with a different name or if
the same behaviour can be achieved using other methods, I would like to be
wiser.
-- Nirmalya
--
View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Availability-of-OrderedKeyedDataStream-tp6903.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
Re: Availability of OrderedKeyedDataStream
Posted by Aljoscha Krettek <al...@apache.org>.
Hi,
you're right, this is not currently implemented. You can implement it as a
custom operator that buffers elements and sorts when a watermark arrives.
Cheers,
Aljoscha
On Fri, 13 May 2016 at 15:42 nsengupta <se...@gmail.com> wrote:
> Hello Flinksters,
>
> Have you decided to do away with the 'OrderedKeyedDataStream' type
> altogether? I didn't find it in the API documents
> <https://ci.apache.org/projects/flink/flink-docs-release-1.0/api/java/> .
> It is mentioned and elaborated here
> <
> https://cwiki.apache.org/confluence/display/FLINK/Streams+and+Operations+on+Streams
> >
> and I think it can be a good fit for an UseCase I am trying to implement.
>
> Could someone please confirm? If it exists but with a different name or if
> the same behaviour can be achieved using other methods, I would like to be
> wiser.
>
> -- Nirmalya
>
>
>
>
> --
> View this message in context:
> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Availability-of-OrderedKeyedDataStream-tp6903.html
> Sent from the Apache Flink User Mailing List archive. mailing list archive
> at Nabble.com.
>