I use wso2cep 4.1.0 and created my own function extension class with the following package name:
package org.wso2.siddhi.extension.custom;
.....
public class MyFunction extends FunctionExecutor {
.....
}
Then I created the file: custom.siddhiext
Insert the following entry into it.
mycount=org.wso2.siddhi.extension.custom.MyFunction
I created a jar that includes both of the above files. I created a maven project for above.
Then I put this jar in the / repository / components / dropins folder.
And restarted cep wso2server.
Now I am executing the following execution plan:
My execution plan:
from inputstream
select custom:mycount(param1) as outparam
insert into outputstream;
When creating outputsteam, I get the following exception:
Exception when checking the flow, exception: "mycount" is not a function extension or an extension of the aggregated attribute in the execution plan "ExecutionPlan"
, jar, dropin, wso2server, , [https://docs.wso2.com/display/CEP410/Writing+a+Custom+Function+Extension]
- .
wso2cepserver :
ERROR {org.wso2.carbon.server.extensions.DropinsBundleDeployer} - Bundle :/home/analytics/wso2cep-4.1.0/repository/components/dropins/function-extension-1.0-SNAPSHOT.jar