ddl

classic Classic list List threaded Threaded
6 messages Options
Reply | Threaded
Open this post in threaded view
|

ddl

阿华田
目前FLINK中对于DDL这块,它都只能什么类型的技术作为源头表或者SINK 表呢,我也网上也仅仅看到了ddl mysql sink、ddl hbase sink等。还有其他类型的支持吗?如果不支持的话,是否flink开放了相关的接口,可以提供对其他类型技术的ddl语法支持呢?比如想做一个 ddl kudu sink之类的


| |
王志华
|
|
[hidden email]
|
签名由网易邮箱大师定制

Reply | Threaded
Open this post in threaded view
|

Re: ddl

wang jinhai
Page on “User-defined Sources & Sinks”. For flink 1.10: https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/sourceSinks.html <https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/sourceSinks.html>

Best Regards

[hidden email]

> 2020年3月13日 下午7:17,王志华 <[hidden email]> 写道:
>
> 目前FLINK中对于DDL这块,它都只能什么类型的技术作为源头表或者SINK 表呢,我也网上也仅仅看到了ddl mysql sink、ddl hbase sink等。还有其他类型的支持吗?如果不支持的话,是否flink开放了相关的接口,可以提供对其他类型技术的ddl语法支持呢?比如想做一个 ddl kudu sink之类的
>
>
> | |
> 王志华
> |
> |
> [hidden email]
> |
> 签名由网易邮箱大师定制
>

Reply | Threaded
Open this post in threaded view
|

Re: ddl

LakeShen
Hi 志华,
     你可以完全自己扩展 Flink SQL DDL 语法的功能,用来支持你们公司自己的实时数据源,或者 Sink
等等,具体实现,请参考楼上 jinhai
的链接

Best wishes,
沈磊

jinhai wang <[hidden email]> 于2020年3月13日周五 下午7:22写道:

> Page on “User-defined Sources & Sinks”. For flink 1.10:
> https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/sourceSinks.html
> <
> https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/sourceSinks.html
> >
>
> Best Regards
>
> [hidden email]
>
> > 2020年3月13日 下午7:17,王志华 <[hidden email]> 写道:
> >
> > 目前FLINK中对于DDL这块,它都只能什么类型的技术作为源头表或者SINK 表呢,我也网上也仅仅看到了ddl mysql sink、ddl
> hbase sink等。还有其他类型的支持吗?如果不支持的话,是否flink开放了相关的接口,可以提供对其他类型技术的ddl语法支持呢?比如想做一个
> ddl kudu sink之类的
> >
> >
> > | |
> > 王志华
> > |
> > |
> > [hidden email]
> > |
> > 签名由网易邮箱大师定制
> >
>
>
Reply | Threaded
Open this post in threaded view
|

Re: ddl

阿华田
好的 感谢


| |
王志华
|
|
[hidden email]
|
签名由网易邮箱大师定制


On 03/14/2020 11:13,LakeShen<[hidden email]> wrote:
Hi 志华,
你可以完全自己扩展 Flink SQL DDL 语法的功能,用来支持你们公司自己的实时数据源,或者 Sink
等等,具体实现,请参考楼上 jinhai
的链接

Best wishes,
沈磊

jinhai wang <[hidden email]> 于2020年3月13日周五 下午7:22写道:

Page on “User-defined Sources & Sinks”. For flink 1.10:
https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/sourceSinks.html
<
https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/sourceSinks.html


Best Regards

[hidden email]

2020年3月13日 下午7:17,王志华 <[hidden email]> 写道:

目前FLINK中对于DDL这块,它都只能什么类型的技术作为源头表或者SINK 表呢,我也网上也仅仅看到了ddl mysql sink、ddl
hbase sink等。还有其他类型的支持吗?如果不支持的话,是否flink开放了相关的接口,可以提供对其他类型技术的ddl语法支持呢?比如想做一个
ddl kudu sink之类的


| |
王志华
|
|
[hidden email]
|
签名由网易邮箱大师定制



Reply | Threaded
Open this post in threaded view
|

回复: ddl

hiroot
In reply to this post by LakeShen
你可以自己定义tablesinkfactory,flink已经预留了这个接口




