我有一个apachenifi1.2工作流，它从hdfs进程读取一些内容，并将信息写入历史表。之后，我想运行3个配置单元查询来创建一个基于历史表的新表。为什么在nifi上这么难？我没有找到任何简单的方法来使用putsql或selecthiveql。我不想使用executestreamedcommand，因为我想保留nifi库。有什么帮助吗？谢谢
jtoj6r0c1#
使用包含要运行的第一个hql的generateflowfile。连接到puthiveql，puthiveql连接到replacetext。在replacetext中，用第二个hql替换现有内容，然后连接到另一个puthiveql。等等。。。。这是非常烦人，但如果你只有3 HQL然后它的工作。更新：更好的方法是使用generateflowfile。把你的整个剧本放在那里。将其连接到splitcontent并按分号（；）拆分然后把它送到puthiveql。
1条答案
按热度按时间jtoj6r0c1#
使用包含要运行的第一个hql的generateflowfile。连接到puthiveql，puthiveql连接到replacetext。
在replacetext中，用第二个hql替换现有内容，然后连接到另一个puthiveql。等等。。。。
这是非常烦人，但如果你只有3 HQL然后它的工作。
更新：更好的方法是使用generateflowfile。把你的整个剧本放在那里。将其连接到splitcontent并按分号（；）拆分然后把它送到puthiveql。