文件名称:nifi-pravega:适用于Apache NiFi的Pravega连接器
文件大小:118KB
文件格式:ZIP
更新时间:2024-03-08 20:52:26
Java
适用于Apache NiFi的Pravega连接器 连接器,用于使用读写流。 处理器 PublishPravega :此处理器将传入的FlowFiles写入Pravega流。 它使用Pravega交易提供至少一个担保。 PublishPravegaRecord :与PublishPravega相似,但是它使用NiFi记录读取器将传入的FlowFiles解析为CSV,JSON或Avro。 每条记录将作为一个单独的事件写入Pravega流中。 写入Pravega的事件将使用Record Writer进行序列化,可以是CSV,JSON或Avro。 ConsumePravega :该处理器从Pravega流中读取事件并生成FlowFiles。 该处理器以NiFi群集状态存储最近成功的Pravega检查点,以使其在重新启动处理器或节点时可以恢复。 它至少提供一次保证。 所有这些处理器均允许在N
【文件预览】:
nifi-pravega-master
----.gitignore(438B)
----images()
--------ConsumePravega-Configure.png(34KB)
--------ConsumePravega-Overview.png(14KB)
--------PublishPravega-Overview.png(12KB)
--------PublishPravega-Configure.png(24KB)
----HEADER(285B)
----LICENSE(11KB)
----pom.xml(1006B)
----README.md(2KB)
----nifi-pravega-processors()
--------src()
--------pom.xml(4KB)
----NOTICE(77B)
----nifi-pravega-nar()
--------pom.xml(1KB)