目次

Search

  1. はじめに
  2. トランスフォーメーションについて
  3. トランスフォーメーションポート
  4. トランスフォーメーションキャッシュ
  5. アドレスバリデータトランスフォーメーション
  6. アグリゲータトランスフォーメーション
  7. 関連付けトランスフォーメーション
  8. 不良レコードの例外トランスフォーメーション
  9. 大文字小文字変換プログラムトランスフォーメーション
  10. 分類子トランスフォーメーション
  11. 比較トランスフォーメーション
  12. 統合トランスフォーメーション
  13. データマスキングトランスフォーメーション
  14. データプロセッサトランスフォーメーション
  15. ディシジョントランスフォーメーション
  16. 重複レコードの例外トランスフォーメーション
  17. 式トランスフォーメーション
  18. フィルタトランスフォーメーション
  19. 階層型からリレーショナルへのトランスフォーメーション
  20. Javaトランスフォーメーション
  21. JavaトランスフォーメーションAPIのリファレンス
  22. Java式
  23. ジョイナトランスフォーメーション
  24. キージェネレータトランスフォーメーション
  25. ラベラトランスフォーメーション
  26. ルックアップトランスフォーメーション
  27. ルックアップキャッシュ
  28. 動的ルックアップキャッシュ
  29. マクロトランスフォーメーション
  30. 一致トランスフォーメーション
  31. フィールド分析での一致トランスフォーメーション
  32. ID分析での一致トランスフォーメーション
  33. ノーマライザトランスフォーメーション
  34. マージトランスフォーメーション
  35. パーサートランスフォーメーション
  36. Pythonトランスフォーメーション
  37. ランクトランスフォーメーション
  38. 読み取りトランスフォーメーション
  39. リレーショナルから階層型へのトランスフォーメーション
  40. REST Webサービスコンシューマトランスフォーメーション
  41. ルータトランスフォーメーション
  42. シーケンスジェネレータトランスフォーメーション
  43. ソータートランスフォーメーション
  44. SQLトランスフォーメーション
  45. 標準化トランスフォーメーション
  46. 共有体トランスフォーメーション
  47. アップデートストラテジトランスフォーメーション
  48. Webサービスコンシューマトランスフォーメーション
  49. WebサービスSOAPメッセージの解析
  50. WebサービスSOAPメッセージの生成
  51. 加重平均トランスフォーメーション
  52. ウィンドウトランスフォーメーション
  53. 書き込みトランスフォーメーション
  54. 付録 A: トランスフォーメーションの区切り文字

Developer Transformation Guide

Developer Transformation Guide

Routerトランスフォーメーションの設定

Routerトランスフォーメーションの設定

Routerトランスフォーメーションでは2つの入力ポートを使用します。データソースからはツイッターメッセージを読み込み、分類子トランスフォーメーションからはISO国コードを読み取ります。Routerトランスフォーメーションでは、入力ポートのデータを、指定した条件に基づいて異なる出力ポートにルーティングします。
次の図に、Routerトランスフォーメーションのポートグループとポートの接続を示します。
このマッピングには、データソースオブジェクト、分類子トランスフォーメーション、Routerトランスフォーメーション、および2つのデータターゲットオブジェクトが含まれています。Routerトランスフォーメーションは、マッピングエディタで展開すると、入力ポートと2つの出力ポートグループとして表示されます。
次の表に、Routerトランスフォーメーションの設定を示します。
ポート名
ポートタイプ
ポートグループ
精度
Classifier_Output
入力
入力
2
text
入力
入力
200
Classifier_Output
入力
デフォルト
2
text
入力
デフォルト
200
Classifier_Output
入力
En_Group
2
text
入力
En_Group
200
英語のメッセージおよび英語以外のメッセージのデータストリームを作成するためのトランスフォーメーションを設定します。データストリームを作成するには、トランスフォーメーションに出力ポートを追加します。トランスフォーメーションの
[グループ]
オプションを使用してポートグループを追加します。
トランスフォーメーションがデータを各データストリームにルーティングする方法を決めるには、ポートグループに対する条件を定義します。この条件でポートを特定し、そのポートで可能な値を指定します。トランスフォーメーションが条件に一致する入力ポート値を検出すると、入力データを条件を適用するポートグループにルーティングします。
En_Groupに対して次の条件を定義します。
ClassifierOutput='en'
Routerトランスフォーメーションでは、マッピング内の2つのオブジェクトからデータを読み込みます。このトランスフォーメーションでは、データオブジェクトで定義した行の順番が変わらないため、各出力グループ内のデータを結合することができます。