Я работаю с Spark Streaming, и у меня есть один уникальный источник ввода, который я использую для выполнения некоторых операций. Итак, мне нужно выполнить другие операции с тем же источником ввода через определенное время. Я ничего не нашел в документации, поэтому я хотел бы знать, знаете ли вы, как это сделать, и уважаете ли вы наилучшую практику.
Заранее спасибо