1 year ago

#220437

test-img

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

Accepted video resources