Scalar Functions
The following are scalar functions for KSQL.
| Function | Example | Description |
|---|---|---|
| ABS | ABS(col1) | Absolute value of a value. |
| CEIL | CEIL(col1) | Ceiling of a value. |
| CONCAT | CONCAT(col1, '_hello') | Concatenate two strings. |
| EXTRACTJSONFILELD | EXTRACTJSONFIELD(message, '$.log.cloud') | Given a sring column in JSON format, extract the field that matches. |
| ARRAYCONTAINS | ARRAYCONTAINS('[1, 2, 3]', 3 | Given a JSON or AVRO array, checks if a search value is contained in it. |
| FLOOR | FLOOR(col1) | Floor of a value. |
| LCASE | LCASE(col1) | Convert a string to lowercase. |
| LEN | LEN(col1) | Length of a string. |
| RANDOM | RANDOM() | Returns a random DOUBLE value between 0 and 1.0 |
| ROUND | ROUND(col1 | Round a value to the nearest BIGINT value. |
| STRINGTOTIMESTAMP | STRINGTOTIMESTAMP(col1, 'yyyy-MM-dd HH:mm:ss.SSS') | Converts a string value in the given format into the BIGINT value representing the timestamp. |
| SUBSTRING | SUBSTRING(col1, 2, 5) | Returns the substring with the start and end indices. |
| TIMESTAMPTOSTRING | TIMESTAMPTOSTRING(ROWTIME, 'yyyy-MM-dd HH:mm:ss.SSS') | Converts a BIGINT timestamp value into the string representation of the timestamp in the given format. |
| TRIM | TRIM(col1) | Trim the spaces from the beginning and the end of the string. |
| CASE | CASE(col1) | Convert a string to uppercase. |