ソート済み行の再グルーピング

このJavaシナリオでは、4つのエレメントからなるジョブについて説明します。これは、区切り付きファイル行を行ごとに読み取り、ソートタイプと順序別で入力データをソートし、すべての入力ソート済み行を非正規化し、[Run] (実行)ログコンソールに出力を表示することを目的としています。

Talendでサポートされているテクノロジーの詳細は、Talendコンポーネントをご覧ください。

• [Palette] (パレット)から、tFileInputDelimited、tSortRow、tDenormalizeSortedRow および tLogRowのコンポーネントをデザインワークスペースにドロップします。

• [Row Main] (行メイン) リンクを使って、4つのコンポーネントを接続します。

• デザインワークスペースでtFileInputDelimitedを選択します。

• [Component] (コンポーネント)タブをクリックして、tFileInputDelimitedの基本設定を定義します。

• [Property type] (プロパティタイプ)を[Built-in] (組み込み)に設定します。

• 処理されたファイルへのパスを[File Name] (ファイル名)フィールドに入力します。この例で使用されているname_listファイルには、idと名前の2つのカラムがあります。

• 必要に応じて、行とフィールドの区切り、ヘッダーとフッター、および処理される行数を定義します。

• [Built-in] (組み込み)に[Schema] (スキーマ)を設定し、[Edit schema] (スキーマを編集)の横にある[...]ボタンをクリックして、次のコンポーネントに渡すデータを定義します。このサンプルのスキーマは、idと[Named] (名前)の2つのカラムで構成されています。

• デザインワークスペースで、tSortRowを選択します。

• [Component] (コンポーネント)タブをクリックして、tSortRowの基本設定を定義します。

• [Schema type] (スキーマのタイプ)を[Built-in] (組み込み)に設定し、[Sync columns] (カラムを同期)をクリックしてtFileInputDelimitedコンポーネントからスキーマを取得します。

• [Criteria] (条件)パネルで、プラスボタンを使用して行を追加し、処理するスキーマカラムのソートパラメーターを設定するために使われます。このサンプルでは、idカラムを昇順にソートします。

• デザインワークスペースで、tDenormalizeSortedRowを選択します。

• [Component] (コンポーネント)タブをクリックして、tDenormalizeSortedRowの基本設定を定義します。

• [Schema type] (スキーマのタイプ)を[Built-in] (組み込み)に設定し、[Sync columns] (カラムを同期)をクリックしてtSortRowコンポーネントからスキーマを取得します。

• [Input rows count] (入力行数)フィールドに、処理する入力行数を入力するか、Ctrl + スペースを押してコンテキスト変数リストにアクセスし、変数を選択します: tFileInputDelimited_1_NB_LINE。

• [非正規化する] (To denormalize)パネルで、プラスボタンを使用して行を追加し、処理するスキーマカラムのソートパラメーターを設定するために使われます。このサンプルでは、[Named] (名前)カラムを非正規化します。

• デザインワークスペースで、tLogRowを選択して、[Component] (コンポーネント)タブをクリックし、基本設定を定義します。tLogRowの詳細は、tLogRowをご覧ください。

• ジョブを保存し、F6を押して実行します。

コンソールに表示される結果は、[name] (名前)カラムがどのように非正規化されたかを示しています。