Flink SplitStream的簡單使用

2021-09-24 04:35:07 字數 655 閱讀 4991

在flink datastream api中有乙個split()運算元,它的功能是將乙個stream,通過split()設定多個標記,劃分成多個流。再通過select()獲取對應標記的流。

像種運算元,可以根據不同的tag,進行不同的邏輯處理,可謂是非常的方便。

具體看**:

public class splitoperator 

}).split(new outputselector() else

return list;

}});

// splitstream流 通過select("tag")獲取datastream流

datastreammale = splitstream.select("male");

male.print("male:");

datastreamfemale = splitstream.select("female");

female.print("female:");

// 將流合併

datastreamunion = male.union(female);

union.print("union:");

senv.execute("splitoperator");

}}

輸出結果:

UICollectionView的簡單使用

所屬controller要遵循三個協議 uicollectionviewdatasource,uicollectionviewdelegate,uicollectionviewdelegateflowlayout uicollectionviewflowlayout flowlayout uicol...

BGAQRCode Android的簡單使用

compile com.google.zxing core 3.2.1 xmlns android 這句是使用選擇器框架時用到的 xmlns tools package com.huaqiang.zxingdemo 選擇框架用到 android name android.permission.cam...

Android VideoView的簡單使用

mvideoview.setvideouri uri.parse android.resource getpackagename r.raw play 設定乙個 控制器 控制器預設在父布局的地步 可以自己實現控制器布局 mvideoview.setmediacontroller new mediac...