数据湖探索 DLI-Elasticsearch结果表:示例

时间:2024-12-27 10:34:29

示例

create table sink1(
  attr1 string,
  attr2 int
) with (
  'connector.type' = 'elasticsearch',
  'connector.version' = '7', 
  'connector.hosts' = 'http://xxxx:9200',
  'connector.index' = 'es',
  'connector.document-type' = 'one',
  'update-mode' = 'append',
  'format.type' = 'json'
);
support.huaweicloud.com/sqlref-flink-dli/dli_08_0316.html