NIFI-13402: Add ability for Python source and transform processors to output multiple FlowFiles - #11531
NIFI-13402: Add ability for Python source and transform processors to output multiple FlowFiles#11531mattyb149 wants to merge 1 commit into
Conversation
… output multiple FlowFiles
exceptionfactory
left a comment
There was a problem hiding this comment.
Although I appreciate the interest in pursuing these changes, I currently remain opposed to further extension of the Python Processor API to support this type of use case with multiple FlowFiles.
Python Processors have inherent scalability challenges due to the decoupled nature of the Python process itself, and the socket communication between Python processes and the JVM.
Extending the Python API introduces new maintenance concerns on top of the foundational issues.
I think it would be helpful to discuss this in Jira before proceeding with code changes, so I'm going to vote against this addition for now.
|
On a procedural note, as this has a direct relationship to public interfaces designed for extension, it should go through the NiFi Improvement Proposal process. That would also provide the opportunity for additional discussion before moving back to implementation. |
Summary
NIFI-13402 This PR adds 2 new interfaces, MultipleFlowFileSource and FlowFileTransformMultipleOutput, for source and transform processors to be able to output a collection of FlowFiles rather than a single FlowFile.
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