Databricks - カスタムSQLによるNew/updated rows（batch）トリガー ​

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

カスタムSQLによるNew/updated rows（batch）トリガー

入力 ​

このトリガーを使用するには、次の入力項目を設定します。

• SQL

• カスタムSQLクエリを入力します。 このクエリは各polling intervalで実行され、New/updated rowsを取得します。 Databricksは、SQL ANSI-92に準拠したSQLステートメントをサポートしています。

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

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

• 一意キー

• 行を識別する一意キー列を選択します。 Workatoはこれを使用して、既存の行の重複を排除します。

• Sort column

• 更新された行を識別する列を選択します。 Unique keyとともに、このフィールドにより、Workatoは既存および更新済みrowsのdeduplicateに使用する列を識別できます。

• 出力フィールド

• クエリで返される列を定義します。 出力をダウンストリームアプリケーションでデータピルとして使用できます。

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

• 任意。 新しいイベントを確認する頻度。 空白のままにした場合、デフォルトは5分です。 最小値：5分。 ポーリング間隔の詳細はこちら。