Cumulocity epr различия с esper

Я тестировал некоторые правила, которые написал в Cumulocity, и, поскольку я не мог получить желаемых результатов, я попытался использовать онлайн-инструмент Esper EPL для сравнения. Оказывается, я обнаружил разницу в результатах между двумя, которую не могу объяснить.

По сути, я хочу создать контекст, разделенный по источникам и разделенный событиями «start» и «stop». Затем, когда мой контекст заканчивается, я хочу отобразить некоторые детали (тип и время) только из моих начальных и конечных событий (в данный момент меня не интересуют промежуточные события).

Вот мое правило (схема создания должна быть удалена для Cumulocity, потому что они уже определены «изначально»):

create schema EventCreated(
  source String,
  type String,
  time Date
);

create schema CreateMeasurement(
  source String,
  type String,
  time Date,
  fragments Object
);



@Name("create_context")
create context Trip
    context bySource
        partition by source from EventCreated,

    context byEvents
        start EventCreated(
            type = "c8y_ObdConnectionReport" or
            type = "c8y_PowerOnReport" or
            type = "c8y_FixedReport" or
            type = "c8y_HarshBehaviorReport") as startEvent

        end EventCreated(
            type = "c8y_ObdDisconnectionReport" or
            type = "c8y_PowerOffReport" or
            type = "c8y_SilentTracker") as endEvent;



@Name("context_end")
context Trip
    insert into
        CreateMeasurement

    select
        context.bySource.key1 as source,
        "Trip" as type,
        e.time as time,
        {
            "startedBy", context.byEvents.startEvent.type,
            "startedAt", context.byEvents.startEvent.time,
            "endedBy", e.type,
            "endedAt", e.time
        } as fragments

    from
        EventCreated e

    output
        last when terminated;

А вот простая последовательность событий, чтобы увидеть разницу:

EventCreated = {
    source = '1672192',
    type = 'c8y_ObdConnectionReport',
    time =  '2016-10-07T10:00:00.000'
}

t = t.plus(5 minutes)

EventCreated = {
    source = '1672192',
    type = 'c8y_FixedReport',
    time =  '2016-10-07T10:05:00.000'
}

t = t.plus(5 minutes)

EventCreated = {
    source = '1672192',
    type = 'c8y_ObdDisconnectionReport',
    time =  '2016-10-07T10:10:00.000'
}

Итак, вот результат использования онлайн-симулятора EPL:

At: 2016-10-07 10:05:00.000
    Statement: context_end
        Insert
            CreateMeasurement={
                source='1672192',
                type='Trip',
                time='2016-10-07T10:05:00.000',
                fragments[
                    'startedBy','c8y_ObdConnectionReport',
                    'startedAt','2016-10-07T10:00:00.000',
                    'endedBy','c8y_ObdDisconnectionReport',
                    'endedAt','2016-10-07T10:10:00.000']}

Это то, что я хочу, как и ожидалось, я получил подробную информацию о моем первом и последнем мероприятии. Вот что я получаю с Cumulocity:

{
   "source":{
      "id":"1672192",
      "name":"Tracker 123456789000000",
      "self":"http://tracker.post-iot.lu/inventory/managedObjects/1672192"},
   "type":"Trip",
   "time":"2016-10-25T11:56:46.983+02:00",
   "self":"http://tracker.post-iot.lu/measurement/measurements/null",
   "startedBy":"c8y_ObdConnectionReport",
   "startedAt":"2016-10-25 11:56:44+0200",
   "endedBy":"c8y_FixedReport",
   "endedAt":"2016-10-25 11:56:46+0200"
}

(Не обращайте внимания на даты, я работаю с Cumulocity в режиме реального времени). Как видите, последним событием считается FixedReport, а не DisconnectionReport. Итак, что в основном происходит в Cumulocity (я пробовал различные ситуации), так это то, что конечное событие контекста каждый раз игнорируется, поэтому я могу получить только предпоследнее событие.

В чем разница с двигателем Esper? Как я могу заставить эту работу работать так, как я думаю?