介绍

该组件为具体数据写入的实现,它主要关心数据写入到哪里去,为数据输出的具体实现。必须作用于Output上才能运行。

扩展

普通写入者

  1. 继承com.starblues.rope.core.output.writer.AbstractWriter抽象类实现方法说明:

    1. id(): 定义该写入者的id(全局读取者唯一)
    2. name(): 定义该写入者的名称
    3. describe(): 定义该写入者的描述
    4. configParameter():该写入者所需参数,如果不需要参数,则返回null
    5. initialize(String processId): 初始化
    6. write(List<Record> records):写入数据的实现
    7. destroy():销毁时的实现
  2. 在该实现类的头部新增Spring注解@Component

携带转换器的写入者

  1. 继承com.starblues.rope.core.output.writer.AbstractConverterWriter<T> 抽象类实现方法说明:
    1. <T>: 泛型T,转换器转换数据后的数据类型
    2. id(): 定义该写入者的id(全局读取者唯一)
    3. name(): 定义该写入者的名称
    4. describe(): 定义该写入者的描述
    5. configParameter():该写入者所需参数,如果不需要参数,则返回null
    6. initialize(String processId): 初始化
    7. T customConvert(Record record):如果没有配置转换器,则调用该自定义方法返回数据结果
    8. write(List<T> records):写入数据的实现
    9. destroy():销毁时的实现
  2. 在该实现类的头部新增Spring注解@Component