サンプルデータを分割してKuduに書き込む - Cloud

tFixedFlowIput コンポーネントをダブルクリックし、[Component] (コンポーネント)ビューを開きます。

例

[Edit schema] (スキーマを編集)の横にある[...]ボタンをクリックし、スキーマエディターを開きます。

この画像に示すように、[+]ボタンをクリックしてスキーマカラムを追加します。

[Type] (タイプ)カラムでは、ageカラムに[Integer] (整数)を選択します。

[Key] (キー)カラムでは、ageカラムのチェックボックスをオンにして、このカラムをプライマリキーカラムとして定義します。

[OK]をクリックしてこれらの変更を確認し、ポップアップ表示されるダイアログボックスで求められるプロパゲーションを承認します。

[Mode] (モード)エリアの[Use Inline Content] (インラインコンテンツを使う)ラジオボタンを選択して、上記のサンプルデータを、表示されている[Content] (コンテンツ)フィールドに貼り付けます。

[Field separator] (フィールド区切り)フィールドでセミコロン(;)を入力します。

tKuduOutputコンポーネントをダブルクリックして、[Component] (コンポーネント)ビューを開きます。

[Component List] (コンポーネントリスト)ドロップダウンリストで、[Use an existing configuration] (既存の設定を使う)チェックボックスをオンにし、前の手順で設定したKudu設定を選択します。

tKuduOutputがtFixedFlowInputと同じスキーマを持つように、[Sync columns] (カラムを同期)をクリックします。

[Table] (テーブル)フィールドに、Kuduで作成するテーブルの名前を入力します。

[Action on table] (テーブルでのアクション)ドロップダウンリストから[Drop table if exists and create] (テーブルが存在する場合、ドロップして作成)を選択します。

[Range partitions] (範囲パーティション)で[+]ボタンをクリックして1行を追加し、以下の操作を行います。

[Partition No] (パーティション番号)に、作成するパーティションのIDとして使う番号を二重引用符なしで入力します。たとえば、1を入力してパーティション1を作成します。
[Partition column] (パーティションカラム)で、パーティショニングに使うプライマリキーカラムを選択します。このシナリオでは、ageを選択します。
年齢データのタイプは整数であるため、[Lower boundary] (下限)に二重引用符なしで20を入力します。
[Upper boundary] (上限)も同じようにして、60に設定します。

このパーティション定義は、次のようにパーティションスキーマの読み取りを作成します。

RANGE (age) (
    PARTITION 20 <= VALUES < 60
)

このパーティションスキーマによると、下限20歳のレコードはこのパーティションに含まれているため、Kuduに書き込まれますが、上限60歳のレコードは除外され、Kuduに書き込まれません。

実際には、Kuduテーブルにすべてのデータを書き込む必要がある場合は、適切な境界でデータを受け取るために、より多くのパーティションを定義します。

[Action on data] (データでのアクション)ドロップダウンリストから[Insert] (挿入)を選択します。