apache beam data flow tutorial:apache光束数据流教程 源码

apache-beam-data-flow-tutorial Apache Beam数据流教程 Apache Beam SDK入门 管道 处理タスク全体(パイプライン)をカプセル化します。处理タスクには,入力データの読み取り,変换处理,および出力データの书き込み等が含まれます。 P系列 通常は,外部のデータソースからデータを読み取り,PCollectionを作成しますが,インメモリから作成することも可能です。 变形 すべての变换は,1つ以上のPCollectionを入力として受け取り,そのPCollectionの要素に対して何らかの处理を実行して,0个以上のPCollectionを出力します