在puthivestreaming之前修改insert语句

whitzsjs  于 2021-06-26  发布在  Hive
关注(0)|答案(1)|浏览(398)

我的csv文件包含一个日期时间格式为12-10-2017 11:30的列
现在使用puthivestreaming,我可以很容易地插入这些记录,但我的要求是只保留12-10-2017的时间
我可以在插入时使用hive命令行和substr()方法来实现这一点,但不确定nifi是否支持它
我也考虑过replacetext,但是因为我在一行上有多个类似datetime的列,所以我不能这样做。
我怎样才能做到这一点?。

yvgpqqbh

yvgpqqbh1#

通过使用getdelimitedfield,可以很容易地获得所需的列。
https://nifi.apache.org/docs/nifi-docs/html/expression-language-guide.html#getdelimitedfield
输入--> 1,12-10-2017 11:30,23 在文本中,只需给出 ${Input:getDelimitedField(2):substringBefore(' ')} 它产生流文件内容 12-10-2017 .
希望这对你有帮助。

相关问题