在循环中插入数据帧的列值



我有一段代码,通过我的工作,我得到了最后一个月的记录。现在我需要一个逻辑,我可以在数据帧中插入手动开始日期和结束日期,我可以从该数据帧中要求我的工作根据该数据帧提供的开始日期和终止日期提取记录。。现在,如果我有4行,那么我的作业应该在每个时间间隔内执行4次获取记录。[您可以在上述链接中查看我当前的代码流和逻辑][1]如何验证历史数据?

我们可以通过首先在每列值上使用映射函数来实现这一点

recorddf = record.map(col=> col(0),col(1),col(2))
recorddf.collect.foreach(row=> {
row_1.tostring=a;
row_2.tostring=b;
row_3.tostring=c;
} )

现在我们可以传递这些字符串来执行我们的主类的函数

最新更新