【Flink Sql 支持表在指定列后面加字段么】

[忝忝向仧]

Hi,all:


Flink sql 支持在表的指定列后面加字段么,比如表A有c1,c2,c3字段，现在我想在c1后面添加字段c4变为c1,c4,c2,c3而不是在末尾追加.


谢谢.

[Jark]

Hi,

能具体说明下你的场景和需求么？ 数据源是什么，源数据中是否原先就有c4这一列呢，还是新增加了 c4 这一列呢？


其次，这个问题要看你的 connector 是什么。 有的 connector 是根据列名来映射的（如
JSON，各种数据库），有的是根据列名顺序来映射的（如 CSV）。
如果是按列名来映射的，那么在 Flink SQL DDL 中，新增 c4 一列就能读取到 c4 的值，不管c4 在哪个字段之后。

Best,
Jark


On Sat, 27 Jun 2020 at 17:26, 忝忝向仧 <[hidden email]> wrote:

> Hi,all:
>
>
> Flink sql
> 支持在表的指定列后面加字段么,比如表A有c1,c2,c3字段，现在我想在c1后面添加字段c4变为c1,c4,c2,c3而不是在末尾追加.
>
>
> 谢谢.

[忝忝向仧]

Hi,


场景就是比如原来的表有c1,c2,c3三列，没有c4这列
但是后来通过alter table增加c4这列，想要表的列的顺序是c1,c4,c2,c3。
也就是说增加的列可以在指定列的后面.






------------------&nbsp;原始邮件&nbsp;------------------
发件人:&nbsp;"Jark Wu"<[hidden email]&gt;;
发送时间:&nbsp;2020年6月28日(星期天) 上午10:51
收件人:&nbsp;"user-zh"<[hidden email]&gt;;

主题:&nbsp;Re: 【Flink Sql 支持表在指定列后面加字段么】



Hi,

能具体说明下你的场景和需求么？ 数据源是什么，源数据中是否原先就有c4这一列呢，还是新增加了 c4 这一列呢？


其次，这个问题要看你的 connector 是什么。 有的 connector 是根据列名来映射的（如
JSON，各种数据库），有的是根据列名顺序来映射的（如 CSV）。
如果是按列名来映射的，那么在 Flink SQL DDL 中，新增 c4 一列就能读取到 c4 的值，不管c4 在哪个字段之后。

Best,
Jark


On Sat, 27 Jun 2020 at 17:26, 忝忝向仧 <[hidden email]&gt; wrote:

&gt; Hi,all:
&gt;
&gt;
&gt; Flink sql
&gt; 支持在表的指定列后面加字段么,比如表A有c1,c2,c3字段，现在我想在c1后面添加字段c4变为c1,c4,c2,c3而不是在末尾追加.
&gt;
&gt;
&gt; 谢谢.