python from pyspark import SparkContext from pyspark.streaming import StreamingContext sc = SparkContext(appName="PySparkStreamingExample") count = filtered_lines.count() count.pprint() ssc.start() ssc.awaitTermination()