Skip to main content

RecordReader支持infer schema

控制器服务JsonTreeReader, JsonPathReader, XML Reader, CSV Reader 支持自动推断schema

参数说明

Schema访问策略

新增"Infer Schema"配置值

示例

以CSV Reader为例

流程说明

在做数据按照具体Reader的格式转化Record时,当使用"Infer Schema"时,不需要提前配置avro.schema的属性值,按配置自动推断, 正确处理数据。并根据wirter的配置支持把推断出的schema值输出到属性,命名为avro.schema。

推断出的schema效果

流程模板

参见附件(请右键另存保存):

支持inferschema模板文件

支持inferschema测试模板文件