代码拉取完成，页面将自动刷新
CREATE TABLE tableName(
colName colType,
...
colNameX colType
)WITH(
type ='mongo',
address ='ip:port[,ip:port]',
userName ='userName',
password ='pwd',
database ='databaseName',
tableName ='tableName',
parallelism ='parllNum'
);
mongo-3.8.2
| 参数名称 | 含义 |
|---|---|
| tableName | 在 sql 中使用的名称;即注册到flink-table-env上的名称 |
| colName | 列名称 |
| colType | 列类型 colType支持的类型 |
| 参数名称 | 含义 | 是否必填 | 默认值 |
|---|---|---|---|
| type | 表明 输出表类型 mongo | 是 | |
| address | 连接mongo数据库 jdbcUrl | 是 | |
| userName | mongo连接用户名 | 否 | |
| password | mongo连接密码 | 否 | |
| tableName | mongo表名称 | 是 | |
| database | mongo表名称 | 是 | |
| parallelism | 并行度设置 | 否 | 1 |
CREATE TABLE MyResult(
channel VARCHAR,
pv VARCHAR
)WITH(
type ='mongo',
address ='172.21.32.1:27017,172.21.32.1:27017',
userName ='dtstack',
password ='abc123',
database ='test',
tableName ='pv',
parallelism ='1'
)
此处可能存在不合适展示的内容，页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容，可点击提交进行申诉，我们将尽快为您处理。
马建仓 AI 助手