()
| 130 | } |
| 131 | |
| 132 | public OnLineStatistics call() throws Exception |
| 133 | { |
| 134 | OnLineStatistics stats = new OnLineStatistics(); |
| 135 | while(true) |
| 136 | { |
| 137 | DataPoint dp = queue.take(); |
| 138 | |
| 139 | if(dp.numNumericalValues() == 0 && dp.numCategoricalValues() == 0) |
| 140 | break;//Posion value, nonsense data point used to signal end |
| 141 | stats.add(vc.search(dp.getNumericalValues(), minPts+1).get(minPts).getPair()); |
| 142 | } |
| 143 | return stats; |
| 144 | } |
| 145 | |
| 146 | } |
| 147 |
nothing calls this directly
no test coverage detected