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