我正在尝试使用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\"