What are the output operations that can be performed on DStreams?
Options
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
06-25-2021 07:01 AM
Options
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
06-25-2021 07:02 AM
Output operations on DStreams pushes the DStream's data to external systems like a database or a file system. Following are the key operations that can be performed on DStreams.
saveAsTextFiles() - Saves the DStream's data as text file.
saveAsObjectFiles() - Saves the DStreams data as serialized Java objects.
saveAsHadoopFiles() - Saves the DStream's data as Hadoop files.
foreachRDD() - A generic output operator that applies a function, func, to each RDD generated from the DStream.