Re: sinktable更新部分字段问题

Tue, 26 May 2020 22:43:26 -0700 

我通过Group By + LAST_VALUE实现了部分字段的更新，DML如下：
insert into
    es_sink
select
    id
    ,LAST_VALUE(`update_column`) AS update_column
from
    my_source
group by id;

naturalfree <[email protected]> 于2020年5月27日周三 下午1:07写道：
>
> Hi, Leonard xu
>
> 谢谢你的回复
> connector当前是支持两种模式的。但是更新的时候，select的字段数量必须等于es索引的全部字段。我这边想要根据主键更新索引的部分字段
>
>
> | |
> naturalfree
> |
> |
> 邮箱：[email protected]
> |
>
> 签名由 网易邮箱大师 定制
>
> 在2020年05月22日 23:29，Leonard Xu 写道：
> 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&gt;
>
> > 在 2020年5月20日，16:07，naturalfree <[email protected]> 写道：
> >
> > 现在有一个es索引，想通过flink sql根据主键更新部分字段。不知是否有可行方案
> >
> >
> > | |
> > naturalfree
> > |
> > |
> > 邮箱：[email protected]
> > |
> >
> > 签名由 网易邮箱大师 定制
>


-- 
Best,
zz zhang

回复