|
7 | 7 | from pandas import DataFrame, Series
|
8 | 8 | from pandas.core.groupby.groupby import DataError
|
9 | 9 | from pandas.core.groupby.grouper import Grouper
|
10 |
| -from pandas.core.indexes.datetimes import date_range |
| 10 | +from pandas.core.indexes.datetimes import DatetimeIndex, date_range |
11 | 11 | from pandas.core.indexes.period import PeriodIndex, period_range
|
12 | 12 | from pandas.core.indexes.timedeltas import TimedeltaIndex, timedelta_range
|
13 | 13 | import pandas.util.testing as tm
|
@@ -274,3 +274,79 @@ def test_resample_quantile(series):
|
274 | 274 | result = s.resample(freq).quantile(q)
|
275 | 275 | expected = s.resample(freq).agg(lambda x: x.quantile(q)).rename(s.name)
|
276 | 276 | tm.assert_series_equal(result, expected)
|
| 277 | + |
| 278 | + |
| 279 | +@all_ts |
| 280 | +@pytest.mark.parametrize( |
| 281 | + "freq, result_name, result_data, result_index, result_freq", |
| 282 | + [ |
| 283 | + ( |
| 284 | + "D", |
| 285 | + "dti", |
| 286 | + [1.0] * 5 + [np.nan] * 5, |
| 287 | + ["2005-01-{}".format(i) for i in range(1, 11)], |
| 288 | + "D", |
| 289 | + ), |
| 290 | + ( |
| 291 | + "D", |
| 292 | + "pi", |
| 293 | + [1.0] * 5 + [np.nan] * 5, |
| 294 | + ["2005-01-{}".format(i) for i in range(1, 11)], |
| 295 | + "D", |
| 296 | + ), |
| 297 | + ( |
| 298 | + "D", |
| 299 | + "tdi", |
| 300 | + [1.0] * 5 + [np.nan] * 5, |
| 301 | + ["{} days".format(i) for i in range(1, 11)], |
| 302 | + "D", |
| 303 | + ), |
| 304 | + ( |
| 305 | + "W", |
| 306 | + "dti", |
| 307 | + [2.0, 3.0, np.nan], |
| 308 | + ["2005-01-02", "2005-01-09", "2005-01-16"], |
| 309 | + "W-SUN", |
| 310 | + ), |
| 311 | + ( |
| 312 | + "W", |
| 313 | + "pi", |
| 314 | + [2.0, 3.0, np.nan], |
| 315 | + ["2004-12-27/2005-01-02", "2005-01-03/2005-01-09", "2005-01-10/2005-01-16"], |
| 316 | + "W-SUN", |
| 317 | + ), |
| 318 | + ("W", "", "", "", ""), |
| 319 | + ("M", "dti", [5.0], ["2005-01-31"], "M"), |
| 320 | + ("M", "pi", [5.0], ["2005-01"], "M"), |
| 321 | + ("M", "", "", "", ""), |
| 322 | + ], |
| 323 | +) |
| 324 | +def test_resample_sum( |
| 325 | + series, freq, result_name, result_data, result_index, result_freq |
| 326 | +): |
| 327 | + # GH 19974 |
| 328 | + series[:5] = 1 |
| 329 | + series[5:] = np.nan |
| 330 | + |
| 331 | + if isinstance(series.index, TimedeltaIndex) and freq != "D": |
| 332 | + msg = ".* is a non-fixed frequency" |
| 333 | + with pytest.raises(ValueError, match=msg): |
| 334 | + result = series.resample(freq).sum(min_count=1) |
| 335 | + |
| 336 | + else: |
| 337 | + result = series.resample(freq).sum(min_count=1) |
| 338 | + |
| 339 | + if isinstance(series.index, DatetimeIndex) and result_name == "dti": |
| 340 | + index = DatetimeIndex(result_index, freq=result_freq) |
| 341 | + expected = Series(result_data, index, name=result_name) |
| 342 | + tm.assert_series_equal(result, expected) |
| 343 | + |
| 344 | + if isinstance(series.index, PeriodIndex) and result_name == "pi": |
| 345 | + index = PeriodIndex(result_index, freq=result_freq) |
| 346 | + expected = Series(result_data, index, name=result_name) |
| 347 | + tm.assert_series_equal(result, expected) |
| 348 | + |
| 349 | + if isinstance(series.index, TimedeltaIndex) and result_name == "tdi": |
| 350 | + index = TimedeltaIndex(result_index, freq=result_freq) |
| 351 | + expected = Series(result_data, index, name=result_name) |
| 352 | + tm.assert_series_equal(result, expected) |
0 commit comments