在火花放电中获取日期间隔
在火花放电中获取日期间隔
提问于 2019-08-23 10:20:07
我怎样才能在interval '12' month中实现类似于date_parse(due_date, '%Y%m%d')- interval '12' month中的SQL的等价操作呢？(我的电火花代码在下面)
(df1.join(df2, ['a', 'b'], how='left')
.filter(F.col('date1') < F.col('date2'))
.filter(F.col('date1') > F.col('date2') - interval '12' month)
.groupby(['a','b']).count()
.cache())在上面的代码中，date1和date2都是强制转换的to_date。
回答 2
Stack Overflow用户
回答已采纳
发布于 2019-08-23 20:53:36
试试这个：
(df1.join(df2, ['a', 'b'], how='left')
.filter(F.col('date1') < F.col('date2'))
.filter(F.months_between(F.col('date2'), F.col('date1')) < 12 )
.groupby(['a','b']).count()
.cache())Stack Overflow用户
发布于 2019-08-23 10:29:36
您可以执行以下操作：
from dateutil.relativedelta import *
(df1.join(df2, ['a', 'b'], how='left')
.filter(F.col('date1') < F.col('date2'))
.filter(F.col('date1') > F.col('date2') + relativedelta(months=-12))
.groupby(['a','b']).count()
.cache())页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/57624269
复制相关文章
相似问题
腾讯云开发者
