• 主要用于控制读取者主动获取其他源的数据，比如从数据库、接口等源数据方主动获取数据。
  1. OneReaderInput：只执行一次的输入
  2. PeriodAcquireReaderInput：周期性执行的输入

所需参数:

  1. QuartzReaderInput: 基于Quartz的定时输入
  1. 实现方法说明：```java

initialize()：初始化时被调用run(): 启动运行时该输入。用于调用读取者中读取数据id(): 定义该输入的id(全局输入唯一)name(): 定义该输入的名称describe(): 定义该输入的描述configParameter(): 返回该输入所需的参数实现类。如果没有参数，则返回 nullstartAfter(): 启动之前的操作

  1. 新增3步骤实现的管理器在输入管理器工厂com.starblues.rope.core.input.manager.InputManagerFactory 的 处，新增3步骤实现的输入管理器。
  • 主要用于程序被动接受其他源发送过来的数据。比如从kafka消费数据。

    不携带转换器

  1. 继承：com.starblues.rope.core.input.support.accept.AbstractAcceptInput 类
  1. 将该实现类的头部新增Spring注解

携带转换器

  1. 继承：com.starblues.rope.core.input.support.accept.AbstractAcceptConverterInput<T> 类

实现方法说明：