caskdata/cdap — pull request #886 by chtyim (2014-12-23 23:37:27+00:00)
Title: (CDAP-1088) Added support for String type as StreamEventDecoder

In MR and Spark it can consume stream body as String object.

Also reorganize the code in StreamInputFormat a bit to make code easier to read.
And also remove the need of Flow in the SparkKMeans test to speed up test.