• 读Mysql表
    • 功能介绍
    • 参数说明
    • 脚本示例
      • mysql batch source
      • mysql stream source
      • mysql batch sink
      • mysql stream sink

    读Mysql表

    功能介绍

    读Mysql表

    参数说明

    名称 中文名称 描述 类型 是否必须？ 默认值
    inputTableName 输入表名字 输入表名字 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")