检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
specific-offsets 否 无 String 在scan.startup.mode参数指定为'specific-offsets'模式下生效,为每个分区指定偏移量,例如:partition:0,offset:42;partition:1,offset:300'。 scan
specific-offsets 否 无 String 在scan.startup.mode参数指定为'specific-offsets'模式下生效,为每个分区指定偏移量,例如:partition:0,offset:42;partition:1,offset:300'。 scan
REGEXP(string1, string2) BOOLEAN 对指定的字符串执行一个正则表达式搜索,并返回一个BOOLEAN值表示是否找到指定的匹配模式。若找到,则返回TRUE。其中string1表示指定的字符串,string2表示正则表达式 若存在参数为null,则返回null REVERSE(string)
REGEXP(string1, string2) BOOLEAN 对指定的字符串执行一个正则表达式搜索,并返回一个BOOLEAN值表示是否找到指定的匹配模式。若找到,则返回TRUE。其中string1表示指定的字符串,string2表示正则表达式 若存在参数为null,则返回null REVERSE(string)
REGEXP(string1, string2) BOOLEAN 对指定的字符串执行一个正则表达式搜索,并返回一个BOOLEAN值表示是否找到指定的匹配模式。若找到,则返回TRUE。其中string1表示指定的字符串,string2表示正则表达式 若存在参数为null,则返回null REVERSE(string)
REGEXP(string1, string2) BOOLEAN 对指定的字符串执行一个正则表达式搜索,并返回一个BOOLEAN值表示是否找到指定的匹配模式。若找到,则返回TRUE。其中string1表示指定的字符串,string2表示正则表达式 若存在参数为null,则返回null REVERSE(string)
schema-syntax取值约束详见schema-syntax取值约束说明。 deploy-mode 否 standalone String redis集群的部署模式,支持standalone、master-replica、cluster。默认为standalone。 retry-count 否 5 Integer
schema-syntax取值约束详见schema-syntax取值约束说明。 deploy-mode 否 standalone String redis集群的部署模式,支持standalone、master-replica、cluster,默认standalone。 retry-count 是 5 Integer
schema-syntax取值约束详见schema-syntax取值约束说明。 deploy-mode 否 standalone String redis集群的部署模式,支持standalone、master-replica、cluster,默认standalone。 retry-count 是 5 Integer
datasource.com:3306/postgreDB dbtable 访问MySQL集群填写"数据库名.表名",访问PostGre集群填写"模式名.表名"。 说明: 如果数据库和表不存在,请先创建数据库和表,否则系统会报错并且运行失败。 user RDS数据库用户名。 password
schema-syntax取值约束详见schema-syntax取值约束说明。 deploy-mode 否 standalone String redis集群的部署模式,支持standalone、master-replica、cluster。默认为standalone。 retry-count 否 5 Integer
urce_disQFXD sinkChannel=xx # dis消费组,需要提前在dis的Apps中创建 groupId=xx # 消费模式,从最开始消费或者EARLIEST从最新开始消费LATEST startOffset=LATEST # flink保存checkpoint的路径
的延迟时间,每到达一个迟到数据,则更新窗口的输出结果 注意事项 若使用insert语句将结果写入sink中,则sink需要支持upsert模式,所以结果表需要支持upsert操作,且定义主键。 延迟时间设置仅用于事件时间,在处理时间中不生效。 辅助函数必须使用与 GROUP BY
的延迟时间,每到达一个迟到数据,则更新窗口的输出结果 注意事项 若使用insert语句将结果写入sink中,则sink需要支持upsert模式,所以结果表需要支持upsert操作,且定义主键。 延迟时间设置仅用于事件时间,在处理时间中不生效。 辅助函数必须使用与 GROUP BY
延迟时间,每到达一个迟到数据,则更新窗口的输出结果 注意事项 如果使用insert语句将结果写入sink中,则sink需要支持upsert模式,所以结果表需要支持upsert操作,且定义主键。 延迟时间设置仅用于事件时间,在处理时间中不生效。 辅助函数必须使用与 GROUP BY
在物化后的 changelog 上主键具有唯一性。定义的主键将决定哪些字段出现在Kafka消息的key中。 由于该连接器以 upsert 的模式工作,该连接器作为 source 读入时,可以确保具有相同主键值下仅最后一条消息会生效。 数据类型的使用,请参考Format章节。 语法格式
schema-syntax取值约束详见schema-syntax取值约束说明。 deploy-mode 否 standalone String redis集群的部署模式,支持standalone、master-replica、cluster,默认standalone。 该值可参考redis集群的实例类型介绍。
schema-syntax取值约束详见schema-syntax取值约束说明。 deploy-mode 否 standalone String redis集群的部署模式,支持standalone、master-replica、cluster,默认standalone。 该值可参考redis集群的实例类型介绍。