ItemReader 和 ItemWriter 列表
项目读取者
项目读取者 | 描述 | 线程安全 |
---|---|---|
|
组合 和 接口的抽象基类。 |
是的 |
|
提供基本
通过计算从
一。 |
不 |
|
提供基本分页功能的抽象基类 |
不 |
|
抽象基类,提供基于 Spring Data 的 分页设施 |
不 |
|
一个将列表作为其
item 中,存储 injected 中的对象,直到它们
已准备好打包为一个系列。必须使用此类
作为可以标识记录的自定义的包装器
边界。自定义读取器应标记
records 通过返回一个来响应其
查询方法( 和 )。请注意,此 reader
不是 Spring Batch 提供的读取器库的一部分
但作为 中的样本给出。 |
是的 |
|
给定一个 Spring ,它提供
同步接收方法。方法
允许您接收 POJO 对象。 |
是的 |
|
从 Apache Kafka 主题读取消息的 an。
它可以配置为从同一主题的多个分区中读取消息。
此读取器将消息偏移量存储在执行上下文中以支持重启功能。 |
不 |
|
从平面文件中读取。包含和功能。请参阅 “FlatFileItemReader”。 |
不 |
|
使任何类适应接口。 |
是的 |
|
通过 JDBC 从数据库游标读取。参见“基于游标的 ItemReaders”。 |
不 |
|
给定一个 SQL 语句,翻阅各行, 这样就可以读取大型数据集而不会用完 记忆。 |
是的 |
|
给定一个 Spring 对象和一个 JMS
将错误发送到的目标或目标名称,提供项目
通过 Injected 方法接收。 |
是的 |
|
执行 JPQL 查询并迭代返回的结果集 |
不 |
|
给定一个 JPQL 查询,页面遍历 行,这样就可以读取大型数据集而不会用完 记忆。 |
是的 |
|
提供列表中的项,一次提供一个。 |
不 |
|
给定一个对象和基于 JSON 的 MongoDB
query,提供从该方法接收的项。 |
是的 |
|
给定一个对象和
Cyhper 查询时,项目将作为 Neo4jOperations.query 的结果返回
方法。 |
是的 |
|
给定一个 Spring Data 对象,
a 和要执行的方法的名称,则返回由
Spring Data 存储库实现。 |
是的 |
|
从数据库游标中读取
执行数据库存储过程。请参阅 |
不 |
|
读取 StAX。参见 |
不 |
|
从 Json 文档中读取项目。请参阅 |
不 |
|
从包含序列化 Avro 对象的资源中读取项目。 |
不 |
|
从 LDIF 资源中读取项目并将其作为 |
不 |
|
从 LDIF 资源中读取项目,并使用 将它们映射到域对象 |
不 |
条目写入器
项目写入器 | 描述 | 线程安全 |
---|---|---|
|
结合了 'ItemStream' 和 'ItemWriter' 接口的抽象基类。 |
是的 |
|
给定一个 Spring ,提供
对于同步方法。该方法允许您发送 POJO 对象。 |
是的 |
|
将一个 item 传递给每个 item 的方法
在注入的对象中。 |
是的 |
|
写入平面文件。includes 和
可跳过功能。参见 “FlatFileItemWriter”。 |
不 |
|
使任何类适应接口。 |
是的 |
|
使用 中的 批处理功能(如果可用),并且可以
采取基本步骤在 . |
是的 |
|
使用对象,将写入项
添加到默认队列中。 |
是的 |
|
此项写入器是 JPA 感知的
并处理一些与事务相关的工作,而非 “JPA-aware” 不需要了解这些工作,并且
然后委托给另一个 writer 来执行实际的写入。 |
是的 |
|
使用对象,通过使用 a 映射项目中的键,通过该方法将项目写入默认主题。
还可以配置删除标志以将删除事件发送到主题。 |
不 |
|
使用 Spring 的 ,类型的项目作为邮件消息发送。 |
是的 |
|
给定一个对象,将写入项
通过该方法。实际写入延迟
直到事务提交前的最后一刻。 |
是的 |
|
给定一个对象,项目将通过方法持久化或通过 删除,具体由配置决定 |
是的 |
|
扩展动态创建参数。参数是通过检索
要处理的项目(通过 a )中字段的值,基于注入的 field 数组
名字。 |
是的 |
|
给定一个 Spring Data 实现,
项目通过配置中指定的方法保存。 |
是的 |
|
使用实现来
将每个项目转换为 XML,然后使用
斯塔克。 |
不 |
|
使用实现来
将每个项目转换为 Json,然后将其写入 Json 文件。 |
不 |
|
将数据序列化到使用 Avro |
不 |
|
将项目写入 . |
不 |