多应用+插件架构,代码干净,二开方便,首家独创一键云编译技术,文档视频完善,免费商用码云13.8K 广告
输出操作允许将 DStream 的数据推送到外部系统,如数据库或文件系统。 <br/> **print():** 在运行流应用程序的驱动节点上打印 DStream 中每批数据的前十个元素。这对于开发和调试非常有用。 **saveAsTextFiles(prefix, [suffix]):** 将 DStream 的内容保存为文本文件。每个批处理间隔的文件名是根据前缀和后缀`prefix-TIME_IN_MS[.suffix]`生成的。 **saveAsObjectFiles(prefix, [suffix]):** 将这个 DStream 的内容保存为序列化的 Java 对象的序列文件。 **saveAsHadoopFiles(prefix, [suffix]):** 将 DStream 的内容保存为 Hadoop 文件。 **foreachRDD(func):** 将函数 func 应用于从流生成的每个 RDD,这是最通用的输出操作。该函数应该将每个 RDD 中的数据推送到外部系统,例如将 RDD 保存到文件中,或者通过网络将其写入数据库。请注意,func函数是在运行流应用程序的驱动程序进程中执行的,并且通常会有 RDD actions,这将强制进行流 RDDs 的计算。