In [27]: top_5_train_elec = train_elec.submeters().select_top_k(k=5)
1/16 ElecMeter(instance=5, building=1, dataset='REDD', appliances=[Appliance(type='fridge', instance=1)])---------------------------------------------------------------------------
TypeError Traceback (most recent call last)
in ()
----> 1 top_5_train_elec = train_elec.submeters().select_top_k(k=5)
/root/nilmtk/nilmtk/metergroup.pyc in select_top_k(self, k, by, asc, group_remainder, **kwargs)
1297 """
1298 function_map = {'energy': self.fraction_per_meter, 'entropy': self.entropy_per_meter}
-> 1299 top_k_series = function_mapby
1300 top_k_series.sort(ascending=asc)
1301 top_k_elec_meter_ids = top_k_series[:k].index
/root/nilmtk/nilmtk/metergroup.pyc in fraction_per_meter(self, **load_kwargs)
1176 Each value is a float in the range [0,1].
1177 """
-> 1178 energy_per_meter = self.energy_per_meter(**load_kwargs).max()
1179 total_energy = energy_per_meter.sum()
1180 return energy_per_meter / total_energy
/root/nilmtk/nilmtk/metergroup.pyc in energy_per_meter(self, per_period, mains, use_meter_labels, **load_kwargs)
1124 stdout.flush()
1125 if per_period is None:
-> 1126 meter_energy = meter.total_energy(**load_kwargs)
1127 else:
1128 load_kwargs.setdefault('use_uptime', False)
/root/nilmtk/nilmtk/elecmeter.pyc in total_energy(self, *_loader_kwargs)
591 nodes = [Clip, TotalEnergy]
592 return self._get_stat_from_cache_or_compute(
--> 593 nodes, TotalEnergy.results_class(), loader_kwargs)
594
595 def dropout_rate(self, ignore_gaps=True, *_loader_kwargs):
/root/nilmtk/nilmtk/elecmeter.pyc in _get_stat_from_cache_or_compute(self, nodes, results_obj, loader_kwargs)
684 if loader_kwargs.get('preprocessing') is None:
685 cached_stat = self.get_cached_stat(key_for_cached_stat)
--> 686 results_obj.import_from_cache(cached_stat, sections)
687
688 def find_sections_to_compute():
/root/nilmtk/nilmtk/results.pyc in import_from_cache(self, cached_stat, sections)
161 else:
162 if isinstance(rows_matching_start, pd.Series):
--> 163 append_row(rows_matching_start, section)
164 else:
165 for row_i in range(rows_matching_start.shape[0]):
/root/nilmtk/nilmtk/results.pyc in append_row(row, section)
148 # so now we must put the timezone back.
149 row['end'] = tz_localize_naive(row['end'], tz)
--> 150 if row['end'] == section.end:
151 usable_sections_from_cache.append(row)
152
pandas/tslib.pyx in pandas.tslib._Timestamp.richcmp (pandas/tslib.c:18004)()
pandas/tslib.pyx in pandas.tslib._Timestamp._assert_tzawareness_compat (pandas/tslib.c:18384)()
TypeError: Cannot compare tz-naive and tz-aware timestamps
In [27]: top_5_train_elec = train_elec.submeters().select_top_k(k=5)
1/16 ElecMeter(instance=5, building=1, dataset='REDD', appliances=[Appliance(type='fridge', instance=1)])---------------------------------------------------------------------------
TypeError Traceback (most recent call last)
in ()
----> 1 top_5_train_elec = train_elec.submeters().select_top_k(k=5)
/root/nilmtk/nilmtk/metergroup.pyc in select_top_k(self, k, by, asc, group_remainder, **kwargs)
1297 """
1298 function_map = {'energy': self.fraction_per_meter, 'entropy': self.entropy_per_meter}
-> 1299 top_k_series = function_mapby
1300 top_k_series.sort(ascending=asc)
1301 top_k_elec_meter_ids = top_k_series[:k].index
/root/nilmtk/nilmtk/metergroup.pyc in fraction_per_meter(self, **load_kwargs)
1176 Each value is a float in the range [0,1].
1177 """
-> 1178 energy_per_meter = self.energy_per_meter(**load_kwargs).max()
1179 total_energy = energy_per_meter.sum()
1180 return energy_per_meter / total_energy
/root/nilmtk/nilmtk/metergroup.pyc in energy_per_meter(self, per_period, mains, use_meter_labels, **load_kwargs)
1124 stdout.flush()
1125 if per_period is None:
-> 1126 meter_energy = meter.total_energy(**load_kwargs)
1127 else:
1128 load_kwargs.setdefault('use_uptime', False)
/root/nilmtk/nilmtk/elecmeter.pyc in total_energy(self, *_loader_kwargs)
591 nodes = [Clip, TotalEnergy]
592 return self._get_stat_from_cache_or_compute(
--> 593 nodes, TotalEnergy.results_class(), loader_kwargs)
594
595 def dropout_rate(self, ignore_gaps=True, *_loader_kwargs):
/root/nilmtk/nilmtk/elecmeter.pyc in _get_stat_from_cache_or_compute(self, nodes, results_obj, loader_kwargs)
684 if loader_kwargs.get('preprocessing') is None:
685 cached_stat = self.get_cached_stat(key_for_cached_stat)
--> 686 results_obj.import_from_cache(cached_stat, sections)
687
688 def find_sections_to_compute():
/root/nilmtk/nilmtk/results.pyc in import_from_cache(self, cached_stat, sections)
161 else:
162 if isinstance(rows_matching_start, pd.Series):
--> 163 append_row(rows_matching_start, section)
164 else:
165 for row_i in range(rows_matching_start.shape[0]):
/root/nilmtk/nilmtk/results.pyc in append_row(row, section)
148 # so now we must put the timezone back.
149 row['end'] = tz_localize_naive(row['end'], tz)
--> 150 if row['end'] == section.end:
151 usable_sections_from_cache.append(row)
152
pandas/tslib.pyx in pandas.tslib._Timestamp.richcmp (pandas/tslib.c:18004)()
pandas/tslib.pyx in pandas.tslib._Timestamp._assert_tzawareness_compat (pandas/tslib.c:18384)()
TypeError: Cannot compare tz-naive and tz-aware timestamps