NiFi How to query Content Repository from NiFi Flow

Question

I have a use case where I need to use FlowFile from another flow.

As I know all flowfiles are saved into Content Repository.

So, for example, my first flow reads data from DB, performs some transformations and puts in to Hive.

My second flow needs to get those transformed flowfiles and put them to another place or perform some filtering, etc.

How can I get those flowfiles from content repo in NiFi flow?

Answer 1

You are mistaken, the content of the flow files is saved into the Content Repository. You don't need to query the Content Repository to use those FlowFiles.. I assume that you are using PutHiveQL, so just use the success relationship for your next flow.

Example: ExecuteSQL ->(success) Transform Process Group ->(output) PutHiveQL ->(success) -> Next Flow

Something like this: