写Mysql表

功能介绍

写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")