gpt4 book ai didi

csv - 如何使用 apache NIFI 处理器重新排序 CSV 列?

转载 作者:可可西里 更新时间:2023-11-01 14:51:23 25 4
gpt4 key购买 nike

在我的场景中,用户可以选择上传 CSV 文件并可以将该 CSV 文件的列映射到预定义的架构。我需要根据用户映射重新排序该 CSV 文件的列并将其上传到 HDFS。有什么办法可以通过 NIFI 处理器来实现吗?

最佳答案

您可以使用 ConvertRecord 处理器完成此操作。在架构注册表( Controller 服务)中注册一个描述预期格式的 Avro 架构,并创建一个 CSVReader 实现以将此传入数据转换为通用的 Apache NiFi 内部记录格式。同样,将 CSVRecordSetWriter 与您的输出架构一起使用,以您喜欢的任何列顺序将数据写回 CSV。

有关记录处理原理和一些示例的更多信息,请参阅 Record-oriented data with NiFiApache NiFi Records and Schema Registries .

关于csv - 如何使用 apache NIFI 处理器重新排序 CSV 列?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/47551772/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com