аю какую-то обработку в spark и хочу реализовать функциональность, которая независимо от выполняемой обработки, я хочу запланировать таймер (с интервалом в 5 минут), который сохранит некоторые данные в Cassandra (или, скажем, любой другой источник)

Чтобы сделать его более легким для понимания, это может звучать как две задачи, выполняющиеся параллельно, одна отслеживает 5-минутный интервал, который будет записывать в Cassandra, а другая выполняет всю обработку, которую я велел выполнить.

Это похоже на то, как я выполняю обработку потоковых данных, а затем я кэшировал выходные данные этой обработки в spark как временную таблицу, и эта кэшированная таблица снова используется где-то в сценарии spark, но только через некоторое время я хочу сохранить его в Cassandra.

Любая помощь приветствуется