В потоке с ключами я хотел бы вычислить функцию окна один раз на новое входящее событие сразу же после поступления нового события, предоставив ему контекст всех предыдущих событий этого ключа из после
Когда я прочитал из hbase, используя richfatMapFunction внутри карты, я получаю ошибку сериализации. То, что я пытаюсь сделать, - это если поток данных равен определенной строке, прочитанной из hbase
Мой вопрос в отношении рамки Apache Flink. Есть ли способ поддержать несколько потоков, таких как kafka и twitter, в одной работе с flink? Есть ли какая-нибудь работа. Можем ли мы обрабатывать несколь