Singh3y
Singh3y

Reputation: 381

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?

Upvotes: 1

Views: 192

Answers (0)

Related Questions