Added support for c8cep cursor #64
Open
Conversation
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
added 11 commits
May 26, 2022 21:36
ghost
requested review from
grainier-macrometa
and removed request for
yehan-macrometa
grainier-macrometa
approved these changes
May 30, 2022
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
This PR contains changes required to fix CEP-216.
Motivation :
Currently , the c8cep uses the restql APIs to create cursor, which does not support ttl and batch-size. We need a way to implement cursor so that the cursor remains active until all records are fetched from the source.
Solution:
Added an overloaded method for query() present in C8Database.java class, which internally calls the cursor API (which supports ttl and batch-size) to handle the request from c8cep.