介绍

该组件为数据处理器,其作用是处理数据,比如将字符型数据处理成其他类型、丢弃某数据、新增某数据字段。该组件可自行扩展,是非必须组件。

实现扩展

  1. 实现接口 com.starblues.rope.core.handler.DateHandler实现方法说明:

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