Spark-Streaming Integration Scala API Reference