Core
Macrometa core functions are described in the table below.
| Function | Description |
|---|---|
| and | Returns the results of AND operation for all the events. |
| avg | Calculates the average for all the events. |
| cast | Converts the first parameter according to the cast.to parameter. |
| coalesce | Returns the value of the first input parameter that is not null, and all input parameters have to be on the same type. |
| convert | Converts the first input parameter according to the convertedTo parameter. |
| count | Returns the count of all the events. |
| createSet | Includes the given input parameter in a java.util.HashSet and returns the set. |
| currentTimeMillis | Returns the current timestamp of stream processor application in milliseconds. |
| default | Checks if the attribute parameter is null and if so returns the value of the default parameter. |
| distinctCount | This returns the count of distinct occurrences for a given arg. |
| eventTimestamp | Returns the timestamp of the processed event. |
| frequency | Counts the number of occurrences of different values of a given attribute. |
| ifThenElse | Evaluates the condition parameter and returns value of the if.expression. |
| instanceOfBoolean | Checks whether the parameter is an instance of Boolean or not. |
| instanceOfDouble | Checks whether the parameter is an instance of Double or not. |
| instanceOfFloat | Checks if the parameter is an instance of Float or not. |
| instanceOfInteger | Checks whether the parameter is an instance of Integer or not. |
| instanceOfLong | Checks whether the parameter is an instance of Long or not. |
| instanceOfString | Checks whether the parameter is an instance of String or not. |
| log | Logs the message on the given priority with or without the processed event. |
| max | Returns the maximum value for all the events. |
| maxForever | This is the attribute aggregator to store the maximum value for a given attribute. |
| maximum | Returns the maximum value of the input parameters. |
| min | Returns the minimum value for all the events. |
| minForever | This is the attribute aggregator to store the minimum value for a given attribute throughout the lifetime of the query regardless of any windows. |
| minimum | Returns the minimum value of the input parameters. |
| or | Returns the results of OR operation for all the events. |
| pol2Cart (sizeOfSet - Stream) | The pol2Cart function calculating the cartesian coordinates x & y for the given theta. |
| sizeOfSet | Returns the size of an object of type java.util.Set. |
| stdDev | Returns the calculated standard deviation for all the events. |
| sum | Returns the sum for all the events. |
| unionSet | Union multiple sets. |
| uuid | Generates a UUID (Universally Unique Identifier). |