检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
'connector.username' = '', 'connector.password' = '' ); 参数说明 表1 参数说明 参数 是否必选 说明 connector.type 是 connector类型，需配置为'gaussdb' connector.url 是 jdbc
watermark-strategy_expression) ) with ( 'connector' = 'datagen' ); 参数说明 表2 参数说明 参数 是否必选 默认值 数据类型 参数说明 connector 是 无 String 指定要使用的连接器，这里是'datagen'。 rows-per-second
kafka_topic = "", encode = "json", json_config="" ); 关键字 表1 关键字说明 参数 是否必选 说明 type 是 数据源类型，“Kafka”表示数据源。 kafka_bootstrap_servers 是 Kafka的连接端口
properties文件中localFilePath配置的本地路面中。 -s,--skip-upload-resources <all | app | deps> 是否跳过，将jar包、Python程序文件、配置文件上传到OBS和加载到DLI服务端资源列表。当相关资源文件已经加载到DLI服务资源列表中，可以使用该参数跳过该步骤。
= 'clickhouse', 'url' = '', 'table-name' = '' ); 参数说明 表2 参数说明 参数 是否必选 默认值 数据类型 说明 connector 是 无 String 固定为：clickhouse url 是 无 String ClickHouse的url。
的具体格式通过调用ImportJob对象的setCsvFormatInfo接口进行设置。 在提交导入作业前，可选择设置导入数据的分区并配置是否是overwrite写入，分区信息可以调用ImportJob对象的setPartitionSpec接口设置，如：importJob.setPartitionSpec(new
dump_interval = "", dis_notice_channel = "" ) 关键字 表1 关键字说明 参数 是否必选 说明 type 是 输出通道类型，“obs”表示输出到对象存储服务。 region 是 对象存储服务所在区域。 ak 否 访问密钥ID(Access
dump_interval = "", dis_notice_channel = "" ) 关键字 表1 关键字说明 参数 是否必选 说明 type 是 输出通道类型，“obs”表示输出到对象存储服务。 region 是 对象存储服务所在区域。 ak 否 访问密钥ID(Access
avro-confluent.subject 参数来指定。 支持的connector kafka upsert kafka 参数说明 表1 参数说明 参数 是否必选 默认值 类型 说明 format 是 无 String 指定使用格式，此处使用'avro-confluent'。 avro-confluent
= '', 'scan.startup.mode' = '', 'format' = '' ); 参数说明 表1 参数说明 参数 是否必选 默认值 数据类型 参数说明 connector 是 无 String 指定要使用的连接器，固定为'kafka'。 topic 是 无
= '', 'scan.startup.mode' = '', 'format' = '' ); 参数说明 表1 参数说明 参数 是否必选 默认值 数据类型 参数说明 connector 是 无 String 指定要使用的连接器，固定为'kafka'。 topic 是 无
'properties.bootstrap.servers' = '', 'format' = '' ); 参数说明 表1 参数说明 参数 是否必选 默认参数 数据类型 说明 connector 是 无 string 固定值为：kafka。 topic 是 无 string 结果表对应topic名称。
'properties.bootstrap.servers' = '', 'format' = '' ); 参数说明 表1 参数说明 参数 是否必选 默认参数 数据类型 说明 connector 是 无 string 固定值为：kafka。 topic 是 无 string 结果表对应topic名称。
'table-name' = '', 'username' = '', 'password' = '' ); 参数说明 表1 参数说明 参数 是否必选 默认值 数据类型 说明 connector 是 无 String connector类型，需配置为'gaussdb'。 url 是 无
'table-name' = '', 'username' = '', 'password' = '' ); 参数说明 表1 参数说明 参数 是否必选 默认值 数据类型 说明 connector 是 无 String connector类型，需配置为'gaussdb'。 url 是 无
'table-name' = '', 'username' = '', 'password' = '' ); 参数说明 表1 参数说明 参数 是否必选 默认值 数据类型 说明 connector 是 无 String connector类型，需配置为'gaussdb'。 url 是 无
= '', 'key.format' = '', 'value.format' = '' ); 参数说明 表1 参数说明 参数 是否必选 默认参数 数据类型 说明 connector 是 (none) String connector类型，对于upsert kafka，需配置为'upsert-kafka'。
2', 'table-name' = '', 'zookeeper.quorum' = '' ); 参数说明 表1 参数说明 参数 是否必选 默认值 数据 说明 connector 是 无 String 指定使用的连接器，需配置为：hbase-2.2。 table-name
2', 'table-name' = '', 'zookeeper.quorum' = '' ); 参数说明 表1 参数说明 参数 是否必选 默认值 数据 说明 connector 是 无 String 指定使用的连接器，需配置为：hbase-2.2。 table-name
2', 'table-name' = '', 'zookeeper.quorum' = '' ); 参数说明 表1 参数说明 参数 是否必选 默认值 数据 说明 connector 是 无 String 指定使用的连接器，需配置为：hbase-2.2。 table-name
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
