07_Flink Streaming transform

flatmap,map,filter都是轉換,經過datastream的transform方法。以最經典的flatmap爲例,transform,須要三個參數,操做名字,輸出類型,對輸入數據的操做。返回java SingleOutputStreamOperator,是datastream的子類,也就是能夠鏈式的調用。返回一個OneInputTransformation。是StreamTransfo
相關文章
相關標籤/搜索