试图让这段代码在col_a if >0或UW <0中显示'OW‘。这适用于一个代码,但当我尝试执行另一个操作时,条件无法工作,因为单元格中的一些数据已从int更改为str。下面是一个示例DataFrame,请注意,col_b是虚拟数据,但表明我还需要引用一列。df = pd.DataFrame({'col_a':[-1,1,2,3,4,-4], 'col_b':[1,2,3,4,5,6]})
col
我有一个场景,通过where条件从同一个DataFrame中使用另一个列从DataFrame读取一列,这个值作为IN条件通过,从另一个DataFrame中选择相同的值,我如何在spark DataFrame中实现。在SQL中,它将类似于:
select distinct(A.date) from table A where A.key in (select B.key from t