You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by Piper Piper <pi...@gmail.com> on 2020/02/24 08:38:10 UTC
Java implementations of Streaming applications for Flink
Hi all,
The examples in the Flink github repo do not seem to include many standard
streaming applications compared to the batch examples.
Where can I get standard (recommended) Java implementations of “Streaming”
applications for Flink, that are clearly: (1) CPU-intensive, like streaming
PageRank, streaming K-Means, etc., and (2) I/O-intensive, and if possible
also, (3) Network intensive?
By "standard", I mean Java implementations that are accepted by the
community in terms of efficiency.
Thank you,
Piper
Re: Java implementations of Streaming applications for Flink
Posted by Piper Piper <pi...@gmail.com>.
Very informative. Thank you, Robert!
On Tue, Feb 25, 2020 at 5:02 AM Robert Metzger <rm...@apache.org> wrote:
> Hey Piper,
>
> Here's an example for a more advanced Flink application:
> https://flink.apache.org/news/2020/01/15/demo-fraud-detection.html
> The Flink developers internally maintain a number of testing jobs. They
> are rather artificial, but you still might find some useful things here and
> there: https://github.com/apache/flink/tree/master/flink-end-to-end-tests
>
> Best,
> Robert
>
>
> On Mon, Feb 24, 2020 at 9:38 AM Piper Piper <pi...@gmail.com> wrote:
>
>> Hi all,
>>
>> The examples in the Flink github repo do not seem to include many
>> standard streaming applications compared to the batch examples.
>>
>> Where can I get standard (recommended) Java implementations of
>> “Streaming” applications for Flink, that are clearly: (1) CPU-intensive,
>> like streaming PageRank, streaming K-Means, etc., and (2) I/O-intensive,
>> and if possible also, (3) Network intensive?
>>
>> By "standard", I mean Java implementations that are accepted by the
>> community in terms of efficiency.
>>
>> Thank you,
>>
>> Piper
>>
>
Re: Java implementations of Streaming applications for Flink
Posted by Robert Metzger <rm...@apache.org>.
Hey Piper,
Here's an example for a more advanced Flink application:
https://flink.apache.org/news/2020/01/15/demo-fraud-detection.html
The Flink developers internally maintain a number of testing jobs. They are
rather artificial, but you still might find some useful things here and
there: https://github.com/apache/flink/tree/master/flink-end-to-end-tests
Best,
Robert
On Mon, Feb 24, 2020 at 9:38 AM Piper Piper <pi...@gmail.com> wrote:
> Hi all,
>
> The examples in the Flink github repo do not seem to include many standard
> streaming applications compared to the batch examples.
>
> Where can I get standard (recommended) Java implementations of “Streaming”
> applications for Flink, that are clearly: (1) CPU-intensive, like streaming
> PageRank, streaming K-Means, etc., and (2) I/O-intensive, and if possible
> also, (3) Network intensive?
>
> By "standard", I mean Java implementations that are accepted by the
> community in terms of efficiency.
>
> Thank you,
>
> Piper
>