主页 / coding / 问题 / 77607089
Accepted
user6386155
Asked: 2023-12-05 22:44:22 +0800 CST

根据条件连接pyspark中的表

  • 772

我想加入 pyspark 表，其中第一个表有，id第二个表有和。合并的表将包含每个列以及. s之间的和可能会重叠startTimeendTimeTimevalueidTimevaluestartTime<=Time<=endTimestartTimeendTimeid

join

1 个回答

  1. Best Answer

    假设 df1 和 df2 是您的 2 个数据帧：

    from pyspark.sql import functions as F

result = df1.join(
    df2,
    on=F.col("Time").between(F.col("startTime"), F.col("endTime")),
    how="inner",
)
    • 0

相关问题