scala - getting number of values within reduceByKey RDD -
When it's called Bike Operation, it's getting a list of the values of a particular key. My question is Is that Is that the list of values received in sequential order? Is it possible to know how much value he gets? I'm trying to calculate the quartile before the list of values of a key, is it possible to reduce bark? .1 No, it is against the whole situation of completely reducing the operation Going - that means taking advantage of co-operatives and commutitiates to parallel an operation in arbitrary tree of sub-operation. .2. You will need to define a new monoide by typing an integer monoide and whatever you have to do is assume that your operation is op . yourRdd.map (kv = & gt; (kv._1, (kv._2, 1)). ReduceByKey ((left, right) => (left ._1 op Right ._1, left._2 + right ._2)) You can get a RDD [(KiType, (ReducedValueType, Int))] where Int will be the number of values received for each key. .3. You have to be more specific about...