调用输出运算符时,它将触发流的计算。
如果在DStream上没有输出运算符,则不会调用任何计算。基本上,您将需要在流上调用以下任何方法
print()foreachRDD(func)saveAsObjectFiles(prefix, [suffix])saveAsTextFiles(prefix, [suffix])saveAsHadoopFiles(prefix, [suffix])
http://spark.apache.org/docs/latest/streaming-programming-guide.html#output-
operations
您还可以先应用任何转换,然后再根据需要输出函数。



