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