Databricks - カスタムSQL（バッチ）トリガーによる新規/更新行

このトリガーは、カスタムSQLに一致する行が挿入/更新されたときに行を取得します。これらの行は、ジョブごとにバッチとして処理されます。このトリガーは、ポーリング間隔ごとに新しい行をチェックします。

カスタムSQL（バッチ）トリガーによる新規/更新行

---

入力フィールド

このトリガーを使用するには、以下の入力フィールドを設定します。

• SQL

• カスタムSQLクエリを入力してください。このクエリは、新規/更新行を取得するために各ポーリング間隔で実行されます。Databricksは、SQL ANSI-92に準拠したSQLステートメントをサポートしています。

  バインド変数（例：id = :id）とパラメータフィールドを使用して入力をパラメータ化します。

  バインド変数を使用する場合は、スキーマを手動で定義する必要があります。

• ユニークキー

• 行を識別するためのユニークキーカラムを選択してください。Workatoはこれを使用して既存の行を重複排除します。

• ソートカラム

• 更新された行を識別するためのカラムを選択してください。ユニークキーとともに、このフィールドを使用してWorkatoは既存の行と更新された行の重複排除に使用する列を識別します。

• 出力フィールド

• クエリで返される列を定義します。出力は、下流のアプリケーションでデータピルとして使用できます。

• トリガーポーリング間隔

• オプション. 新しいイベントをチェックする頻度です。空白のままにすると、デフォルトで5分になります。最小値: 5分。ポーリング間隔について詳しくはこちら。