| 246 | """ |
| 247 | from .algorithms import global_func |
| 248 | class MinImpl: |
| 249 | def op(self): |
| 250 | return algs.min |
| 251 | |
| 252 | def mpi_op(self): |
| 253 | from mpi4py import MPI |
| 254 | return MPI.MIN |
| 255 | |
| 256 | def serial_composite(self, array, axis): |
| 257 | res = _apply_func2(algs.min, array, (axis,)) |
| 258 | clean_list = [] |
| 259 | for a in res: |
| 260 | if a is not dsa.NoneArray: |
| 261 | clean_list.append(a) |
| 262 | if clean_list is []: |
| 263 | return None |
| 264 | return algs.min(clean_list, axis=0).astype(numpy.float64) |
| 265 | |
| 266 | def default(self): |
| 267 | return numpy.finfo(numpy.float64).max |
| 268 | |
| 269 | return global_func(MinImpl(), array, axis, controller) |
| 270 | |