Add FunctionStreamProcessor to core

We don't have many stream processors. I have written a generic function stream processor, which essentially does the "map" in MapReduce, ie.

Function<Record, Optional<Record>>

Given an input Record apply a tranformation and optionally return a Record response

This greatly simplifies the implementation for this use case.