手順
-
tKuduInputをダブルクリックして、[Component] (コンポーネント)ビューを開きます。
例
-
[Edit schema] (スキーマを編集)の横の[...]ボタンをクリックし、スキーマエディターを開きます。
-
この画像に示すように、[+]ボタンをクリックしてスキーマ出力カラムを追加します。
例
-
[Type] (型)フィールドで、ageカラムのデータ型として[Integer] (整数)を選択します。
-
[Key] (キー)カラムでageカラムのチェックボックスをオンにします。これがプライマリキーカラムだからです。
-
[OK]をクリックしてこれらの変更を確認し、ポップアップ表示されるダイアログボックスで求められるプロパゲーションを承認します。
-
[Table name] (テーブル名)フィールドに、データを読み取るテーブルの名前を入力します。このシナリオでは、ychen_kuduです。
-
[Query mode] (クエリーモード)エリアで[Use scan] (スキャンを使う)ラジオボタンを選択して、Kuduテーブルからすべてのデータを読み取ります。
-
tLogRowをダブルクリックして[Component] (コンポーネント)ビューを開き、[Table] (テーブル)ラジオボタンを選択して結果をテーブルに表示します。
-
[F6] を押してこのジョブを実行します。
タスクの結果
完了したら、 [Run] (実行)ビューのコンソールで、Kuduテーブルから読み取ったデータを確認できます。
レコード04;tom;60
はパーティションの境界を超えているため、テーブルに書き込まれていません。
実際の運用では、実行に成功した場合、Talend JobServerがあればそこでジョブをデプロイし、起動できます。
関連情報は、Talend Help Center(https://help.talend.com)でジョブをリモート実行する方法を検索してください。