Wilson-β

belle 百里国际 

> > Yes, encapsulate such a data structure, dynamically load by spelling the URL on the sink side, and add a keyby operator before sink > > At present, flink-doris-connector...

> 生成 canal json ---> serialize to RowData --> TableBufferMap map key is ```{db}_{table}```, buffer value is a buffer contained``` {"column_a":"value_a","column_b":"value_b"...}``` we can submit to http://xxx:xx/api/{db}/{table}/_streamLoad when buffer over size...

> Perhaps，doris can provide another http interface for database sync，use a special header ```-H 'table:xxx'``` to flush into doris the same database. and we can also reuse the url.