0

我正在尝试替换从 nifi 中的另一个处理器获取的查询中的值,我该如何实现这一点或最好的方法是什么?处理器详细信息如下,

  1. 执行 SQL 处理器 ->SELECT Rno FROM sampleDB WHERE operation = 1;
  2. SplitAvro 处理器
  3. 将 Avro 转换为 Json -> 在这里我得到以下 JSON{'Rno':'121'}
  4. 执行 SQL 处理器 -> DELETE FROM NewDB WHERE Rno = X(此处 X 应替换为从前一个处理器接收到的 Rno,即“121”)

如何实现第 4 步除上述处理器外还应使用哪些处理器?

4

0 回答 0