Apache Nifi 提供多种数据处理组件，如 CSVReader 和 CSVRecordSetWriter，用于读写CSV格式数据。此外，还包括分布式缓存服务如 DistributedMapCacheServer 和 DistributedSetCacheServer，以及对HBase、MongoDB、Redis等数据库的集成服务。Nifi 还支持JsonPathReader和JsonTreeReader，方便JSON数据的解析和操作。
摘要由CSDN通过智能技术生成
2.4.4 Controller Service分类介绍
AvroReader
AvroReader解析Avro数据并且将每个Avro记录解析为一个独立的记录对象返回。解析Avro的schema可以来自于数据本身，也可以通过“Schema Access Strategy”属性配置的策略去Schema注册服务获取Schama。
AvroRecordSetWriter
将记录集的内容写成Avro二进制格式。Schama同样可以通过“Schema Access Strategy”属性配置的策略去Schema注册服务获取。
AvroSchemaRegistry
提供一个Schama集中注册管理的服务。可以通过添加动态属性来添加Schama，其中动态属性的名称就是Schama的名称，动态属性的值就是Schama。
ConfluentSchemaRegistry
？？？？？？？？？？？
CSVReader
解析CSV格式的数据，并将CSV文件的每一行作为一个单独的解析对方返回。默认情况下它会将CSV文件第一行认为是列名称，将之后的行作为实际的数据。
CSVRecordSetWriter
将记录集的内容写成CSV格式数据。默认第一行写的是列名称(如果想取消可将“Include Header Line”属性设置成false)。后面的行将会写入记录集的值。
SimpleCsvFileLookupService
一个以CSV文件格式为基础的可重载的查询服务。
DistributedMapCacheClientService
提供访问DistributedMapCacheServer的访问能力。可以用在NiFi集群各个节点之间共享Map的场景。
DistributedMapCacheServer
提供一个可通过Socket方式访问的map缓存服务。这个
2.4.4 Controller Service分类介绍AvroReaderAvroReader解析Avro数据并且将每个Avro记录解析为一个独立的记录对象返回。解析Avro的schema可以来自于数据本身，也可以通过“Schema Access Strategy”属性配置的策略去Schema注册服务获取Schama。AvroRecordSetWriter将记录集的内容写成Avro二进制格式。S...
RedisConnectionPoolS
er
vice
该控制器服务用来链接到Redis，并控制链接参数
RedisDistributedMapCacheClientS
er
vice
PutDistributedMapCache
FetchDistributedMapCache
通用步骤指的是读写Redis都需要执行的操作，其实就
