Update attributes based on content in NiFi

java apache-nifi
Lasitha Yapa picture Lasitha Yapa · Aug 12, 2016 · Viewed 14.5k times · Source

How can I add a attribute to the current flow file when developing an Apache NiFi cusom processor.
What I want to do is adding a new attribute (or at least update a current attribute) to the current flow file with calculated value.
Or is there an already built processor that I can use?

Answer

James picture James · Aug 12, 2016

NiFi supports several methods of creating and updating attributes, depending on the data source you wish to use. Some general purpose processors include:

UpdateAttribute - Updates attributes on flow files using both static values and NiFi's expression language.

enter image description here

You can add as many properties with one processor. I recommend scanning through the Apache NiFi Expression Language Guide to get a feel for what you can do with it.

ExtractText - The Sets attribute values by applying regular expressions to the flowfile content.

ExecuteScript - ExecuteScript Runs custom script code, which can be used to update attributes however you wish.

And there are more for particular content formats, for example:

Related questions

How do I convert a String to an int in Java?

How can I convert a String to an int in Java? My String contains only numbers, and I want to return the number it represents. For example, given the string "1234" the result should be the number 1234.

Read More
How do I declare and initialize an array in Java?

How do I declare and initialize an array in Java?

Read More
How do I generate random integers within a specific range in Java?

How do I generate a random int value in a specific range? I have tried the following, but those do not work: Attempt 1: randomNum = minimum + (int)(Math.random() * maximum); // Bug: `randomNum` can be bigger than `maximum`. Attempt 2: Random rn = new …

Read More