我试着用flink，但我有一些麻烦，我用flink的例子“wordcount”来解释我的痛苦
我有三个问题：
如何在每个单词的实时流中获取计数器。
如何丰富输入数据。
如何将所有输入推送到另一个套接字上。
例子：

______FirstInput_____
 | InputSocket_A : "hello word"
 | AfterWindowsCount : "hello:1 word:1"
 | AfterUniqCount : "hello:1 word:1 nbOfWord:2"
 | PutSocket_B: "hello:1 word:1 nbOfWord:2"

_____SecondeInput____
 | InputSocket_A : "hello word"
 | AfterWindowsCount : "hello:2 word:2"
 | AfterUniqCount : "hello:2 word:2 nbOfWord:2"
 | PutSocket_B: "hello:2 word:2 nbOfWord:2"

我在flink1.3中使用scalaapi