我已经将nifi设置为从sftp中提取文件，然后根据文件名将它们放到hdfs文件夹中。从那里，它需要发送命令 alter table ${dbname}.${tablename} add partition (year=${year}, date='${date}'); 我知道我需要使用“puthiveql”处理器，但我不知道如何将“altertable”命令提供给它。我在hortonworks上读到过一些线程说要使用“replacetext”处理器，但我不确定在这种情况下是否可以。我以前的所有处理器都只是用来创建构建hdfs文件夹路径的变量。没有真正的“文本”可以替代。你知道我怎么把这个命令传给Hive吗？任何协助都将不胜感激。
1条答案
按热度按时间9lowa7mx1#
使用
ReplaceText处理器Always Replace战略。Add these processors at the end of your flow:```--other processors
PutHDFS //store file into HDFS
ReplaceText //always replace and replacement value alter statement
PutHiveQL //configure HiveConnectionPool and processor executes hive statements.