My point was, that as far as I know, Sinks are "terminating" operators, that ends the stream like .collect in Java 8 stream API. The don't emit elements further and I cannot link then in a way:
source - proces - sink - process - sink Sink function produces DataStreamSink which is used for emitting elements from a streaming topology. It is not SingleOutputStreamOperator or DataStream that I can use as input for next operator. -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
