- Task which collects input data from different sources
- Spark allocates a receiver for each input source
- Special task that run on the executors
Note
- Task run within executors
- Collect data from input source and save them as RDDs in memory, so that spark can replicate the collected data to another executor for fault tolerance
- If we have 2 sources then 2 exectors would be assigned for the streaming data
No comments:
Post a Comment