flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Leonard Xu <xbjt...@gmail.com>
Subject Re: sinktable更新部分字段问题
Date Fri, 22 May 2020 15:29:02 GMT
Hi,naturalfree

Flink SQL 里es sink 是支持Append mode和upsert mode的[1],upsert mode下支持按主键更新的,你可以看看。


Best,
Leonard Xu
[1] https://ci.apache.org/projects/flink/flink-docs-master/zh/dev/table/connect.html#elasticsearch-connector
<https://ci.apache.org/projects/flink/flink-docs-master/zh/dev/table/connect.html#elasticsearch-connector>

> 在 2020年5月20日,16:07,naturalfree <naturalfree@126.com> 写道:
> 
> 现在有一个es索引,想通过flink sql根据主键更新部分字段。不知是否有可行方案
> 
> 
> | |
> naturalfree
> |
> |
> 邮箱:naturalfree@126.com
> |
> 
> 签名由 网易邮箱大师 定制


Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message