我需要从Apache Nifi实现Hive Joins。
我在Apache nifi中找到了PutHiveQL
,PutHiveStreaming
和SelectHiveQL
处理器,但找不到有关Hive Joins实现的任何用例。
如果要在 Hive 中联接查询,可以像往常一样将这些处理器与联接查询语句一起使用。
但是,如果您希望使用不同的常规查询,然后在NiFi中加入它们,我会发现这相当困难(但可以使用MergeRecord或MergeContent(,因为NiFi并不是完全为连接查询而构建的。