功能介绍

写Mysql表

参数说明

名称 中文名称 描述 类型 是否必须？ 默认值
outputTableName 输出表名字 输出表名字 String ✓
dbName 数据库名字 数据库名字 String ✓
ip IP地址 IP地址 String ✓
password 密码 密码 String ✓
port 端口 端口 String ✓
username 用户名 用户名 String ✓

脚本示例

mysql batch source

  1. data = MySqlSourceBatchOp()\
  2.      .setDbName("alink")\
  3.      .setUsername("alink")\
  4.      .setPassword(passwd)\
  5.      .setIp("***")\
  6.      .setPort("20001")\
  7.      .setInputTableName("test")

mysql stream source

  1. data = MySqlSourceStreamOp()\
  2.      .setDbName("alink")\
  3.      .setUsername("alink")\
  4.      .setPassword(passwd)\
  5.      .setIp("***")\
  6.      .setPort("20001")\
  7.      .setInputTableName("test")

mysql batch sink

  1. data = MySqlSourceBatchOp()\
  2.      .setDbName("alink")\
  3.      .setUsername("alink")\
  4.      .setPassword(passwd)\
  5.      .setIp("***")\
  6.      .setPort("20001")\
  7.      .setOutputTableName("test_out")

mysql stream sink

  1. data = MySqlSourceStreamOp()\
  2.      .setDbName("alink")\
  3.      .setUsername("alink")\
  4.      .setPassword(passwd)\
  5.      .setIp("***")\
  6.      .setPort("20001")\
  7.      .setOutputTableName("test_out")