pyspark.streaming.StreamingContext.queueStream ============================================== .. currentmodule:: pyspark.streaming .. automethod:: StreamingContext.queueStream