Manipulate Spark-streaming by SQL