Пользовательский источник Flink, запланированный на каждый час
#scala #apache-flink #flink-streaming Вопрос: Я пытаюсь создать пользовательский источник, который может работать только с определенным интервалом, например, 1 час опроса по протоколу http.Есть ли какой-либо способ использовать запланированного исполнителя внутри…