天天看點

Nifi Processor | PutHiveQL

    執行HiveQL DDL / DML指令(例如,UPDATE,INSERT)。傳入的FlowFile的内容應該是要執行的HiveQL指令。HiveQL指令可能會使用?逃避參數。在這種情況下,要使用的參數必須作為具有命名約定hiveql.args.N.type和hiveql.args.N.value的FlowFile屬性存在,其中N是正整數。hiveql.args.N.type應該是一個表示JDBC Type的數字。FlowFile的内容預計為UTF-8格式。

用法:

場景 :生成Hive Sql 語句執行以建立分區

Nifi Processor | PutHiveQL

GenerateFlowFile:

alter table dev_wiwide_edw.wiupdate_f drop if exists partition(date_key="${now():format('yyyyMMdd')}");alter table dev_wiwide_edw.wiupdate_f add partition (date_key="${now():format('yyyyMMdd')}") location '/data/database/wiwide_edw.db/table/wiupdate_f/${now():format('yyyyMMdd')}';

以下是PutHiveQL 的配置

Nifi Processor | PutHiveQL
Nifi Processor | PutHiveQL
Nifi Processor | PutHiveQL

在Database Connection URL 中寫入連接配接Hive 的連接配接資訊,如 jdbc:hive2://cdh1:21050/dev_wiwide_edw;auth=noSasl

繼續閱讀