阿帕奇弗林克了：KeyedStream值地圖功能，又不失鍵狀態

Question

我有一個密鑰流：

KeyedStream<String, Data> keyed = 
     env.addSource(...) 
      .map(new Parser()) 
      .keyBy(i -> i.key) 

我想運行在我流的狀態，全過程的功能;但process將返回，導致失去KeyedStream正常未鍵控流，並迫使我再次打電話keyBy：

SingleOutputStreamOperator<Data> unkeyed = keyed.process(new Function) 
KeyedStream<String, Data> keyedAgain = keyed.keyBy(i -> i.key) 

• 有什麼辦法叫過值的地圖功能上KeyedStream？

• 如何在不使用低成本API（如ProcessFunction）的情況下運行狀態完全功能，這會導致不必要的成本：運行時產生一個新的子任務，並重新清理我的數據？

Answer 1

您可以使用RichMapFunction或RichFlatmapFunction，並有機會獲得弗林克的管理狀態的機制。與ProcessFunction相比，你會錯過的是定時器。

請參閱示例here。