Failed to execute custom function extension in wso2 cep

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#window.timeBatch( 1 sec )

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

+4
2

, maven-bundle-plugin . , pOM , maven-bundle-plugin.

, Bundle-SymbolicName . , .

( Carbon 4.4.3 DropinsBundleDeployer, , dropins), :

  • Bundle-SymbolicName
  • Bundle-Version .

, , Bundle-SymbolicName in config , Bundle-Version. maven-bundle-plugin.

+1

, org.wso2.siddhi.extension.custom? , .

0

Source: https://habr.com/ru/post/1655464/


All Articles