NIFI-15254 Add Cassandra Processors into NiFi 2.x Version.#10773
NIFI-15254 Add Cassandra Processors into NiFi 2.x Version.#10773vishal-firgan-ksolves wants to merge 2 commits intoapache:mainfrom
Conversation
exceptionfactory
left a comment
There was a problem hiding this comment.
Thanks for putting together this updated version of Cassandra components @vishal-firgan-ksolves.
It is great to have the upgrade to the latest client driver version included.
A recent attempt to reintroduce Cassandra support stalled, but includes some important feedback about additional changes needed. In particular, a number of important implementation conventions need to be addressed before this can be considered for inclusion. I have not reviewed this code in detail, but it looks like most of the following issues mentioned in this comment also need to be addressed in this pull request:
If you are willing to put in the time to work through these issues, then this has the opportunity go forward.
exceptionfactory
left a comment
There was a problem hiding this comment.
Also for the purpose of efficient review, I recommend breaking this pull request into multiple parts. Specifically, starting with only the QueryCassandra Processor would allow us to get the core interface and conventional details addressed. Once that is reviewed and merged, the PutCassandra Processors could be considered. This is not a hard requirement, but it more components will require more review time.
|
Thank you for the feedback @exceptionfactory and for pointing me to the relevant review. I will work through these suggestions and update the code to align with NiFi’s current conventions. I'll let you know once the changes are ready for another look. |
|
@exceptionfactory I’ve pushed a new commit that takes care of all the review and convention updates. Since the processors share a common abstract base class and a few tests are used across multiple processors, splitting the PR right now would likely create duplication and inconsistencies. |
|
Hii @exceptionfactory , I'm just following up to see if you've had a moment to look at the latest commits. I've finished the requested convention updates and addressed the previous feedback. Looking forward to your thoughts when you have a chance! Thanks! |
|
Thanks for the updates @vishal-firgan-ksolves, I will look to review this again soon. |
Summary
This PR introduces Cassandra processor support for Apache NiFi 2.x, enabling Cassandra integration aligned with the latest DataStax Java driver.
NIFI-15254
Enhancements over NiFi 1.28:
UUID,TIMEUUID,DATE,TIME,TIMESTAMP,DECIMAL,VARINT, etc.Tracking
Please complete the following tracking steps prior to pull request creation.
Issue Tracking
Pull Request Tracking
NIFI-00000NIFI-00000VerifiedstatusPull Request Formatting
mainbranchVerification
Please indicate the verification steps performed prior to pull request creation.
Build
./mvnw clean install -P contrib-checkLicensing
LICENSEandNOTICEfilesDocumentation