You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by 王志华 <a1...@163.com> on 2020/03/13 11:17:56 UTC
ddl
目前FLINK中对于DDL这块，它都只能什么类型的技术作为源头表或者SINK 表呢，我也网上也仅仅看到了ddl mysql sink、ddl hbase sink等。还有其他类型的支持吗？如果不支持的话，是否flink开放了相关的接口，可以提供对其他类型技术的ddl语法支持呢？比如想做一个 ddl kudu sink之类的
| |
王志华
|
|
a15733178518@163.com
|
签名由网易邮箱大师定制
Re: ddl
Posted by 王志华 <a1...@163.com>.
好的 感谢
| |
王志华
|
|
a15733178518@163.com
|
签名由网易邮箱大师定制
On 03/14/2020 11:13，LakeShen<sh...@gmail.com> wrote：
Hi 志华，
你可以完全自己扩展 Flink SQL DDL 语法的功能，用来支持你们公司自己的实时数据源，或者 Sink
等等，具体实现，请参考楼上 jinhai
的链接
Best wishes,
沈磊
jinhai wang <ji...@gmail.com> 于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
jinhai.me@gmail.com
2020年3月13日 下午7:17，王志华 <a1...@163.com> 写道：
目前FLINK中对于DDL这块，它都只能什么类型的技术作为源头表或者SINK 表呢，我也网上也仅仅看到了ddl mysql sink、ddl
hbase sink等。还有其他类型的支持吗？如果不支持的话，是否flink开放了相关的接口，可以提供对其他类型技术的ddl语法支持呢？比如想做一个
ddl kudu sink之类的
| |
王志华
|
|
a15733178518@163.com
|
签名由网易邮箱大师定制
Re: ddl
Posted by Jingsong Li <ji...@gmail.com>.
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 <73...@qq.com> wrote:
> 你可以自己定义tablesinkfactory，flink已经预留了这个接口
>
>
>
>
> ------------------ 原始邮件 ------------------
> 发件人: "LakeShen"<shenleifighting@gmail.com>;
> 发送时间: 2020年3月14日(星期六) 中午11:13
> 收件人: "user-zh"<user-zh@flink.apache.org>;
>
> 主题: Re: ddl
>
>
>
> Hi 志华，
> 你可以完全自己扩展 Flink SQL DDL 语法的功能，用来支持你们公司自己的实时数据源，或者
> Sink
> 等等，具体实现，请参考楼上 jinhai
> 的链接
>
> Best wishes,
> 沈磊
>
> jinhai wang <jinhai.me@gmail.com> 于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
> >
> > jinhai.me@gmail.com
> >
> > > 2020年3月13日 下午7:17，王志华 <a15733178518@163.com> 写道：
> > >
> > > 目前FLINK中对于DDL这块，它都只能什么类型的技术作为源头表或者SINK 表呢，我也网上也仅仅看到了ddl mysql
> sink、ddl
> > hbase
> sink等。还有其他类型的支持吗？如果不支持的话，是否flink开放了相关的接口，可以提供对其他类型技术的ddl语法支持呢？比如想做一个
> > ddl kudu sink之类的
> > >
> > >
> > > | |
> > > 王志华
> > > |
> > > |
> > > a15733178518@163.com
> > > |
> > > 签名由网易邮箱大师定制
> > >
> >
> >
--
Best, Jingsong Lee
回复： ddl
Posted by hiliuxg <73...@qq.com>.
你可以自己定义tablesinkfactory，flink已经预留了这个接口
------------------ 原始邮件 ------------------
发件人: "LakeShen"<shenleifighting@gmail.com>;
发送时间: 2020年3月14日(星期六) 中午11:13
收件人: "user-zh"<user-zh@flink.apache.org>;
主题: Re: ddl
Hi 志华，
你可以完全自己扩展 Flink SQL DDL 语法的功能，用来支持你们公司自己的实时数据源，或者 Sink
等等，具体实现，请参考楼上 jinhai
的链接
Best wishes,
沈磊
jinhai wang <jinhai.me@gmail.com> 于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
>
> jinhai.me@gmail.com
>
> > 2020年3月13日 下午7:17，王志华 <a15733178518@163.com> 写道：
> >
> > 目前FLINK中对于DDL这块，它都只能什么类型的技术作为源头表或者SINK 表呢，我也网上也仅仅看到了ddl mysql sink、ddl
> hbase sink等。还有其他类型的支持吗？如果不支持的话，是否flink开放了相关的接口，可以提供对其他类型技术的ddl语法支持呢？比如想做一个
> ddl kudu sink之类的
> >
> >
> > | |
> > 王志华
> > |
> > |
> > a15733178518@163.com
> > |
> > 签名由网易邮箱大师定制
> >
>
>
Re: ddl
Posted by LakeShen <sh...@gmail.com>.
Hi 志华，
你可以完全自己扩展 Flink SQL DDL 语法的功能，用来支持你们公司自己的实时数据源，或者 Sink
等等，具体实现，请参考楼上 jinhai
的链接
Best wishes,
沈磊
jinhai wang <ji...@gmail.com> 于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
>
> jinhai.me@gmail.com
>
> > 2020年3月13日 下午7:17，王志华 <a1...@163.com> 写道：
> >
> > 目前FLINK中对于DDL这块，它都只能什么类型的技术作为源头表或者SINK 表呢，我也网上也仅仅看到了ddl mysql sink、ddl
> hbase sink等。还有其他类型的支持吗？如果不支持的话，是否flink开放了相关的接口，可以提供对其他类型技术的ddl语法支持呢？比如想做一个
> ddl kudu sink之类的
> >
> >
> > | |
> > 王志华
> > |
> > |
> > a15733178518@163.com
> > |
> > 签名由网易邮箱大师定制
> >
>
>
Re: ddl
Posted by jinhai wang <ji...@gmail.com>.
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
jinhai.me@gmail.com
> 2020年3月13日 下午7:17，王志华 <a1...@163.com> 写道：
>
> 目前FLINK中对于DDL这块，它都只能什么类型的技术作为源头表或者SINK 表呢，我也网上也仅仅看到了ddl mysql sink、ddl hbase sink等。还有其他类型的支持吗？如果不支持的话，是否flink开放了相关的接口，可以提供对其他类型技术的ddl语法支持呢？比如想做一个 ddl kudu sink之类的
>
>
> | |
> 王志华
> |
> |
> a15733178518@163.com
> |
> 签名由网易邮箱大师定制
>