streaming.core.compositor.spark.streaming.source.MockInputStreamCompositor", "params": [{ "batch-1":["1","2","3"], "batch
// html