Skip to main content

remove (Function)

Function returns the updated list after removing the element with the specified value.

Syntax

<OBJECT> list:remove(<OBJECT> list, <OBJECT|INT|LONG|FLOAT|DOUBLE|BOOL|STRING> value)

Query Parameters

NameDescriptionDefault ValuePossible Data TypesOptionalDynamic
listThe list that needs to be updated.OBJECTNoYes
valueThe value of the element that needs to removed.OBJECT INT LONG FLOAT DOUBLE BOOL STRINGNoYes

Example 1

list:remove(stockSymbols, 'IBM')

The list:remove(stockSymbols, 'IBM') function removes the element IBM from the stockSymbols list and returns the updated list.

Example 2

CREATE STREAM StockStream (symbols OBJECT, symbolToRemove STRING);
CREATE SINK STREAM OutputStream (updatedSymbols OBJECT);

@info(name = 'RemoveSymbol')
INSERT INTO OutputStream
SELECT list:remove(symbols, symbolToRemove) AS updatedSymbols
FROM StockStream;

In this stream worker, an input stream StockStream is defined, which includes a list of stock symbols (symbols) and a symbol to remove (symbolToRemove). The function list:remove(symbols, symbolToRemove) operates on each event in the StockStream. This function processes the symbols attribute from each event and removes the specified symbolToRemove from the list. The updated list is then aliased as updatedSymbols and inserted into the OutputStream. Consequently, OutputStream contains the updated lists with the specified symbol removed from each event in the StockStream.