Databricks - カスタムSQLを使用した新規行（バッチ）トリガー ​

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

カスタムSQLを使用した新規行（バッチ）トリガー

入力 ​

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

• SQL

• カスタムSQLクエリを入力します。 このクエリは各ポーリング間隔で実行され、新規行を取得します。 Databricksは、SQL ANSI-92に準拠したSQLステートメントをサポートしています。 [詳細はこちら]。 ここで使用するSQLは、出力データツリーを生成します。 これを行うために、SQLは指定時に1回実行されます。

• 一意キー

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

• 出力フィールド

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

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

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