Stateless transformations

Stateless transformations transform one DStream to another by applying transformations to each of the RDDs within the DStream. Transformations such as map(), flatMap(), union(), join(), and reduceByKey are all examples of stateless transformations.

Shown in the following is an illustration showing a map() transformation on inputDStream to generate a new mapDstream:

..................Content has been hidden....................

You can't read the all page of ebook, please click here login for view all page.
Reset
3.149.253.239