[GitHub] [incubator-hudi] zhangxinjian123 edited a comment on issue #829: Structured Streaming read kafka

2019-08-15 Thread GitBox
zhangxinjian123 edited a comment on issue #829: Structured Streaming read kafka URL: https://github.com/apache/incubator-hudi/issues/829#issuecomment-521086833 first json: ``` {"database":"zhang","table":"hao","type":"insert","ts":1555984612,"xid":90202,"commit":true,"data":{"id":7,"N

[GitHub] [incubator-hudi] zhangxinjian123 edited a comment on issue #829: Structured Streaming read kafka

2019-08-13 Thread GitBox
zhangxinjian123 edited a comment on issue #829: Structured Streaming read kafka URL: https://github.com/apache/incubator-hudi/issues/829#issuecomment-521086833 first json: {"database":"zhang","table":"hao","type":"insert","ts":1555984612,"xid":90202,"commit":true,"data":{"id":7,"Name":"z

[GitHub] [incubator-hudi] zhangxinjian123 edited a comment on issue #829: Structured Streaming read kafka

2019-08-13 Thread GitBox
zhangxinjian123 edited a comment on issue #829: Structured Streaming read kafka URL: https://github.com/apache/incubator-hudi/issues/829#issuecomment-520660528 For example, the DataFrame I started writing saved to the path is three fields, the second two fields are normal, the third writing