如何将自定义表源和自定义表接收器与SQL客户端集成?-问答-阿里云开发者社区-阿里云

开发者社区> flink小助手> 正文

如何将自定义表源和自定义表接收器与SQL客户端集成?

2018-12-10 13:42:39 1604 1

假设我们定义了一个自定义的TableSource和TableSink,那么如何与SQL Client集成?我是否需要手动注册下面的自定义TableSource Sink名称?如果不手动注册,连接器类型custom1 map 如何与custom1TableSource相关?

StreamTableEnvironment tableEnv = TableEnvironment.getTableEnvironment(env);
TableSource custom1TableSource = new custom1TableSource ( );
tableEnv.registerTableSource("custom1", custom1TableSource);
然后配置下面的环境文件?

tables:

  - name: custom1TableSource
    type: Source
    update-mode: append
    connector:
      property-version: 1
      type: ***custom1****

我声明的源和接收器:

package com.abc;
public static class custom1TableSource implements StreamTableSource, DefinedRowtimeAttributes, DefinedProctimeAttribute {

package com.abc;
public static class custom1TableSink implements TableSink, AppendStreamTableSink {
https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/table/sqlClient.html#configuration

更新:

在从源代码检查后,我发现Flink通过实现StreamTableSinkFactory和ServiceLoader创建的Factory创建接收器和源实例,但是如何将接收器和源名称注册到TableSource和TabSink类?

取消 提交回答
全部回答(1)
  • flink小助手
    2019-07-17 23:19:14

    SQL Client和Table&SQL API TableFactory都使用Java的服务提供程序接口(SPI)发现的所谓的s。

    0 0
相关问答

3

回答

请教一个范围查询的问题

小文文文 2019-06-14 14:37:01 115017浏览量 回答数 3

4

回答

Spark 【问答合集】

社区小助手 2019-05-29 14:13:40 123644浏览量 回答数 4

9

回答

【精品问答合集】Hbase热门问答

hbase小能手 2019-05-29 14:37:26 120207浏览量 回答数 9

38

回答

干货分享:DBA专家门诊一期:索引与sql优化问题汇总

xiaofanqie 2014-12-25 15:13:38 91749浏览量 回答数 38

1

回答

通过spark-thriftserver读取hive表执行sql时,tasks 数量怎么设置

游客iwhrjhvjoyqts 2019-07-05 15:30:22 113842浏览量 回答数 1

38

回答

[@饭娱咖啡][¥20]对于慢sql有没有什么比较实用的诊断和处理方法?

江小白太白 2018-10-30 18:47:38 141631浏览量 回答数 38

1

回答

在flink集群模式下,能不能指定某个节点的solt来执行一个task?

孙goku 2019-07-01 15:19:09 113328浏览量 回答数 1

2

回答

mySQL数据库报错You have an error in your SQL syntax

落地花开啦 2016-02-14 16:09:24 126059浏览量 回答数 2

7

回答

flink sql 支持checkpoints吗?

游客izljdlkgbdwfc 2019-07-10 17:46:37 121092浏览量 回答数 7

78

回答

【2013.9.5修正版图文】新手如何使用阿里云(linux)服务器建站(搬站)

姑苏公子 2013-04-11 00:39:13 107721浏览量 回答数 78
+关注
flink小助手
flink小助手会定期更新直播回顾等资料和文章干货,还整合了大家在钉群提出的有关flink的问题及回答。
0
文章
377
问答
问答排行榜
最热
最新
推荐问答
相关电子书
更多
文娱运维技术
立即下载
《SaaS模式云原生数据仓库应用场景实践》
立即下载
《看见新力量:二》电子书
立即下载