------------------&nbsp;原始邮件&nbsp;------------------
发件人:&nbsp;"LakeShen"<[hidden email]&gt;;
发送时间:&nbsp;2020年3月14日(星期六) 中午11:13
收件人:&nbsp;"user-zh"<[hidden email]&gt;;

主题:&nbsp;Re: ddl



Hi 志华,
&nbsp;&nbsp;&nbsp;&nbsp; 你可以完全自己扩展 Flink SQL DDL 语法的功能,用来支持你们公司自己的实时数据源,或者 Sink
等等,具体实现,请参考楼上 jinhai
的链接

Best wishes,
沈磊

jinhai wang <[hidden email]&gt; 于2020年3月13日周五 下午7:22写道:

&gt; Page on “User-defined Sources &amp; Sinks”. For flink 1.10:
&gt; https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/sourceSinks.html
&gt; <
&gt; https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/sourceSinks.html
&gt; &gt;
&gt;
&gt; Best Regards
&gt;
&gt; [hidden email]
&gt;
&gt; &gt; 2020年3月13日 下午7:17,王志华 <[hidden email]&gt; 写道:
&gt; &gt;
&gt; &gt; 目前FLINK中对于DDL这块,它都只能什么类型的技术作为源头表或者SINK 表呢,我也网上也仅仅看到了ddl mysql sink、ddl
&gt; hbase sink等。还有其他类型的支持吗?如果不支持的话,是否flink开放了相关的接口,可以提供对其他类型技术的ddl语法支持呢?比如想做一个
&gt; ddl kudu sink之类的
&gt; &gt;
&gt; &gt;
&gt; &gt; | |
&gt; &gt; 王志华
&gt; &gt; |
&gt; &gt; |
&gt; &gt; [hidden email]
&gt; &gt; |
&gt; &gt; 签名由网易邮箱大师定制
&gt; &gt;
&gt;
&gt;
Reply | Threaded
Open this post in threaded view
|

Re: ddl

Jingsong Li
Hi,

底层实现的话可以参考下[1]

[1] https://github.com/apache/bahir-flink/tree/master/flink-connector-kudu

Best,
Jingsong Lee

On Thu, Mar 19, 2020 at 11:30 PM hiliuxg <[hidden email]> wrote:

> 你可以自己定义tablesinkfactory,flink已经预留了这个接口
>
>
>
>
> ------------------&nbsp;原始邮件&nbsp;------------------
> 发件人:&nbsp;"LakeShen"<[hidden email]&gt;;
> 发送时间:&nbsp;2020年3月14日(星期六) 中午11:13
> 收件人:&nbsp;"user-zh"<[hidden email]&gt;;
>
> 主题:&nbsp;Re: ddl
>
>
>
> Hi 志华,
> &nbsp;&nbsp;&nbsp;&nbsp; 你可以完全自己扩展 Flink SQL DDL 语法的功能,用来支持你们公司自己的实时数据源,或者
> Sink
> 等等,具体实现,请参考楼上 jinhai
> 的链接
>
> Best wishes,
> 沈磊
>
> jinhai wang <[hidden email]&gt; 于2020年3月13日周五 下午7:22写道:
>
> &gt; Page on “User-defined Sources &amp; Sinks”. For flink 1.10:
> &gt;
> https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/sourceSinks.html
> &gt; <
> &gt;
> https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/sourceSinks.html
> &gt; &gt;
> &gt;
> &gt; Best Regards
> &gt;
> &gt; [hidden email]
> &gt;
> &gt; &gt; 2020年3月13日 下午7:17,王志华 <[hidden email]&gt; 写道:
> &gt; &gt;
> &gt; &gt; 目前FLINK中对于DDL这块,它都只能什么类型的技术作为源头表或者SINK 表呢,我也网上也仅仅看到了ddl mysql
> sink、ddl
> &gt; hbase
> sink等。还有其他类型的支持吗?如果不支持的话,是否flink开放了相关的接口,可以提供对其他类型技术的ddl语法支持呢?比如想做一个
> &gt; ddl kudu sink之类的
> &gt; &gt;
> &gt; &gt;
> &gt; &gt; | |
> &gt; &gt; 王志华
> &gt; &gt; |
> &gt; &gt; |
> &gt; &gt; [hidden email]
> &gt; &gt; |
> &gt; &gt; 签名由网易邮箱大师定制
> &gt; &gt;
> &gt;
> &gt;



--
Best, Jingsong Lee