RDS
更新时间：2021-06-24
RDS DDL
CREATE TABLE rds_table (
`field01` STRING,
`field02` BIGINT,
`field03` FLOAT,
`field04` BINARY,
`field05` INT,
`field06` TINYINT,
`field07` BOOLEAN,
`field08` DATA,
`field09` DOUBLE,
`field10` SMALLINT
) WITH (
'connector.type' = 'RDS',
'connector.url' = 'jdbc:mysql://localhost:3306/flink-test',
'connector.table' = 'jdbc_table_name',
'connector.driver' = 'com.mysql.jdbc.Driver',
'connector.username' = 'asc_test',
'connector.password' = 'asc_1234'
);
RDS 参数设置
| 名称 | 简称 | 必填 | 用例 | SPARK | FLINK | 说明 |
|---|---|---|---|---|---|---|
| connector.type | type | Y | RDS |
Y | Y | 服务类型 |
| connector.scan | scan | STREAM / STATIC， 默认 STREAM |
Y | Y | 数据读取形式，仅用于STREAM类型的作业中，流表join时生效 | |
| connector.emit | emit | BATCH / STREAM， 默认 STREAM |
Y | Y | 数据输出形式 | |
| connector.url | url | Y | jdbc:mysql://localhost:3306/flink-test |
Y | Y | JDBC/RDS DB 地址 |
| connector.table | table | Y | jdbc_table_name |
Y | Y | JDBC/RDS 表名 |
| connector.driver | driver | com.mysql.jdbc.Driver |
Y | Y | JDBC/RDS 驱动类名 | |
| connector.username | username | Y | bsc_test |
Y | Y | JDBC/RDS 用户密码 |
| connector.password | password | Y | bsc_1234 |
Y | Y | JDBC/RDS 用户密码 |
