Stream Processing アプリケーション (Apache Flink または Apache Spark Streaming に基づく) では、データを一度だけ処理する必要がある場合があります。
データベースの世界では、ACID 基準に従うデータベースを使用することで同等のことが達成されます (ここで間違っている場合は訂正してください)。
ただし、ACID ではなく BASE に従っている (非リレーショナル) データベースは多数あります。
ここで私の質問は次のとおりです。このような BASE データベースをストリーム処理アプリケーションに統合する場合 (正確に 1 回)、パイプライン全体で正確に 1 回の処理を保証できますか? また、これが可能である場合、どのような状況で可能ですか?