[GitHub] [hudi] liujinhui1994 commented on issue #2162: [SUPPORT] Deltastreamer transform cannot add fields

[GitBox]

liujinhui1994 commented on issue #2162:
URL: https://github.com/apache/hudi/issues/2162#issuecomment-706981577


   source.avsc
   {
        "type": "record",
        "name": "t3_app_td_ad_info",
        "fields": [{
                        "name": "dataId",
                        "type": "string"
                },
                {
                        "name": "collectTime",
                        "type": "string"
                },
                {
                        "name": "clickTime",
                        "type": "string"
                },
           {
                        "name": "spreadUrl",
                        "type": ["null", "string"],
                "default": null
                },{
                        "name": "spreadName",
                        "type": ["null", "string"],
               "default": null
                },
                {
                        "name": "ua",
                        "type": ["null", "string"],
               "default": null
                },
                {
                        "name": "uid",
                        "type": ["null", "string"],
               "default": null
                },
                {
                        "name": "adnetName",
                        "type": ["null", "string"],
               "default": null
                },
                {
                        "name": "adnetDesc",
                        "type": ["null", "string"],
               "default": null
                }
        ]
   }
   
   target.avsc
   {
        "type": "record",
        "name": "t3_app_td_ad_info",
        "fields": [{
                        "name": "dataId",
                        "type": "string"
                },
                {
                        "name": "collectTime",
                        "type": "string"
                },
                {
                        "name": "clickTime",
                        "type": "string"
                },
           {
                        "name": "spreadUrl",
                        "type": ["null", "string"],
                "default": null
                },{
                        "name": "spreadName",
                        "type": ["null", "string"],
               "default": null
                },
                {
                        "name": "ua",
                        "type": ["null", "string"],
               "default": null
                },
                {
                        "name": "uid",
                        "type": ["null", "string"],
               "default": null
                },
                {
                        "name": "adnetName",
                        "type": ["null", "string"],
               "default": null
                },
                {
                        "name": "adnetDesc",
                        "type": ["null", "string"],
               "default": null
                },
                {
                        "name": "ds",
                        "type": "string"
                }
        ]
   }
   
   


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org