【发布时间】:2021-06-07 06:49:45
【问题描述】:
我需要为 spark.sql() 作业编写 REGEXP_REPLACE 查询。 如果值遵循以下模式,则仅提取第一个连字符之前的单词并将其分配给目标列“名称”,但如果模式不匹配,则应报告整个“名称”。
图案:
- 值应该用连字符分隔。任何值都可以出现在第一个连字符之前(无论是数字, 字母、特殊字符甚至空格)
- 第一个连字符后面应该紧跟两个单词,用连字符隔开(只能是数字, 字母或字母数字)(注意:不允许使用特殊字符和空格)
- 两个词后应接一个或多个数字,后接连字符。
- 最后一部分只能是一位或多位数字。
例如:
如果 name = abc45-dsg5-gfdvh6-9890-7685,则输出 REGEXP_REPLACE = abc45
如果 name = abc,则输出 REGEXP_REPLACE = abc
如果 name = abc-gf5-dfg5-asd5-98-00,则 REGEXP_REPLACE 的输出 = abc-gf5-dfg5-asd5-98-00
我有
spark.sql("SELECT REGEXP_REPLACE(name , '-[^-]+-\\w{2}-\\d+-\\d+$','',1,1,'i') AS name").show();
但它不起作用。
【问题讨论】:
-
尝试使用regexp_extract 和模式
^(?:[^-\s]+(?=-\w+-\w+\d+-\d+-\d+$)|\S+)来匹配所需的字符串。见regex101.com/r/BeCTRF/1
标签: sql regex apache-spark apache-spark-sql regexp-replace