print():打印DStream中的前10行数据

saveAsTextFiles(prefix, [suffix]):保存成文本文件到prefix指定的目录下,后缀为suffix

saveAsObjectFiles(prefix, [suffix]) :保存DStream数据为 SequenceFiles 或者 serialized Java objects

saveAsHadoopFiles(prefix, [suffix]) :保存文件到hadoop上

foreachRDD(func):遍历DStream中的RDD

相关文章:

  • 2021-06-06
  • 2021-07-11
  • 2021-10-11
  • 2021-05-03
  • 2021-11-03
  • 2022-02-24
  • 2021-12-10
  • 2021-10-24
猜你喜欢
  • 2021-09-04
  • 2022-01-29
  • 2022-03-09
  • 2021-09-17
  • 2021-08-29
  • 2021-06-17
相关资源
相似解决方案