一、获取表

    1. 添加处理器ListDatabaseTables

    image.png

    1. 配置ListDatabaseTables

    image.png

    1. 配置DBCPConnectionPool

    image.png
    二、利用ReplaceText将表名转换固定查询格式

    1. 添加ReplaceText处理器

    image.png

    1. 配置ReplaceText

    image.png
    三、利用ExecuteSQL执行sql语句

    1. 添加ExecuteSQL处理器

    image.png

    1. 配置ExecuteSQL处理器

    这里ListDatabaseTables处理器以及配置DBCPConnectionPool，直接使用。
    image.png
    四、利用ConvertRecord进行读写转换。

    1. 添加ConvertRecord处理器

    image.png

    1. 配置ConvertRecord处理器

    image.png

    1. 配置AvroReader和CSVRecordSetWrite

    AvroReader
    image.png
    CSVRecordSetWrite
    image.png
    五、更新输出文件名，以tablename为文件名

    1. 添加UpdateAttribute处理器

    image.png

    1. 配置UpdateAttribute处理器

    添加字段，设置更新输出文件名
    image.png
    六、测试环节直接利用PutFile保存在本地。保存在hdfs用puthdfs

    1. 添加PutFile处理器

    image.png

    1. 配置PutFile处理器

    image.png
    七、测试

    1. 连接所有处理器

    image.png

    1. 运行

    image.png

    1. 结果

    image.png
    至此，成功读取。