"void"データ型を持つapache crunchでDoFnをどのように定義できますか？

Question

基本的に、私はDoFnからの出力を必要としません。DoFnに入っているレコードごとにいくつかのmysql dbを更新したいだけです。だから私は空のデータ型を持つDoFnを定義することができますか？基本的に私はDoFnから何も放出したくありません。

Answer 1

それはできません。 Crunchが実行のためのグラフを生成すると、書き込まれる出力があるかどうか、またはデータがマテリアライズされるかどうかが決定されます（アクションによく似ています）。あなたが望むものを達成するためにも、DoFn<T,String>の作成のような回避策を行う必要があります。あなたが既に出力がないことがわかっていても、あなたのDoFnからPCollectionの結果を書いたり、実現したりするコードです。