Интересно, можно ли во Flink разделить состояние между операторами.
Скажем, например, что у меня есть разделение по ключу на операторе, и мне нужен фрагмент состояния раздела A внутри раздела C (по любой причине) (рис. 1.a), или мне нужно состояние оператора C в последующем операторе F (рис 1.b).
Я знаю, что можно broadcast записей во все разделы. Итак, если вы включите внутреннее состояние оператора в записи, вы можете поделиться своим внутренним состоянием с последующими операторами.
Однако это может быть дорогостоящей операцией, вместо того, чтобы просто позволить op1 специально запрашивать op2 состояние.
Двигаются ли последние разработки в области запрашиваемого состояния в сторону этой концепции или они предназначены только для того, чтобы позволить внешнему пользователю запрашивать внутреннее состояние топологии?
Заранее благодарим вас за понимание
