我正在尝试使用Esper Dataflows做一些测试,所以我正在使用Esper Dataflows提供的Select运算符编写一些模式。但是我没有让它工作。我正在尝试执行以下代码:

    public class BenchmarkEvent {
    long ReceivedTimestamp;
    long ProcessedTimestamp;

    String atr1;
    String atr2;
    String atr3;

    String getAtr1() {
        return atr1;
    }

}


然后,我要编译的句子:

 "Select(demostream) -> outdemostream {"
                + "     select: (select * from demostream"
                + "              where demostream.atr1 = \"Attribute\") }" +


最后,我得到的错误是:

Failed to obtain operator 'Select': Error validating expression: Failed to validate filter expression 'demostream.getAtr1="Attribute"': Failed to resolve property 'demostream.getAtr1' to a stream or nested property in a stream


有办法使它起作用吗?提前致谢

最好的祝福,
伊万

最佳答案

试试这个。事件类型名称通常可以用于属性名称的前缀,但是似乎编译器不允许它用于数据流运算符。
不需要首先使用前缀。

select * from demostream where atr1 = \"Attribute\"

10-08 15:59