使用Apache NiFi柱的内容写入CSV文件(Using Apache NiFi to writ

2019-11-05 06:02发布

我有一个Apache NiFi流动,在那里我一个巨大的阅读.csv文件。 下面是一个示例.csv

school, date, city
Vanderbilt, xxxx, xxxx
Georgetown, xxxx, xxxx
Duke, xxxx, xxxx
Vanderbilt, xxxx, xxxx

我想用NiFi读取该文件,然后输出另一个.csv按文件school名。 即,存在将是一个.csv的两种文件Vanderbilt记录(两行合计,B / C两个记录),并且一个文件Georgetown ,并且一个文件Duke

我用GetFile在我的文件画(工程,验证),然后SplitText (线分割数= 1标题行数= 1),然后ExtractText ,但我有一个非常错误的配置。 最后,我有PutFile ,其中写到,我需要它去。 谢谢。

Answer 1:

看看NiFi的记录处理能力,你将要使用PartitionRecord到校场,这将产生你所描述的正是分区。

https://nifi.apache.org/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.7.1/org.apache.nifi.processors.standard.PartitionRecord/index.html



文章来源: Using Apache NiFi to write CSV files by contents of column