如何在结构化流数据帧中获取当前行的前几行
How to get the former few rows of current row in structured streaming dataframe
我想获取当前行之前的几行,但是,首先,在结构化数据流中不支持之间的行。
使用groupByKey和flatMapGroupsWithState可以达到目的
我想获取当前行之前的几行,但是,首先,在结构化数据流中不支持之间的行。
使用groupByKey和flatMapGroupsWithState可以达到目的