数据目的表CREATETABLEes_sink(`id`INT,`name`STRING,`score`INT,PRIMARYKEY(`id`)NOTENFORCED)WITH('connector'='elasticsearch Elasticsearch)CREATETABLEes_sink(`id`INT,`name`STRING,`score`INT,PRIMARYKEY(`id`)NOTENFORCED)WITH('connector'='elasticsearch
3.2 Sink 端参数配置 -- Sink 端配置,将数据写入 ES 'connector' = 'elasticsearch-7', -- 输出到 Elasticsearch
user_name STRING uv BIGINT, pv BIGINT, PRIMARY KEY (user_id) NOT ENFORCED ) WITH ( 'connector' = 'elasticsearch