esper

-1熱度

1回答

即時消息全新的Esper，所以如果下面的問題聽起來很愚蠢，請不要開槍。我正在將POJO事件發送給esper實例。該POJO。有一些屬性，具體如下： MyEventPOJO { final String sourceIP; final String destIP; final Calendar transmissionTime; final List<WorkingDay> Working

0熱度

1回答

複雜事件處理-Esper

我想知道是否有任何關於Esper源代碼的組件如何協作以產生查詢結果的信息（例如圖表）。例如，當應用選擇查詢時，數據是存儲在一個數組中，Esper的源代碼在哪裏發生？

0熱度

1回答

Esper：event_batch unsing timestamp event of event-POJO

我對esper有一個非常具體但很短的問題。我在esper中獲得了event-POJO，它們都以timeStamp作爲屬性。我需要做一個time_batch窗口，但是我必須根據事件的時間戳做窗口。時間戳將是一個很長的值。我正在網上搜索幾個小時，找不到任何可以幫助我的東西。

0熱度

1回答

Esper：當值超過閾值時拋出事件

我是Espers新手，嘗試實施警報系統。當項目值超過閾值時，我需要拋出一個事件。例如，對於一輛汽車，我想在屬性坦克超過40值時獲得一個事件，而當此值回到40以下時，我想獲得一個事件。我已經嘗試了很多Esper的功能，但沒有任何效果。我想要做這樣的事情，但它不能很好地工作： insert into AlertEvt select b from pattern[t=Car while (t.ta

0熱度

1回答

EPL模式匹配最新的A和所有B與濾波器

我試圖找到一個EPL模式，將匹配最新的A，其次是任何&所有B（prop1 = A.prop1）。使用在Esper's documentation定義相同序列... A1 B1 C1 B2 A2 D1 A3 B3 E1 A4 F1 B4 我要尋找，將匹配{A1，B1} {A1，B2}模式{A3，B3} {A4，B4 }假設它們都具有相同的prop1值。所以確切地說，在第一次匹配後，我不希望模

0熱度

1回答

如何指定何時不發出聲音？

如何指定時不火的聲明中，類似如下： select a.timestamp from pattern [every a = A -> (not timer:at (0, 6:12, *, *, *) and not timer:at (0, 16:20, *, *, *))]; 我想所有指定範圍時不火的聲明。謝謝

0熱度

1回答

ESPER CEP將在Hadoop或Spark平臺上工作

我在獨立系統中使用了ESPER CEP。 ESPER雲是否兼容？它可以在Hadoop或Spark平臺上運行謝謝

0熱度

1回答

如何在運行時從Esper配置對象獲取eventType

我正在運行一個使用Esper作爲我的核心CEP引擎的應用程序。當我嘗試獲取之前在Esper運行時註冊的事件類型時，我得到一個UnsupportedOperationException。 esperConfiguration.addEventType(streamName, fieldNames, fieldTypes); -------- //several lines later --

0熱度

1回答

在子查詢中支持esper having子句？

我寫了下面的查詢中的超能力： on pattern[every timer:interval(10 sec)] delete from OrderEvent as OE where OE.orderId IN (select orderId from OrderEvent group by orderId having last(orderAction) = CANCEL) 但它給我一個語法錯

1熱度

1回答

在幾個查詢中重用esper中的流

我試圖使用EsperIO從數據庫加載一些信息，並在具有不同條件的其他查詢中使用它。要做到這一點，我用下面的代碼： ConfigurationDBRef dbConfig = new ConfigurationDBRef(); dbConfig.setDriverManagerConnection("org.postgresql.Driver", "jdbc:postgr