Siddhi Extensions

Siddhi language has a wide variety of extensions ranging from string processing to natural language processing. These extensions can be utilized in numerous scenarios to manipulate attributes with ease. When using extensions within Siddhi queries, you need to follow the convention of extensionName:functionName to refer to a particular extension. If the extension is of the Function type you can refer to it as shown in the following example in different parts of the query.

FROM inputStream[str:contains(description, "Pi-Value")]
SELECT id, math:round(math:pi()) as roundedPiValue
INSERT INTO outputStream;

If the extension is of the Stream Processor type, you can refer to it as follows.
#reorder:kslack(eventTimestamp). 

e.g., 

@info(name = 'query1') 
FROM inputStream#reorder:kslack(eventTimestamp) 
SELECT eventTimestamp, price, volume 
INSERT INTO outputStream;

The extensions that are currently available for Siddhi are as follows

• Time Series Extension
• Math Extension
• String Extension
• Geo Extension
• R Language Extension
• Regular Expression Extension
• Time Extension
• Natural Language Processing Extension
• Map Extension
• Reorder Extension
• Markov Models Extension
• PMML Based Predictive Analytics Extension
• Machine Learning Extension
• Kalman Filter Extension