スパークストリーミング時のベースデータの更新

Question

私のシナリオでは、データaはスパークストリーミングを使用してリアルタイムでkafkaから読み込まれます。累積されたT + 1データであるrdbms（MySQLなど）からのデータAに基づいて、計算が行われ、結果= A + aとなります。 次の蓄積データはBです。計算は結果= B + a

私の質問はどのようにrdbmsからのT + 1データに基づいてデータを合計できますか？

ありがとうございます！

Answer 1

最後に、赤目を使用して解決しました。毎日rdbmsからデータをインポートし、redisでデータを更新し、毎日の終わりにrdbms結果テーブルにデータをエクスポートします。この質問を閉じる、ありがとう。