Writing a custom NiFi Processor

One of my previous posts about NiFi dealt with POSTing dynamically built JSON. Looking at it in retrospect, I realised there was space for improvement and ended up writing a custom processor. The result is not as feature rich as NiFi’s out-of-the-box counterparts InvokeHTTP and PostHTTP. However, my implementation incorporates request body definition including the support of expression language….

| |

JaCoCo beats Cobertura when it comes to Java 8 support

I’ve recently reached out for Cobertura to add test coverage reporting to one of my project. One of the first challenges I’ve face was integrating the plugin into a project powered by Gradle. Turns out there is a Gradle version of the plugin available (credit: Steve Saliman). https://gist.github.com/zezutom/8526e229a4ab01d7a69f The problem I was unable to work around when using Cobertura was…

Count characters in a piece of text as a one-liner using Java 8 Streaming API

A WordCount app is arguably the most commonly used example of the MapReduce principle – see Hadoop or Spark tutorials. I wanted to do a similar thing in plain old Java as “a one-liner” (kind of). My objective was to explore the power and expressiveness of the Streaming API and Lambda expressions. Here is what I wanted to achieve: Input:…