Временные ряды WSO2: регрессия в разделе кажется поврежденной - PullRequest
Новая
       43

Временные ряды WSO2: регрессия в разделе кажется поврежденной

0 голосов
/ 25 февраля 2020

Требуемое поведение

  • Поток событий скорости нескольких источников.
  • Определите для каждого источника, ускоряется ли он, идет с постоянной скоростью или замедляется.

Наблюдаемое поведение

  • Если с помощью предварительной фильтрации потока обрабатывается только один источник (например, sourceID == 7 в приведенном ниже примере), результаты выглядят нормально.
  • Если разрешены все идентификаторы источника (например, в потоке имеется 10 источников), кажется, что результаты влияют друг на друга, как будто раздел неправильно разделяет данные для временных рядов: регресс.
  • Для вашей информации: я отправляю данные, используя воспроизведение. У меня нет живых потоков. @App: воспроизведение (idle.time = '100 миллисекунд', приращение = '2 se c'). И я отправляю информацию Сиддхи через приложение Java.

Код 

from SpeedEventsAll
select sourceID, speed, time
having sourceID == 7
insert into SpeedEvents;

partition with (sourceID of SpeedEvents)
begin
    from SpeedEvents#timeseries:regress(1, 20, 0.8, speed, time)
    select *
    insert into #SpeedRegression;

    -- Separate in slope categories
    -- -1: slowing down (below 0.05 speedChange/ms)
    -- 0: constant
    -- 1: speeding up
    from #SpeedRegression
    select sourceID, speed, time, stderr, beta0, beta1,
      ifThenElse(beta1<-0.05, -1,
        ifThenElse(beta1<0.05, 0, 1)) as speedStatus
    insert into SpeedStatus;
end;

Уже пробовал

  • Я попробовал то же самое с timeseries: lengthTimeRegress, но также не работает.
  • Я пробовал разные версии расширения timeseries, но все они, похоже, не работают.

Вопрос

  • Вы уверены, что timeseries: regress отлично работает в разделах?
  • Используете ли вы неверную композицию версий?

Используемые версии

Из зависимости Maven: Команда tree, в настоящее время я получаю следующие пакеты Siddhi: 

[INFO] +- io.siddhi:siddhi-core:jar:5.1.12:compile
[INFO] +- io.siddhi:siddhi-query-api:jar:5.1.12:compile
[INFO] +- io.siddhi:siddhi-query-compiler:jar:5.1.12:compile
[INFO] +- io.siddhi:siddhi-annotations:jar:5.1.12:compile
[INFO] +- io.siddhi.extension.execution.string:siddhi-execution-string:jar:5.0.9:compile
[INFO] +- io.siddhi.extension.execution.time:siddhi-execution-time:jar:5.0.4:compile
[INFO] +- org.wso2.extension.siddhi.execution.timeseries:siddhi-execution-timeseries:jar:5.0.0:compile

Я использую эти репозитории: 

  <repositories>
    <repository>
      <id>WSO2</id>
      <name>Siddhi specific WSO2 repository</name>
      <url>https://maven.wso2.org/nexus/content/repositories/releases/</url>
    </repository>
    <repository>
      <id>central</id>
      <name>Central Maven repository</name>
      <url>https://repo1.maven.org/maven2/</url>
    </repository>
  </repositories>
...