Я пытаюсь отобразить данные за каждый ip источника, а затем построить все кривые на одном и том же рисунке.Так что я могу сравнить их.
sqlContext.registerDataFrameAsTable(btd, "Packets_EB")
df1 = sqlContext.sql("SELECT wpan_wpan_src64, wpan_tsch_time_sync_wpan_tsch_asn, frame_frame_time from Packets_EB where wpan_tsch_time_sync_wpan_tsch_asn is not NULL order by wpan_wpan_src64 ")
df1.collect()
Это пример моих данных:
[Row(wpan_wpan_src64='14:15:92:cc:00:00:00:01', wpan_tsch_time_sync_wpan_tsch_asn='707', frame_frame_time='Oct 9, 2018 09:55:48.441610333 CEST'),
Row(wpan_wpan_src64='14:15:92:cc:00:00:00:01', wpan_tsch_time_sync_wpan_tsch_asn='1212', frame_frame_time='Oct 9, 2018 09:55:52.314076465 CEST'),
Row(wpan_wpan_src64='14:15:92:cc:00:00:00:02', wpan_tsch_time_sync_wpan_tsch_asn='1616', frame_frame_time='Oct 9, 2018 09:55:55.578094951 CEST'),
Row(wpan_wpan_src64='14:15:92:cc:00:00:00:01', wpan_tsch_time_sync_wpan_tsch_asn='1818', frame_frame_time='Oct 9, 2018 09:55:57.167274612 CEST'),
.....
Итак, у меня две проблемы: я не могу выбрать данные для каждого source_ip, а затем построить все мои кривые втакая же цифра?