如何使用ConvertRecord和CSVRecordSetWriter在Apache Nifi中输出头（没有数据）？
我正在使用Apache NiFi从数据库表中提取数据，并使用ConvertRecord将获取的记录从avro更改为使用AvroReader和CSVRecordSetWriter的CSV文件。
当至少有一行从数据库返回时，我的流程工作正常。
但是，当executesQL处理器输出一个包含0条记录的FlowFile（该FlowFile仍然包含元数据/avro模式）时，convertrecord会给出一个0字节的FlowFile输出。我在CSVRecordSetWriter服务中的设置被设置为输出标头。
在这种情况下，有没有办法让convertrecord输出一个只包含标题行的FlowFile？
共有1个答案
ExecuteSql处理器将ExecuteSql.row.count（包含选择查询中返回的行数）属性添加到流中。
您可以检查属性(executesql.row.count)的值，并决定是否需要使用ConvertRecord处理器。
流程：
Executesql(success)--> RouteOnAttribute(add new property ${executesql.row.count:equals(0)})
--> matched --> ReplaceText //Add Header
--> unmatched --> ConvertRecord //convert to csv format
-
问题内容： 有人可以给我一些在函数中使用输出参数的示例代码吗？我尝试过使用Google，但只是在功能中发现了它。我想在另一个函数中使用此输出值。 我正在开发的代码打算在Android中运行。 问题答案： Java通过值传递；没有像C＃这样的参数。 您可以使用，或更改 作为 参考传递的对象（ 按 值）。 代码样例 至于OP需要帮助的代码，以下是使用特殊值（通常用于引用类型）指示成功/失败的典型解决方
-
这个程序创建了一个名为datafile.txt的文件，并且应该使用文本I/O将100个随机创建的整数写入文件中。但是，我的输出是“java.util.Random@30c221”100次。我如何得到100个随机数？提前谢谢。
-
我很难找到关于这些命令的功能、返回什么以及如何在C++中的应用程序中获得它们的信息。这是一个练习，这就是我需要如何获得我将从中读取的输入文件和我将向其写入的输出文件： 我试图使用： 谢谢！
-
我在应用程序中收到一个错误，我没有得到解决方案。应用程序请求REST/JSON并尝试与另一个应用程序通信。有一个轮询器可以异步调用每个请求。当一个do a请求总是分派错误“没有可用的输出通道或replyChannel头”，它被重定向到errorChannel句柄。 日志打印： 后发送（发送=true）在通道'错误通道'，消息：错误消息[有效载荷=org.springframework.messag
-
我有一个函数： 输出将为“x 天，0：00：00”。如何只输出没有小时，分钟和秒的天？我可以将日差与整数相乘而不取“天数”吗？*抱歉我的英语不好
-
问题内容： 当按预期执行时，goroutine不打印任何内容。 问题答案： 当函数结束时，程序也将结束。它不等待其他goroutine完成。 引用Go语言规范：程序执行： 程序执行首先初始化主程序包，然后调用函数。当该函数调用返回时，程序退出。它不等待其他（非）goroutine完成。 有关更多详细信息，请参见此答案。 您必须告诉您的函数等待以goroutine形式启动的函数完成。您可以将它们与通