Added support for SparkRunner streaming stateful processing#33267

Merged

kennknowles merged 21 commits intoapache:masterfrom twosom:spark-streaming-stateful-pardo

Dec 18, 2024

+886-60

Commits on Nov 26, 2024

change SparkAndTimers as public class
twosom
committed
move getBatchDuration method from SparkGroupAlsoByWindowViaWindowSet to TranslationUtils
twosom
committed
move checkpointIfNeeded from SparkGroupAlsoByWindowViaWindowSet to TranslationUtils
twosom
committed

Commits on Nov 28, 2024

Commits on Dec 1, 2024

Commits on Dec 6, 2024

touch trigger files
twosom
committed

Commits on Dec 15, 2024

Merge branch 'master' into spark-streaming-stateful-pardo
twosom
authored

Commits on Dec 17, 2024

Merge branch 'master' into spark-streaming-stateful-pardo
twosom
authored