Interested to Buy Any Domain ? << Click Here >> for more details...
Explain different transformations in DStream in Apache Spark Streaming?
- 1 Answers
- 346 Views
- I also Faced
- E-Mail Answers
Answer Posted / Awanish Kumar Dwivedi
{"transformations":[n "map": maps each element of a DStream to a new value using a user-defined function.n "filter": selects and returns elements from the input DStream based on a given condition.n "reduceByKey": aggregates values associated with the same key across partitions.n "join": combines two DStreams or a DStream and an RDD on a common key.n "updateStateByKey": updates an accumulator value associated with each key in a DStream.n ]}
| Is This Answer Correct ? | 0 Yes | 0 No |
Post New Answer View All Answers
