跳到主要内容
版本:2.1.3

Replace

Description

Examines string value in a given field and replaces substring of the string value that matches the given string literal or regexes with the given replacement.

提示

This transform ONLY supported by Spark.

Options

nametyperequireddefault value
source_fieldstringnoraw_message
fieldsstringyes-
patternstringyes-
replacementstringyes-
is_regexbooleannofalse
replace_firstbooleannofalse

source_field [string]

Source field, if not configured, the default is raw_message

field [string]

The name of the field to replaced.

pattern [string]

The string to match.

replacement [string]

The replacement pattern (is_regex is true) or string literal (is_regex is false).

is_regex [boolean]

Whether or not to interpret the pattern as a regex (true) or string literal (false).

replace_first [boolean]

Whether or not to skip any matches beyond the first match.

common options [string]

Transform plugin common parameters, please refer to Transform Plugin for details

Examples

the word a will be replaced by b at message field values.

replace {
source_field = "message"
fields = "_replaced"
pattern = "a"
replacement = "b"
}

Use Replace as udf in sql.

  Replace {
fields = "_replaced"
pattern = "([^ ]*) ([^ ]*)"
replacement = "$2
isRegex = true
replaceFirst = true
}

# Use the split function (confirm that the fake table exists)
sql {
sql = "select * from (select raw_message, replace(raw_message) as info_row from fake) t1"
}