Indirectly access rounding functions by wrapping data as a Series or CFTimeIndex Parameters ---------- values : np.ndarray or dask.array-like Array-like container of datetime-like values name : {"ceil", "floor", "round"} Name of rounding function freq : str
(values, name, freq)
| 168 | |
| 169 | |
| 170 | def _round_field(values, name, freq): |
| 171 | """Indirectly access rounding functions by wrapping data |
| 172 | as a Series or CFTimeIndex |
| 173 | |
| 174 | Parameters |
| 175 | ---------- |
| 176 | values : np.ndarray or dask.array-like |
| 177 | Array-like container of datetime-like values |
| 178 | name : {"ceil", "floor", "round"} |
| 179 | Name of rounding function |
| 180 | freq : str |
| 181 | a freq string indicating the rounding resolution |
| 182 | |
| 183 | Returns |
| 184 | ------- |
| 185 | rounded timestamps : same type as values |
| 186 | Array-like of datetime fields accessed for each element in values |
| 187 | |
| 188 | """ |
| 189 | if is_duck_dask_array(values): |
| 190 | from dask.array import map_blocks |
| 191 | |
| 192 | dtype = np.datetime64 if is_np_datetime_like(values.dtype) else np.dtype("O") |
| 193 | return map_blocks( |
| 194 | _round_through_series_or_index, values, name, freq=freq, dtype=dtype |
| 195 | ) |
| 196 | else: |
| 197 | return _round_through_series_or_index(values, name, freq) |
| 198 | |
| 199 | |
| 200 | def _strftime_through_cftimeindex(values, date_format: str): |
no test coverage detected
searching dependent graphs…