(int numSamples, int numReduceres)
| 128 | } |
| 129 | |
| 130 | private float getProbVecSum(int numSamples, int numReduceres) throws Exception { |
| 131 | DataBag samples = generateUniqueSamples(numSamples); |
| 132 | Map<String, Object> res = getFindQuantilesResult(samples, numReduceres); |
| 133 | |
| 134 | InternalMap weightedPartsData = (InternalMap) res.get(FindQuantiles.WEIGHTED_PARTS); |
| 135 | Iterator<Object> it = weightedPartsData.values().iterator(); |
| 136 | float[] probVec = getProbVec((Tuple)it.next()); |
| 137 | float sum = 0.0f; |
| 138 | for (float f : probVec) { |
| 139 | sum += f; |
| 140 | } |
| 141 | return sum; |
| 142 | } |
| 143 | |
| 144 | } |
no test coverage detected