Hello @mburgess ,    If you have an input string but don't know what the value might be, e.g. it could be "8" or "8.4", and want to convert this into an int. Is there a way you can convert the "8" to an 8 and the "8.4" to an 8.4 float? Currently I am only able to convert both to ints as 8, or both to floats as 8.0, and 8.4.    For context, I am using a ValidateRecord to validate the number is an int, so would not like float values to be validated. This means that if an input is converted from a string into a number, I would like to know whether it is a decimal or integer.    Are you able to please assist?    Many thanks! ... View more

Hi @mburgess I tried the solution but it is not working for other JSON paths like $.key I tried multiple JSON paths but seems like it only works for $.cells.year. Please let me know your thoughts. I followed the exact steps you provided. ... View more

@mburgess  Matt, thank you so much for your quick response and help. It took me some time to figure out what you meant... but it works like a charm!   If anyone can use the solution, here it is: //====================================================================================================== // TEST java LocalDate.parse with groovy max-function // FF-Attribute RESPONSE contains [{"id":"(1208)", "datbis":"20180219" }, { "id":"(1210)", "datbis":"20191231" }, { "id":"(1212)", "datbis":"20200128" }] // FF-Atribute MAX_datbis returns 20200128 //====================================================================================================== import java.time.LocalDate def flowFile = session.get() if(!flowFile) return try { def objList = new groovy.json.JsonSlurper().parseText(flowFile.getAttribute('RESPONSE')) def max = objList.max {LocalDate.parse(it.datbis,"yyyyMMdd")} flowFile = session.putAttribute(flowFile, 'MAX_datbis', max.datbis.toString()) session.transfer(flowFile, REL_SUCCESS) } catch(e) { log.error("Error while determining max", e) session.transfer(flowFile, REL_FAILURE) } ... View more

Hi, i am trying to get an ArrayList as an output of the ExecuteStreamCommand Processor using Java  but I am neither getting it in the output destination attribute nor anything in the execution.status. I tried testing it with assigning an Integer too but did not work.Can you tell me if I am missing something here. ... View more

I did explore the way to hash and dynamically can extract data as csv or avro as default by developing a custom processor. You can download the processor from HERE. The full source code is shared from here, feel free to contribute for further functionalities. https://github.com/vanducng/hashing-columns-nifi-processor   ... View more

Hi @mburgess    I tried adding attribute name “auth” in Attributes to Send property and had this “auth” as a custom property in my invokeHTTP processor with value 'Authorization: Bearer ${access_token}' where the value of variable access_token gets populated from EvaluateJsonPath processor in front of my invokeHTTP, but somehow I am still getting unauthorized as the response. Is there anything else that I’m missing for token to get passed on as a header in this call? ... View more

After we load over 100 million notes in HBase, I will be using Nifi to listening to a live HL7 feed to keep the data current.  Some of these HL7 message are delete message and the rows need to be removed from HBase.   ... View more

@mburgess  I have a csv file which might have corrupt data as well. How can I still insert the correct data and collect the corrupted data in seperate flow?   ... View more

Thank you for the response. This was the correct answer, but I was unable to verify until recently.  ... View more