Delta Lake のインポート
PlaidCloud Documentに保存されたDelta Lakeテーブルを、プロジェクトのテーブルにインポートします。ステップには、テーブルのフォルダー(_delta_log フォルダーとデータファイルを含むフォルダー)を指定します。テーブルは最新バージョンで読み取られます。
ステップのフォームには、Parquetのインポートと同じタブがあります。インポートパラメーターではテーブルのフォルダーであるソースファイルとターゲットテーブルを選択し、テーブルデータの選択では列をマッピングし、データフィルターでは行をフィルターします。取り込みは、テーブルの _delta_log から列とその型を読み取り、パーティション列があれば最後にテキストとして追加します。フォルダーが存在しない場合や空の場合、取り込みは警告にパスを示して取り込む列がありませんと応答し、現在のマッピングはそのまま保持されます。
移行されたKNIMEワークフローでは、Delta Table Readerノードにこのステップが使用されます。
input_file— ドキュメントアカウントと、Deltaテーブルフォルダーのパスです。検索で複数のテーブルが見つかった場合、schema_mismatchがunion(デフォルト)に設定されていれば、各テーブルは列名で読み込まれ、テーブルにない列はNULLになり、マッピングで宣言されていない列は除外されます。errorの場合はステップが停止し、テーブルと列が示されます。schema_mismatchは、AIアシスタントまたはREST APIで設定します。target_frame— 行の書き込み先のテーブルです。source_columnsとtarget_columns— 列のマッピングです。source_where、having、aggregate、aggregation_type、distinct— 他のインポートステップと同様に、行のフィルターと集計を行います。use_target_slicer、limit_target_start、limit_target_end— 結果の一部のみを保持します。delete_file— インポート後に、インポートしたファイルを削除します。ascii_only— ASCII以外の文字を削除します。skip_if_unchanged— デフォルトでオンです。前回の成功した実行以降、ソースファイルとステップの設定が変更されていない場合、ワークフローの実行はインポートをスキップします。