I am fetching data from table for employees and each employees has maximum 7 Records. I am splitting data based on the IDs and week number column. I need to merge the data in such a way that each flow file contains 100 records and all the records of each employees comes into that flow file for example My flow file already has 98 records and next employee has 7 records so, that employee's data should not be the part of that flow file. It should come in next flow file likewise.....  While merging the FFs order is also important. How can I do that. I am not familiar with all the processors of NiFi ... View more

I am getting below input flow file:   Input: [ { "original" : { "Id" : "100008", "Date" : "2022-09-22" }, "enrichment" : { "Record" : "Record 11", "Description" : "Invalid values for Id or Date" } }, { "original" : { "Id" : "100009", "Date" : "2022-09-02" }, "enrichment" : { "Record" : "Record 2", "Description" : "Invalid values for Id or Date" } } ]   Expected output: [ { "original" : { "Id" : "100009", "Date" : "2022-09-02" }, "enrichment" : { "Record" : "Record 2", "Description" : "Invalid values for Id or Date" } } ]   and Output I am getting is the below using Groovy script: [ "{\"original\":{\"Id\":\"100009\",\"Date\":\"2022-09-02\"},\"enrichment\":{\"Record\":\"Record 2\",\"Description\":\"Invalid values for Id or Date\"}}" ]     Groovy Script: import org.apache.commons.io.IOUtils import java.nio.charset.StandardCharsets import groovy.json.* import java.util.ArrayList def flowFile = session.get() if(!flowFile) return try { flowFile = session.write(flowFile, { inputStream, outputStream -> def text = IOUtils.toString(inputStream, StandardCharsets.UTF_8) def obj = new JsonSlurper().parseText(text) def final1 = [] int j = obj.text.size() for (int i=0;i<j;i++){ index = i+1 def rec = 'Record ' + index if (rec in obj.enrichment.Record){ final1.add(JsonOutput.toJson(obj[i])) } } response1 = JsonOutput.toJson(final1) outputStream.write(response1.getBytes(StandardCharsets.UTF_8)) } as StreamCallback) session.transfer(flowFile, REL_SUCCESS) } catch(Exception e) { log.error('Error during JSON operations', e) session.transfer(flowFile, REL_FAILURE) }     Can you please help to can I get the formatted array of json output of this groovy Script. I am new to groovy ... View more