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效果
流程模板
参见附件(请右键另存保存):