Databricks - カスタムSQL（バッチ）トリガーによる新しい行の取得

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

カスタムSQL（バッチ）トリガーによる新しい行の取得

---

入力フィールド

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

• SQL

• カスタムSQLクエリを入力してください。このクエリは、新しい行を取得するために各ポーリング間隔で実行されます。Databricksは、SQL ANSI-92に準拠したSQLステートメントをサポートしています。[詳細を見る]。 ここで使用されるSQLは、出力データツリーを生成します。これを行うために、SQLは提供されたときに一度実行されます。

• ユニークキー

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

• 出力フィールド

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

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

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