Flink Streaming Scala API

[Gyula Fóra]

Hey guys,

I am sure everyone is very busy with Christmas stuff, but if you are
getting bored try out the brand new Streaming Scala API.

I have opened a PR for it here:
https://github.com/apache/incubator-flink/pull/275

Basically everything works, but I still need to do some finishing touches.

I will probably add an example to the scala-examples package tomorrow but
it is getting very late (early) today :)

Happy Holidays!
Gyula

[Stephan Ewen]

Amazing, I'll try it out over the holidays!
Am 21.12.2014 03:53 schrieb "Gyula Fóra" <[hidden email]>:

> Hey guys,
>
> I am sure everyone is very busy with Christmas stuff, but if you are
> getting bored try out the brand new Streaming Scala API.
>
> I have opened a PR for it here:
> https://github.com/apache/incubator-flink/pull/275
>
> Basically everything works, but I still need to do some finishing touches.
>
> I will probably add an example to the scala-examples package tomorrow but
> it is getting very late (early) today :)
>
> Happy Holidays!
> Gyula
>

[Gyula Fóra]

Also added a simple window-join example here
<https://github.com/mbalassi/incubator-flink/blob/ca2af20de5ed5b11a7739358204622871bb83c32/flink-examples/flink-scala-examples/src/main/scala/org/apache/flink/examples/scala/streaming/windowing/WindowJoin.scala>,
where you can check out some features :)

Gyula

On Sun, Dec 21, 2014 at 1:13 PM, Stephan Ewen <[hidden email]> wrote:

> Amazing, I'll try it out over the holidays!
> Am 21.12.2014 03:53 schrieb "Gyula Fóra" <[hidden email]>:
>
> > Hey guys,
> >
> > I am sure everyone is very busy with Christmas stuff, but if you are
> > getting bored try out the brand new Streaming Scala API.
> >
> > I have opened a PR for it here:
> > https://github.com/apache/incubator-flink/pull/275
> >
> > Basically everything works, but I still need to do some finishing
> touches.
> >
> > I will probably add an example to the scala-examples package tomorrow but
> > it is getting very late (early) today :)
> >
> > Happy Holidays!
> > Gyula
> >
>

[Henry Saputra]

Thanks for sharing. Gyula!

- Henry

On Sat, Dec 20, 2014 at 6:51 PM, Gyula Fóra <[hidden email]> wrote:

> Hey guys,
>
> I am sure everyone is very busy with Christmas stuff, but if you are
> getting bored try out the brand new Streaming Scala API.
>
> I have opened a PR for it here:
> https://github.com/apache/incubator-flink/pull/275
>
> Basically everything works, but I still need to do some finishing touches.
>
> I will probably add an example to the scala-examples package tomorrow but
> it is getting very late (early) today :)
>
> Happy Holidays!
> Gyula

[sirinath]

See if there is anything you can borrow from Akka Streaming API for Flink Streams: http://doc.akka.io/docs/akka-stream-and-http-experimental/1.0-M2/scala.html

The DSL looks good and perhaps might stimulate some ideas.