I am creating a custom processor and was attempting to support batching. >From reading the code for the standard nifi processor it seems like all I have to do is:
final List<FlowFile> flowFileBatch = session.get(50); Is this correct? The documentation states "If this annotation is present, the user will be able to choose whether they prefer high throughput or lower latency in the Processor’s Scheduling tab. " I pulled in the EvaluateXQuery processor and I do not see where that is set. Is that feature not currently enabled? Also if I decided not to all batching in the scheduling tab what would happen in the processor when i do session.get(50), will it really only get 1 flow file or would it always get 50? Thanks for the help ahead of time.
