Processing (インテグレーション)のシナリオ
- 値の集計とデータのソートを行う
- ダイナミックスキーマに基づいて値を集計
- CSVファイルのクリーンアップとフィルタリングを行う
- お気に入りのオンラインソーシャルネットワークからデータを収集
- Javaタイプの変換
- Map/Reduceコンポーネントを使用したJavaタイプの変換
- ダイナミックカラムを作成してそのコンテンツを抽出する
- エントリーの重複を除去
- ダイナミックスキーマに基づいてエントリーの重複を除去
- Map/Reduceコンポーネントを使用したエントリーの重複除去
- 複数カラムで正規化
- 1カラムで正規化
- 2つのカラムに完全一致を実行し、メインデータとリジェクトデータを出力
- データベーステーブルのフィールドからXMLデータを抽出
- データベーステーブルの区切り文字カラムを抽出
- 区切り付きファイルのXMLフィールドから正しいデータと誤ったデータを抽出
- EDIFACTメッセージからデータを抽出
- メールアドレスから名前、ドメイン、TLDを抽出
- tJavaRowを介してダイナミックカラムのコンテンツを抽出する
- さまざまな論理演算で名前のリストをフィルタリング
- 単純な条件を使って名前のリストをフィルタリングする
- 行と行のグループをフィルタリングする
- ファイルを反復処理してコンテンツをマージ
- ダイナミックカラムをベースに、入力データを参照ファイルと照合して一致
- データを正規化
- Map/Reduceコンポーネントを使用したデータを正規化
- Spark Batchジョブを使用したダウンロード分析を実行
- ソート済み行を再グルーピング
- Map/Reduceコンポーネントを使って値の置換とカラムのフィルタリングを行う
- フローを複製し、2つの同一のフローをそれぞれソート
- JSONフィールドからデータを抽出中にエラーメッセージを取得
- 入力データをソートして集計
- エントリーをソートする
- ダイナミックスキーマに基づくソートエントリー
- 1行を2行に分割
- JSONフィールドにフラットデータを書き込む