注: 以下の翻訳の正確性は検証されていません。AIPを利用して英語版の原文から機械的に翻訳されたものです。

はじめに

このチュートリアルの前にバッチパイプラインのチュートリアルをご検討ください

以下の手順では、Java による簡単なデータ変換を順を追って説明します。データ変換をはじめたばかりの場合は、先に Pipeline Builder または Code Repositories のバッチパイプラインのチュートリアルに沿って進めることをご検討ください。

初めての Java トランスフォームの作成をはじめるには、以下の手順に沿って進めます。

  1. 新しい Transforms Java リポジトリを作成します。プロジェクトに移動し、+ 新規 > リポジトリを選択して、Template の言語で Java を選択します。

  2. このサンプルデータセットをダウンロードします。titanic.zip をダウンロード。このデータセットを Foundry にインポートします。

  3. リポジトリに移動します。データ変換コードは myproject/datasets/HighLevelAutoTransform.java に記述します。このファイル内のサンプルコードはコメントアウトされているため、次に進む前に必ずコメントを解除してください。

  4. /path/to/input/dataset を titanic データセットのフルパスに置き換えて、入力データセットを更新します。

  5. /path/to/output/dataset を出力データセットの希望する場所のフルパスに置き換えて、出力データセットを更新します。

  6. デフォルトの変換コードを変更し、titanic データセットを性別に基づいて絞り込んで、女性の乗客をすべて取得します。my_compute_function 内のデータ変換コードを更新します。

    Copied!
    1 2 3 4 5 6 7 @Compute // 出力データセットのフルパスに置き換えます。 @Output("/path/to/output/dataset") // 「titanic」データセットのフルパスに置き換えます。 public Dataset<Row> myComputeFunction(@Input("/path/to/input/dataset") Dataset<Row> myInput) { return myInput.filter(myInput.col("Sex").equalTo("female")); }
  7. 変更をこのブランチに正常にコミットすると、出力データセットを開いてビルドできます。

この例では、自動登録を使用する高レベルのトランスフォームを定義しています。Transforms Java がサポートするデータ変換の種類や、テンプレートプロジェクトの構造および含まれるファイルの説明については、こちらのドキュメントを参照してください。