fransking opened a new pull request, #315: URL: https://github.com/apache/flink-statefun/pull/315
As per the JIRA in the Python SDK accessing a state variable multiple times in a single function invocation or multiple times in sequency when many function invocations are batched together is inefficient because the variable is deserialized and reserialized from/to protobuf multiple times. This change corrects that by lazily deserializing the typed_value into a backing value which is only reserialised at the end of the batch when mutations to the store are collected. It also means that considering... var1 = storage.a var2 = storage.a ...var1 and var2 are now reference equal - i.e. storage.a is reference equal to storage.a which was not previously the case but I think is better semantically where properties are concerned. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
