kotlin-spark-api_3.3.2_2.13/org.jetbrains.kotlinx.spark.api/KSparkStreamingSession/setRunAfterStart

setRunAfterStart

fun setRunAfterStart(block: KSparkStreamingSession.() -> Unit)

block will be run after the streaming session has started from a new context (so not when loading from a checkpoint) and before it's terminated.