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 侯林蔚 <time...@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.
