1CREATE TABLE sink_tsdb_table (
2     `datapoints` ARRAY < ROW(
3        `timestamp` BIGINT,
4        `metric` STRING,
5        `value` BIGINT,
6        `tags` MAP < STRING, STRING >
7    ) >
8) WITH (
9    'connector.type' = 'TSDB',
10    'connector.emit' = 'batch',
11    'connector.url' = 'http://xxxxxx.tsdb-ej9v6mg6q8z9.tsdb.iot.bj.baidubce.com',
12    'connector.net.max-connection-total' = '10',
13    'connector.net.max-connection-per-route' = '10',
14    'connector.net.connection-timeout-ms' = '60000',
15    'connector.write.max-message-num-per-batch' = '1000'
16);

1CREATE TABLE TsdbTable (
2    `field` STRING
3) WITH (
4    'connector.type' = 'TSDB',
5    'connector.emit' = 'batch',
6    'connector.url' = 'http://xxxxxx.tsdb-ej9v6mg6q8z9.tsdb.iot.bj.baidubce.com',
7    'connector.net.max-connection-total' = '10',
8    'connector.net.max-connection-per-route' = '10',
9    'connector.net.connection-timeout-ms' = '60000',
10    'connector.write.max-message-num-per-batch' = '1000',
11    'connector.write.max-message-size-per-batch' = '1024'
12);