赞
踩
Flink 版本:1.10.3
在执行如下自定义 Socket Connector 示例:
// 创建 Socket Source 表
String sourceSql = "CREATE TABLE socket_source_table (\n" +
" word STRING COMMENT '单词'\n" +
") WITH (\n" +
" 'connector.type' = 'socket',\n" +
" 'host' = 'localhost',\n" +
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。