Apache Nifi Execute Process Processor

Question

I am trying to implement the workflow below using Apache Nifi:

1. ExecuteSQL - This is fetching data from oracle database in avro format
2. PutHDFS –This is to put the data into hdfs
3. ExecuteProcess – This processor executes a bash script in the background which in turn creates the external hive table

I have a few questions:

Does ExecuteProcess Processor in Apache Nifi takes incoming flow files?

I am not able to provide ExecuteProcess processor any incomming flow file. If not, is there any way to support taking incoming flow files?

Answer 1

Hey soujanyabargavi! 

NO, ExecuteProcess does not allow incoming flow files. You can use ExecuteStreamCommand instead. This processor accepts an incoming flowfile and can access attributes and content. You can find more about ExecuteStreamCommand here