このタスクについて
この設定を行うには、次の手順に従います。
手順
-
tHBaseInputをダブルクリックして、[Component] (コンポーネント)ビューを開きます。
- [Use an existing connection] (既存の接続を使用)チェックボックスをオンにし、あらかじめ設定しておいた接続を選択します。このサンプルでは、tHBaseConnection_1です。
-
[Edit schema] (スキーマを編集)の横にある[...]ボタンをクリックし、スキーマエディターを開きます。
- [+]ボタンを3回クリックして3つの行を追加し、[Column] (カラム)カラムでそれぞれid、name、ageに名前を変更します。つまり、HBaseからこれら3つのカラムを抽出します。
- 3つそれぞれのカラムの型を選択します。この例の場合、idとageは整数型、nameは文字列型です。
- [OK]をクリックしてこれらの変更を確定し、ポップアップ表示されるダイアログボックスで求められるプロパゲーションを承認します。
- [Table name] (テーブル名)フィールドに、対象カラムを抽出するテーブル名を入力します。このシナリオのテーブルはcustomerです。
- [Mapping] (マッピング)テーブルの[Column] (カラム)カラムには、スキーマが定義済みなので値が既に自動入力されています。あとは[Column family] (カラムファミリー)カラムに、このファミリーに含まれるカラムに対応するファミリー名をそれぞれ入力するだけです。
-
tHBaseCloseをダブルクリックして、[Component] (コンポーネント)ビューを開きます。
- [Component List] (コンポーネントリスト)フィールドで、閉じる必要があるコンポーネントを選択します。この例では、接続はtHBaseConnection_1です。