Hello everyone, I have a question about the StateFutureUtils.toIterable() method. I'm working on a KeyedCoProcessFunction that needs access to all values in a MapState.
The StateFutureUtils.toIterable method seems to do exactly what I need: load all values from my MapState. However, in the documentation, I see this line: "There is no good reason to do so, since this may disable the capability of lazy loading. Only useful when the further calculation depends on the whole data from the iterator." My calculation does depend on all the data in the iterator. I need to collect an event that includes all elements in my MapState. However, I worried about the "disable the capability of lazy loading" part. Does this only mean that Flink will need to load all elements in my iterator, moving them from an async state to my local process function? Or is there something deeper that could happen here, resulting in lazy loading being further disabled? Thanks a lot, Francis
