草庐IT

SelectHiveQL

全部标签

hadoop - 如何在 Apache NiFi 中动态地将值从 executeSQL 传递到 SelectHiveQL

我有两个表,一个在mysqltest.employee中,另一个在hivedefault.dept中我想通过test.employee表的empid作为参数在hive表中查询并将数据存储到HDFSExecuteSQL->selectempidfromtest.employee(给出10条记录)SelectHiveQL->SELECT*FROMdefault.deptwhereempid=${empid}(应检索10条记录)imagedescriptionhere 最佳答案 您可以执行以下操作:ExecuteSQL-检索员工记录Con