MySQL Input Connector


链接库路径为'MySQLInputConnector。默认ID为'mysqlin'。 支持参数:

  • jdbc_url: (必需提供) STRING格式。 连接的JDBC URL。
  • jdbc_username: (必需提供) STRING格式。 连接的用户名。
  • jdbc_password: (必需提供) STRING格式。 连接的密码。
  • table_name: (非必需) STRING格式。 读入表的表名。表名可以为部分(table)或全名(如 db.table)。 table_name或query其中必需有一个提供而且只能有一个提供。
  • query: (非必需) STRING格式。 读入查询的语句。 table_name或query其中必需有一个提供而且只能有一个提供。
  • input_method: (非必需) STRING格式。 读入数据的方法。支持的方法包括 'value.range', 'partition.range'。 默认值为 'value.range'。
  • database_name: (非必需) STRING格式。读入表的数据库名。默认值为空(连接用户的默认数据库)。如果table_name为全名格式,这个参数会被忽略。
  • split_by_column: (非必需) STRING格式。 拆分列名,用表其中一列的值来拆分数据和并行读入。默认值为表的第一列。
  • conditions: (非必需) STRING格式。 读入表时的过滤条件。
  • order_by: (非必需) STRING格式。 读入表的时排序条件,多条件以逗号分隔。
  • batch_size: (非必需) INT格式。 每批读入的最大数据行数。默认值为 80000。
  • use_staging: (非必需) BOOLEAN格式。 是否用临时表来存储中间结果。当读表的时候这个值默认为FALSE,读查询的时候这个值默认为TRUE。
  • stage_database_name: (非必需) STRING格式。 临时表的数据库名。当读表的时候,默认值为与表一样的database;当读查询的时候,默认值为用户的默认database。
  • stage_table_name: (非必需) STRING格式。 临时表的表名。
  • password_decrypt_class: (非必需) STRING格式。 解密密码的class名。
  • jdbc_driver_class: (非必需) STRING格式。 连接数据库的JDBC Driver Class名。默认值为'com.mysql.jdbc.Driver'。