如何解决Esper:在命名窗口中按值分组,然后使用此分组的值确定输出ID
我想创建一个命名窗口,该窗口需要最后20秒的速度设置(1-10)和功率输出(浮动)。然后,我想查询它以获取每速度设置的平均功率(从1到10)。对于每个速度设置,我需要指定一个特定的输出ID。我尝试使用表达式将速度转换为此输出ID,但是无论采用哪种方式,都会收到错误消息“表达式需要流名称作为参数”。
谁能指出正确的表达式+如何使用该表达式以获得我想要的输出?
如果您可以指出一种更好的方法,那也很好。我是一个超级新手,而且不懂Java,而且我正在具有CEP堆栈的服务器上运行这些脚本,我不知道到底发生了什么,所以我发现很难进行故障排除!
CREATE expression getoutput {
speed =>
when speed = 1 then 4000
when speed = 2 then 5000
....
};
CREATE window Power.win:time(20 sec) as (power double,speed int);
INSERT into PortPower
SELECT
powerEvent.value as power,cast(speedSetting.value,int) as speed
FROM
Event(id = 1000).std:lastevent() as powerEvent,Event(id = 2000).std:lastevent() as speedEvent;
INSERT into Event
SELECT
getoutput(powerEvent.speed) as id,avg(PowerEvent.power) as value
FROM
Power as PowerEvent
GROUP BY
PowerEvent.speed
HAVING
count(PowerEvent.speed) > 0;
解决方法
“表达式需要将流名称作为参数”是我认为的较旧版本错误消息,一种EPL版本,仅允许表达式参数使用流名称。尝试使用不受此限制的当前版本。
您的EPL进行得比问题所要求的要多。当问一个问题时,最好只关注与特定问题有关的公正而唯一的问题。请编辑问题,并删除所有不相关的内容。每个帖子问一个明确的最小问题可以帮助我节省时间。
由于您坚持使用旧版本,因此可以像这样使用插入:
insert into ResultStream select ... from ....
select ...,case when speed = 1 then 4000 .... end as speedMappedToWhatever
from ResultStream
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。