You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
We'd like to introduce a version of StateStoreCommitRequest that holds the transaction object either directly in the message, or with a pointer to S3.
This should let us simplify the flow of the state store committer lambda, and potentially avoid the need for StateStoreCommitter as a separate class. To apply this commit request we would pass it directly to the state store after deserialisation.
Analysis
The commit request could use the same model as the state store method added in the following issue:
We can use that directly in StateStoreCommitter for now, and anticipate removing most of the logic in that class such that it can be removed in the future.
We could include serialisation/deserialisation code that will be necessary for the following issue, or split it out:
Background
Split from:
Description
We'd like to introduce a version of StateStoreCommitRequest that holds the transaction object either directly in the message, or with a pointer to S3.
This should let us simplify the flow of the state store committer lambda, and potentially avoid the need for StateStoreCommitter as a separate class. To apply this commit request we would pass it directly to the state store after deserialisation.
Analysis
The commit request could use the same model as the state store method added in the following issue:
We can use that directly in StateStoreCommitter for now, and anticipate removing most of the logic in that class such that it can be removed in the future.
We could include serialisation/deserialisation code that will be necessary for the following issue, or split it out:
The text was updated successfully, but these errors were encountered: