Переопределение сиддхи eventTimestamp - PullRequest
Новая
       8

Переопределение сиддхи eventTimestamp

0 голосов
/ 27 июня 2018

У меня есть следующий источник в WSO2 Siddhi CEP: 

@source(type='kafka',
    topic.list='userInfo',
    partition.no.list='0',
    threading.option='single.thread',
    group.id="threadAccessor",
    bootstrap.servers='localhost:9092',
    @map(type='json', @attributes(USERID = '$.USERID', tst = '$.TST', ACTIVITY = '$.ACTIVITY', AVG_HBR = '$.AVG_HBR')))
define stream SweetProductionStream (USERID string, tst long, ACTIVITY string, AVG_HBR int);

Есть ли способ переопределить значение, возвращаемое функцией eventTimestamp(), используя отображение? Возможно ли это вообще? Я знаю, что это для externalTimeWindow, но я хотел бы использовать свои собственные временные метки для поиска паттернов.

Спасибо.

1 Ответ

0 голосов
/ 27 июня 2018

Отметка времени события является неизменной, вы можете получить доступ только к отметке времени с помощью eventTimestamp(). Если вам нужно использовать свою собственную временную метку, используйте ее в качестве атрибута в потоке и используйте ее.

Я не уверен, чего вы пытаетесь достичь в источнике. Вы можете передать временную метку в сообщении, извлечь ее и использовать в качестве атрибута. Вы можете передать этот атрибут при обработке externalTimeWindow, а также при использовании шаблонов вы можете использовать этот атрибут и определять временные условия наряду с другими.

...