所以,我用的是类型安全配置文件 application.properties
用spark读取外部参数。我的输入和输出路径如下所示:
dev.input.base.dir = s3://inp_bucket/my_dir/2021/03/21/00/
dev.output.base.dir = s3://oup_bucket/my_dir/2021/03/21/00/
现在这个代码应该每天都运行,而且每天都必须处理上一个日期。所以基本上,我想替换 2021/03/21
在路径中 current_date()-1
. 我如何做到这一点?
如果在typesafe配置中不可能,我可以在读取字符串后执行吗 Scala
?
1条答案
按热度按时间o8x7eapl1#
如果你的路径是一个字符串,你可以用正则表达式分解它,然后用date减去你需要的天数
下面是一个简单的例子: