queueStream
StreamingContext JavaStreamingContext