エントリーの編集
エントリーの編集は全ユーザーに共通の機能です。
必ずガイドラインを一読の上ご利用ください。
FileIOのDynamic DestinationのDestinationTはequals/hashCodeが必要だよ - Qiita
記事へのコメント0件
- 注目コメント
- 新着コメント
このエントリーにコメントしてみましょう。
注目コメント算出アルゴリズムの一部にLINEヤフー株式会社の「建設的コメント順位付けモデルAPI」を使用しています
- バナー広告なし
- ミュート機能あり
- ダークモード搭載
関連記事
FileIOのDynamic DestinationのDestinationTはequals/hashCodeが必要だよ - Qiita
細かすぎて伝わらないApache Beam/Dataflow選手権#1です。 FileIOって? Apache Beamのファイル一般を扱... 細かすぎて伝わらないApache Beam/Dataflow選手権#1です。 FileIOって? Apache Beamのファイル一般を扱うIOクラスです。 ドキュメントによるとS3/GCS/HDFS/ローカルのファイルを、扱う事が出来るようです。 Dynamic Destinationって? PCollectionの中身によって出力先を変える機能です。 具体的な設定はFileIO.Writeで定義されており、 byで、入力(UserT)をグループ(DestinationT)に分類するクラスを指定 viaで、入力(UserT)を出力(OutputT)に変換するクラスを指定 withNamingで、グループ(DestinationT)からファイル名を決めるクラスを指定 の3つが、Dynamic Destinationの主な設定です。 DestinationTって 入力(UserT)分類し、グ