如何從一個處理器dynamicallly值傳遞給使用Apache nifi

Question

我想傳遞一個處理器結果作爲輸入，以使用Apache NiFi另一個處理器的另一處理器。

我geeting使用的ExecuteSQL處理器.I要動態傳遞這個結果在阿帕奇nifi SelectHiveQL處理器從MySQL值。

Answer 1

ExecuteSQL輸出設定爲阿夫羅的結果。如果您想單獨處理每一行，則可以使用SplitAvro，然後使用ConvertAvroToJson，或者ConvertAvroToJson然後使用SplitJson。在這一點上，你可以使用EvaluateJsonPath將值提取到的屬性（使用與NiFi Expression Language），並在某些時候，你可能會希望ReplaceText你設置流文件的一個HiveQL語句（供SelectHiveQL）的內容。