1

INPUT PostgreSQL テーブルの変更によってトリガーされる Spark 構造化ストリーミング計算によってOUTPUT TABLEの状態を更新する方法は?

実際のシナリオの USERS テーブルは によって更新されましたuser_id = 0002。そのユーザーのみに対して Spark 計算をトリガーし、結果を別のテーブルに書き込み/更新するにはどうすればよいですか?

4

1 に答える 1