@chauvin christophe You can use NiFi RestApi /processors/{id}/state/clear-requests call, to clear the state stored in the processor. We can make restapi call by using invokehttp processor (or) groovy script and triggered by using NiFi. ... View more

@vinay p Try with CountText,CalculateRecordStats processors will gives what you are looking for. To get one summary flowfile from 3 flowfiles then first you should merge 3 flowfilee into one by using MergeRecord/MergeContent processor then use CountText,CalculateRecordStats processors to get the summary of the flowfile. Then use PutEmail processor to send to send the flowfile as an attachment. ... View more

@Haijin Li Use hive Regex serde and your matching regex will be (.{22})(.{1})(.{12})(.*) (.{22}) -> 1st capture group for 22 characters (.{1}) -> 2nd for 1 character (.{12}) -> 3rd for 12 characters (.*) -> 4th capture group matches for rest of the row. ... View more

@Prathamesh H Instead of select count(*) use select count(<column_name>) from my_table;  this command will display number of rows in the hive-hbase table. - If the answer is helpful to resolve the issue, Click on Accept button below to close this thread.This will help other community users to find answers quickly :-). ... View more

@Patrick Hochstenbach You can use SplitJson processor to split the array($.*) into individual flowfile then split json processor adds fragment.count attribute to the flowfile which is array size. Use UpdateAttribute processor to change the attribute name. Use MergeContent processor to merge back the content using Defragment strategy. ... View more

@OS FetchFile processor accepts incoming connections but we need to pass fully qualified filename to this processor to fetch files from the directory. To get fully qualified filename we need to use ExecuteStreamCommand processor to run shell commands. Refer to this link i have given in detailed answer how to get fully qualified name in middle of the flow. Let us know if you have any issues..!! ... View more

@OS Yes its possible starting from NiFi-1.7, introduced DatabasePoolLookup. Please refer to this answer as i have answered for similar thread. ... View more