Assume say JavaWord count
I call the equivalent of a Mapper
JavaPairRDD ones = words.mapToPair(,,,
Now right here I want to guarantee that each word starting with a
particular letter is processed in a specific partition - (Don't tell me
this is a dumb idea - I know that but in a Hadoop code a cus
Assume say JavaWord count
I call the equivalent of a Mapper
JavaPairRDD ones = words.mapToPair(,,,
Now right here I want to guarantee that each word starting with a
particular letter is processed in a specific partition - (Don't tell me
this is a dumb idea - I know that but in a Hadoop code a cus