1 year ago
#220437
Singh3y
Flink MapState with remote functions
So, I'm trying to implement flink's mapState using remote functions. In the mapState I'll be storing around 1000 values mapped with one key. Can someone point me in direction to implement it for remote function. I've found the article with embedded functions https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/dev/datastream/fault-tolerance/state/.
Also, when I access it from remote function will my entire state be transferred in each request? If yes, is there any way this could be implemented to avoid this huge data transfer each time I request?
apache-flink
flink-statefun
0 Answers
Your Answer