シナリオをジョブに変換する

このシナリオを実装するには、ジョブに関する次の4つのステップが必要です。

ジョブの作成、入力データのスキーマの定義、定義済みスキーマを基にした入力ファイルの読み取り。
出力ストリーム機能を有効にするコマンドの設定。
tMapコンポーネントを使ったデータのマッピング。
選択したデータストリームの出力。

終了したジョブは次の画像のようになります。ジョブのデザインの詳細は、次のセクションをご覧ください。

ステップ1: ローカルファイルから入力データを読み取る

tFileInputDelimitedコンポーネントを使って、入力データとしてcustomers.csvファイルを読み取ります。このコンポーネントは、[Palette] (パレット)の[File/Input] (ファイル/入力)グループにあります。

手順

tFileInputDelimitedコンポーネントをデザインワークスペースに配置してダブルクリックし、[Basic settings] (基本設定)ビューを開いて、プロパティを設定します。
[File name/Stream] (ファイル名/ストリーム)の横にある[...]ボタンをクリックし、入力データファイルのパスを参照して選択します。入力データファイルのパスは手動で入力することもできます。
[Edit schema] (スキーマを編集)をクリックしてダイアログボックスを開き、入力ファイルのファイルストラクチャーを設定します。
[ + ]ボタンをクリックしてカラムを6つ追加し、タイプとカラム名を次のスクリーンショットにある値に設定します。
OKをクリックしてダイアログボックスを閉じます。

ステップ2: 出力ストリーム機能を有効にするコマンドを設定する

tJavaを使って、出力ファイルと、そのファイルを含むディレクトリーを作成するコマンドを設定します。

手順

tJavaコンポーネントをデザインワークスペースに配置してダブルクリックし、[Basic settings] (基本設定)ビューを開いて、プロパティを設定します。
[Code] (コード)エリアに次のコマンドを入力します。
```
new java.io.File("C:/myFolder").mkdirs(); 
globalMap.put("out_file",new java.io.FileOutputStream("C:/myFolder/customerselection.txt",false));
```
情報メモヒント:
このステップで入力したコマンドにより、出力ファイルcustomerselection.txtを保存するための新規ディレクトリーC:/myFolderが作成されます。実際の状況に応じて、コマンドをカスタマイズできます。
[Trigger] (トリガー) > [On Subjob Ok]接続を使って、tJavaとtFileInputDelimitedを接続します。
tJavaが実行に成功すると、tFileInputDelimitedで始まるサブジョブがトリガーされます。

手順3: tMapコンポーネントを使ってデータのマッピングを行う

手順

tMapコンポーネントをデザインワークスペースに配置してダブルクリックし、[Basic settings] (基本設定)ビューを開いて、プロパティを設定します。
[Map Editor] (マップエディター)の横にある[...]ボタンをクリックし、ダイアログボックスを開いて、マッピングを設定します。
左側の[+]ボタンをクリックし、入力側データのスキーマのためにカラムを6つ追加します。これらのカラムは次の画像と同じでなければなりません:
右側の[+]ボタンをクリックし、出力側データフローのスキーマを追加します。
[New output] (新規出力)を選択し、[OK]をクリックして、出力スキーマを保存します。

現在のところ、出力スキーマはまだ空の状態です。
out1テーブルの下にある[+]ボタンをクリックし、出力データのカラムを3つ追加します。
id、CustomerName、CustomerAgeの各カラムを右側のそれぞれの行に配置します。
[OK]をクリックして、設定を保存します。

手順4: 選択したデータストリームを出力する

手順

tFileOutputDelimitedコンポーネントをデザインワークスペースに配置してダブルクリックし、[Basic settings] (基本設定)ビューを開いて、コンポーネントのプロパティを設定します。
[Use Output Stream] (出力ストリームを使用)チェックボックスをオンにし、[Output Stream] (出力ストリーム)フィールドを有効にして、[Output Stream] (出力ストリーム)フィールドに次のコマンドを入力します:
```
(java.io.OutputStream)globalMap.get("out_file")
```
情報メモ注:
[Output Stream] (出力ストリーム)フィールドのコマンドは、[Ctrl] + [Space]を押して、リストから組み込みコマンドを選択するか、実際の状況に従って、フィールドにコマンドを手動で入力します。このシナリオでは、[Output Stream] (出力ストリーム)フィールドで使用するコマンドにより、java.io.OutputStreamクラスが呼び出され、絞り込んだデータストリームを、tJavaの[Code] (コード)エリアで定義するローカルファイルに出力します。
[Row] (行) > [Main] (メイン)接続を使ってtFileInputDelimitedをtMapに接続し、tMapの[Map Editor] (マップエディター)で定義する[Row] (行) > [out1]接続を使ってtMapをtFileOutputDelimitedに接続します。
[Sync columns] (カラムを同期)タブをクリックし、先行コンポーネントで定義されているスキーマを取得します。
tLogRowコンポーネントをデザインワークスペースに配置してダブルクリックし、[Basic settings] (基本設定)ビューを開きます。
[Mode] (モード)エリアの[Table] (テーブル)ラジオボタンを選択します。
[Row] (行) > [Main] (メイン)接続を使って、tFileOutputDelimitedをtLogRowに接続します。
[Sync columns] (カラムを同期)タブをクリックし、先行のコンポーネントで定義されているスキーマを取得します。

これで、このジョブを実行する準備ができました。
Ctrl+Sを押してジョブを保存し、F6を押して実行します。

選択したデータの内容がコンソールに表示されます。

選択したデータは、指定したローカルファイルのcustomerselection.txtにも出力されます。

このページは役に立ちましたか?

このページまたはコンテンツにタイポ、ステップの省略、技術的エラーなどの問題が見つかった場合はお知らせください。

こちらにフィードバックをお寄せください