/nifi-word-count-custom-processor

This repository contains code for word count using custom NiFi processor.

Primary LanguageScala

This repository contains code for custom NiFi processor which

  1. reads contents of each flow file as a string

  2. splits string by space

  3. counts occurrance of each word

  4. for each word-count pair outputs one flow file.