PutIgniteCache
描述:
通过使用DataStreamer将输入数据流的内容输出到Ignite缓存中。该组件使用数据流的属性(Ignite缓存实体键) 作为缓存键并将输入数据流的内容作为缓存实体的值。需同时提供字符串键和非空字节数据，否则将路由到失败连线。注意-Ignite内核定期将节点性能统计信息输出到日志中。该信息可通过设置logback.xml文件配置中关闭日志，且级别设置 'org.apache.ignite' 到 WARN
标签:
Ignite, insert, update, stream, write, put, cache, key, 插入, 更新, 写入, 缓存
参数:
如下列表中，必填参数则标识为加粗. 其他未加粗参数，则表示为可选参数。表中同时提到参数默认值设置, 并且 参数还支持 表达式语言.
| 名字 | 默认值 | 允许值列表 | 描述 |
|---|---|---|---|
| Ignite Spring配置文件 | 指定Ignite 的Spring配置文件， <path>/<ignite-configuration>.xml. 如果不指定，Ignite配置将使用默认绑定 127.0.0.1:47500..47509 | ||
| 缓存名 | 指定Ignite缓存的名字 | ||
| 分批数量 | 250 | 缓存实体的分批数量 (1-500). | |
| 缓存实体标识符 | 指定数据流上的属性用于标识Ignite缓存键读取内容到数据流输出 支持表达式语言 (支持流属性和变量) | ||
| DataStreamer并行操作数 | 5 | 设置单个节点的最大并行流操作数。 | |
| DataStreamer缓存大小 | 250 | 指定每个节点数据处理的缓存大小 (1-500). | |
| DataStreamer自动Flush频率 | 10 | 设置自动Flush间隔（毫秒） | |
| DataStreamer允许覆盖 | 禁止 | - 覆盖 - 禁止 | 指定是否允许覆盖已经存在于缓存的值 |
连线:
| 名字 | 描述 |
|---|---|
| success | 数据流成功写入Ignite缓存的数据输出到此连线 |
| failure | 数据流不能写入Ignite缓存的数据将路由到此失败连线 |
读取属性:
未提供。
写入属性:
| 名字 | 描述 |
|---|---|
| ignite.cache.batch.flow.file.total.count | 分批后的数据流总数 |
| ignite.cache.batch.flow.file.item.number | 分批后的当前数据流序号 |
| ignite.cache.batch.flow.file.successful.number | 成功数据流序号 |
| ignite.cache.batch.flow.file.successful.count | 成功数据流数 |
| ignite.cache.batch.flow.file.failed.number | 失败数据流数 |
| ignite.cache.batch.flow.file.failed.count | 分批后失败的数据流总数 |
| ignite.cache.batch.flow.file.failed.reason | 失败原因 |
状态管理:
该组件不保存状态。
限制:
该组件没有限制
输入流要求:
组件必须提供输入流。
系统资源考量:
| 资源 | 描述 |
|---|---|
| MEMORY | 此组件的实例可能导致此系统资源的高使用率。多个实例或高并发性设置可能导致性能下降。 |