Spark-Streaming Integration API