flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Gábor Gévay <gga...@gmail.com>
Subject Re: can Flink use multi "addSink"?
Date Mon, 26 Sep 2016 11:43:02 GMT
Hello,

You can't call map on the sink, but instead you can continue from the
stream that you have just before the sink:

val stream = datastream.filter(new Myfilter())
val sink1 = stream.addSink(new Mysink())
val sink2 = stream.map(new MyMap()).addSink(MySink2())

Best,
Gábor



2016-09-26 12:47 GMT+02:00 侯林蔚 <timeror@gmail.com>:
> hello,
>
> I am a green hand  with Flink, and I want to build a topology with streaming
> api  like this:
>
>   datastream.fliter(new Myfilter()).addSink(new Mysink()).map(new
> MyMap()).addSink(MySink2())
>
> can Flink support operations like this?
>
> Hope for your reply sincerely. thx.

Mime
View raw message