CDAP-953 moving classes around a little big and changing format
implementations to be over byte buffers instead of stream events
to be more generic.