What is DStream?
What are the input sources Dstreams can be created?
Flume/Kafka/HDFS/S3/Kinesis
Operations on DStream?
Transformation
O/P operation
What are the special operations Dstream provide?
Sliding Windows
Why does Spark needs Checkpointing?
Will data get lost if the application is restarted?
https://github.com/mkuthan Windowing Implicit Functions
Page183- Viknesh
What is DStream? What are the input sources Dstreams can be created? Flume/Kafka/HDFS/S3/Kinesis Operations on DStream? Transformation O/P operation What are the special operations Dstream provide? Sliding Windows Why does Spark needs Checkpointing? Will data get lost if the application is restarted?