Streaming clustering in Spark