我在一个表的lbb_diag_value列中有两条消息(‘usb_reset’,'onewire_cable')。我使用的两个列是:created_at(带时间戳)、lbb_diag_value 问题:我想为所有连续的usb_port_reset消息关联one_wire_cable,直到在表中找到另一个one_wire_cableusb_port_reset Some Time usb_port_reset 当前解决方案:
pyspark是否支持窗口函数(例如first, last, lag, lead)?
例如,如何按一列分组并按另一列排序,然后按SparkSQL或数据框选择每个组的第一行(这就像窗口函数一样)?我发现pyspark.sql.functions类包含聚合函数first和last,但它们不能用于groupBy类。