2

Siddhi でサンプル プロジェクトを実装しようとしています。1 つの属性を持つ入力イベント ストリームがありますheight。sequence同じ高さのイベントが 3 つ連続する場合にコールバックを返すクエリを作成したいと考えています。これとこのブログを参照しましたが、正しい構文を取得できません。SiddhiParserExceptionシーケンスクエリを実行しようとすると取得しています。

これは、正常に機能する対応するパターン クエリです。

executionPlan = "" +
                "define stream cseEventStream (height int); " +
                "" +
                "@info(name = 'query1') " +
                "from every e1 =  cseEventStream " +
                "-> e2 = cseEventStream[e1.height == e2.height]" +
                "-> e3 = cseEventStream[e2.height == e3.height] "+
                "select e1.height as height1, e2.height as height2, e3.height as height3  " + 
                "insert into outputStream ;";

以下は、2 つの連続した等しい高さを取得するシーケンス クエリを作成する方法ですが、正しく取得できません。

executionPlan = "" +
                "define stream cseEventStream (height int); " +
                "" +
                "@info(name = 'query1') " +
                "from every e1 =  cseEventStream, e2 = cseEventStream[e1.height == height]" +
                "select e1.height as height1, e2.height as height2" + 
                "insert into outputStream ;";

エラー ログの追加:

java.lang.reflect.InvocationTargetException
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:497)
at org.codehaus.mojo.exec.ExecJavaMojo$1.run(ExecJavaMojo.java:293)
at java.lang.Thread.run(Thread.java:745)
Caused by: org.wso2.siddhi.query.compiler.exception.SiddhiParserException: You have an error in your SiddhiQL at line 1:195, extraneous input 'into' expecting {',', GROUP, HAVING, INSERT, DELETE, UPDATE, RETURN, OUTPUT}
at org.wso2.siddhi.query.compiler.internal.SiddhiErrorListener.syntaxError(SiddhiErrorListener.java:36)
at org.antlr.v4.runtime.ProxyErrorListener.syntaxError(ProxyErrorListener.java:65)
at org.antlr.v4.runtime.Parser.notifyErrorListeners(Parser.java:566)
at org.antlr.v4.runtime.DefaultErrorStrategy.reportUnwantedToken(DefaultErrorStrategy.java:375)
at org.antlr.v4.runtime.DefaultErrorStrategy.sync(DefaultErrorStrategy.java:273)
at org.wso2.siddhi.query.compiler.SiddhiQLParser.query_section(SiddhiQLParser.java:3702)
at org.wso2.siddhi.query.compiler.SiddhiQLParser.query(SiddhiQLParser.java:1903)
at org.wso2.siddhi.query.compiler.SiddhiQLParser.execution_element(SiddhiQLParser.java:619)
at org.wso2.siddhi.query.compiler.SiddhiQLParser.execution_plan(SiddhiQLParser.java:550)
at org.wso2.siddhi.query.compiler.SiddhiQLParser.parse(SiddhiQLParser.java:152)
at org.wso2.siddhi.query.compiler.SiddhiCompiler.parse(SiddhiCompiler.java:63)
at org.wso2.siddhi.core.SiddhiManager.createExecutionPlanRuntime(SiddhiManager.java:61)
at mainpkg.DriverClass.initiateExecutionPlan(DriverClass.java:54)
at mainpkg.DriverClass.main(DriverClass.java:37)

どんな助けでも大歓迎です。

4

1 に答える 1

2

私は問題を解決することができました。文字列セグメントの末尾にスペースがありませんでした。「]」と「height2」の後の5行目と6行目の最後のスペースに注意してください

executionPlan = "" +
                "define stream cseEventStream (height int); " +
                "" +
                "@info(name = 'query1') " +
                "from every e1 =  cseEventStream, e2 = cseEventStream[e1.height == height] " +
                "select e1.height as height1, e2.height as height2 " + 
                "insert into outputStream ;";
于 2016-02-05T08:35:36.487 に答える