-
Notifications
You must be signed in to change notification settings - Fork 556
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Move LastProcessedPositionState
to stream processor
#9801
Move LastProcessedPositionState
to stream processor
#9801
Conversation
The last processed position state is only used by the StreamProcessor. Therefore, it was moved into the streamprocessor package. The existing classes and interfaces were moved as is. There is probably a way to simplify this code, but this is something we can still do after the refactoring. In the tests, minimal effort was undertaken to make the tests pass. The test classes are very complex and ripe for an overhaul, but this would have increased the change set considerably
/cc @deepthidevaki relates to the discussion we had about separating the DB state between engine and non-engine |
|
||
streamProcessorDbState = new StreamProcessorDbState(zeebeDb, transactionContext); | ||
streamProcessorContext.lastProcessedPositionState( | ||
getStreamProcessorDbState().getLastProcessedPositionState()); |
Check notice
Code scanning / CodeQL
Deprecated method or constructor invocation
return factory.createProcessors(processingContext); | ||
})); | ||
|
||
lastProcessedPositionState = result.getStreamProcessorDbState().getLastProcessedPositionState(); |
Check notice
Code scanning / CodeQL
Deprecated method or constructor invocation
return factory.createProcessors(processingContext); | ||
})); | ||
|
||
lastProcessedPositionState = result.getStreamProcessorDbState().getLastProcessedPositionState(); |
Check notice
Code scanning / CodeQL
Deprecated method or constructor invocation
}), | ||
streamWriterFactory); | ||
|
||
lastProcessedPositionState = result.getStreamProcessorDbState().getLastProcessedPositionState(); |
Check notice
Code scanning / CodeQL
Deprecated method or constructor invocation
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
🚀
- 👍 Love seeing the state interface get smaller/split up
Just a small suggestion, mostly for future things.
engine/src/main/java/io/camunda/zeebe/streamprocessor/StreamProcessor.java
Show resolved
Hide resolved
bors merge |
9801: Move `LastProcessedPositionState` to stream processor r=pihme a=pihme ## Description The last processed position state is only used by the StreamProcessor. Therefore, it was moved into the streamprocessor package. The existing classes and interfaces were moved as is. There is probably a way to simplify this code, but this is something we can still do after the refactoring. In the tests, minimal effort was undertaken to make the tests pass. The test classes are very complex and ripe for an overhaul, but this would have increased the change set considerably. ## Related issues related to #9725 Co-authored-by: pihme <pihme@users.noreply.github.com>
Build failed: |
bors retry |
Build succeeded: |
Description
The last processed position state is only used by the StreamProcessor. Therefore, it
was moved into the streamprocessor package. The existing classes and interfaces were
moved as is. There is probably a way to simplify this code, but this is something we
can still do after the refactoring.
In the tests, minimal effort was undertaken to make the tests pass. The test classes
are very complex and ripe for an overhaul, but this would have increased the change
set considerably.
Related issues
related to #9725
Definition of Done
Not all items need to be done depending on the issue and the pull request.
Code changes:
backport stable/1.3
) to the PR, in case that fails you need to create backports manually.Testing:
Documentation:
Please refer to our review guidelines.