createStreamingContext
ScalaJobContext