我想将json插入配置单元数据库。我尝试使用convertjsontosql处理器将json转换为sql。我怎么用 PARTITION (....) 加入我的问题？？我可以这样做，还是应该使用replacetext处理器进行查询？
PARTITION (....)
utugiqy61#
你用的是什么版本的Hive？puthivestreaming和puthive3streaming的Hive1.2和Hive3版本（分别）允许您将数据直接放入Hive1.2和Hive3，而不必发出hiveql语句。对于orc格式的外部配置单元表，还有convertavrotoorc（对于配置单元1.2）和putorc（对于配置单元3）处理器。假设这些不适用于您的用例，您还可以考虑使用freeformtextrecordsetwriter使用partition语句等生成hiveql的convertrecord。它提供了比尝试修补sql语句以将其转换为分区表的hiveql更大的灵活性。编辑：我忘了提到，由于空间原因，hive3nar/组件不包括在nifi版本中。您可以在这里找到nifi 1.11.4的hive 3 nar。
1条答案
按热度按时间utugiqy61#
你用的是什么版本的Hive？puthivestreaming和puthive3streaming的Hive1.2和Hive3版本（分别）允许您将数据直接放入Hive1.2和Hive3，而不必发出hiveql语句。对于orc格式的外部配置单元表，还有convertavrotoorc（对于配置单元1.2）和putorc（对于配置单元3）处理器。
假设这些不适用于您的用例，您还可以考虑使用freeformtextrecordsetwriter使用partition语句等生成hiveql的convertrecord。它提供了比尝试修补sql语句以将其转换为分区表的hiveql更大的灵活性。
编辑：我忘了提到，由于空间原因，hive3nar/组件不包括在nifi版本中。您可以在这里找到nifi 1.11.4的hive 3 nar。