can Flink use multi "addSink"?

[侯林蔚]

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.

[Gábor Gévay]

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 侯林蔚 <[hidden email]>:

> 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.