This repository contains code for custom NiFi processor which
-
reads contents of each flow file as a string
-
splits string by space
-
counts occurrance of each word
-
for each word-count pair outputs one flow file.
This repository contains code for word count using custom NiFi processor.
Scala
This repository contains code for custom NiFi processor which
reads contents of each flow file as a string
splits string by space
counts occurrance of each word
for each word-count pair outputs one flow file.