Flink 的神奇分流器:sideoutput

今天浪尖给大家讲讲flink的一个神奇功能,sideouptut侧输出。 为了说明侧输出(sideouptut)的作用,浪尖举个例子,比如现在有一篇文章吧,单词长度不一,但是我们想对单词长度小于5的单词进行wordcount操作,同时又想记录下来哪些单词的长度大于了5,那么我们该如何做呢? 比如,Datastream是单词流,...