I am using wso2cep 4.1.0 and have created custom function extension class with following package name:
package org.wso2.siddhi.extension.custom;
.....
public class MyFunction extends FunctionExecutor {
.....
}
Then I have created file : custom.siddhiext
An put following entry into it.
mycount=org.wso2.siddhi.extension.custom.MyFunction
I have created jar including both of above files. I have created maven project for above.
Then i put this jar to /repository/components/dropins folder.
And restarted cep wso2server.
Now i am executing following execution plan: My execution plan:
from inputstream#window.timeBatch( 1 sec )
select custom:mycount(param1) as outparam
insert into outputstream;
On creating outputsteam i get following exception:
Exception when validating the stream, exception : 'mycount' is neither a function extension nor an aggregated attribute extension in execution plan "ExecutionPlan"
It seems like jar i put in dropin folder is not read by wso2server but i followed steps stated in [https://docs.wso2.com/display/CEP410/Writing+a+Custom+Function+Extension]
anybody have face similar issues or have solution for it.
During restart of wso2cepserver i get following ERROR:
ERROR {org.wso2.carbon.server.extensions.DropinsBundleDeployer} - Required Bundle manifest headers do not exists: /home/analytics/wso2cep-4.1 .0/repository/components/dropins/function-extension-1.0-SNAPSHOT.jar