CODEWITHSUNDEEP
hdfsapache-nifi
sriram
sriram

Reputation: 3

How can I send the write attribute of a NiFi processor to next processor?

I am using GetHDFSEvents processor to know hdfs.inotify.event.path. I need to get notified of the path when an new file is created in hdfs. How can I pass the attribute hdfs.inotify.event.path to the next processor to execute a shell script based on the path

Upvotes: 0

Views: 241

Answers (2)

EnthuDev
EnthuDev

Reputation: 170

Try using ListHDFS processor and use Fetchhdfs or ExecuteStream command processor. Use Expression language ${path}/${filename}

Upvotes: 0

maxime G
maxime G

Reputation: 1771

Use ListHDFS and path attribut instead of GetHDFS if you just want to be notified.

Upvotes: 1

Related Questions