介绍
该组件为具体数据写入的实现,它主要关心数据写入到哪里去,为数据输出的具体实现。必须作用于Output
上才能运行。
扩展
普通写入者
继承
com.starblues.rope.core.output.writer.AbstractWriter
抽象类实现方法说明:id(): 定义该写入者的id(全局读取者唯一)
name(): 定义该写入者的名称
describe(): 定义该写入者的描述
configParameter():该写入者所需参数,如果不需要参数,则返回null
initialize(String processId): 初始化
write(List<Record> records):写入数据的实现
destroy():销毁时的实现
在该实现类的头部新增Spring注解@Component
携带转换器的写入者
- 继承
com.starblues.rope.core.output.writer.AbstractConverterWriter<T>
抽象类实现方法说明:<T>: 泛型T,转换器转换数据后的数据类型
id(): 定义该写入者的id(全局读取者唯一)
name(): 定义该写入者的名称
describe(): 定义该写入者的描述
configParameter():该写入者所需参数,如果不需要参数,则返回null
initialize(String processId): 初始化
T customConvert(Record record):如果没有配置转换器,则调用该自定义方法返回数据结果
write(List<T> records):写入数据的实现
destroy():销毁时的实现
- 在该实现类的头部新增Spring注解@Component