Output Operations on DStreams
2017-04-28 17:41
218 查看
print():打印DStream中的前10行数据
saveAsTextFiles(prefix, [suffix]):保存成文本文件到prefix指定的目录下,后缀为suffix
saveAsObjectFiles(prefix, [suffix]) :保存DStream数据为 SequenceFiles 或者 serialized Java objects
saveAsHadoopFiles(prefix, [suffix]) :保存文件到hadoop上
foreachRDD(func):遍历DStream中的RDD
saveAsTextFiles(prefix, [suffix]):保存成文本文件到prefix指定的目录下,后缀为suffix
saveAsObjectFiles(prefix, [suffix]) :保存DStream数据为 SequenceFiles 或者 serialized Java objects
saveAsHadoopFiles(prefix, [suffix]) :保存文件到hadoop上
foreachRDD(func):遍历DStream中的RDD
相关文章推荐
- spark-streaming-[7]-Output Operations on DStreams-foreachRDD写Mysql
- output-operations-on-dstreams
- 11gR2 Preinstallation Operations On RHEL5.4 32bit Only
- Consistency model(The system supports a given model if operations on memory follow specific rules)
- Operations+on+word+vectors+-+v2
- 每次执行过程之前都要set serveroutput on 一下,否则dbms_output.put_line()无显示
- Silence output of return object in IRB console on windows
- 【Oracle问题集5】ORA-55622: DML, ALTER and CREATE UNIQUE INDEX operations are not allowed on table
- 关于链表的一些重要操作(Important operations on a Linked List)
- java io读书笔记(7) Closing Output Streams
- Design a stack with operations on middle element
- OpenCV - Operations on Arrays
- cat - concatenate files and print on the standard output
- 在编译时出现:/usr/bin/ld: final link failed: Nonrepresentable section on output解决方法
- Mixing two digital audio streams with on the fly Loudness Normalization by Logarithmic Dynamic Range
- [SQL Server]:backup, file manipulation operations changes on a database must be serialized.
- 安装sql2000: 出现 A previous program installation created pending file operations on the installation machine. You must restart the computer before running setup
- final link failed: Nonrepresentable section on output的解决办法
- Multithreading on iOS And Mac OS X Using NSOperations
- SyntaxError: Non-ASCII character '\xe5' in file H:\workspace\output\out\out.py on line 4, but no enc