Questions tagged [siddhi]

Siddhi CEP is a lightweight, easy-to-use Open Source Complex Event Processing Engine (CEP) under Apache Software License v2.0. Siddhi CEP processes events which are triggered by various event sources and notifies appropriate complex events according to the user-specified queries.

Siddhi is a fully open-source, cloud-native, scalable, Streaming and Complex Event Processing System capable of building real-time analytics, data integration, notification and surveillance use cases.

Siddhi understands Streaming SQL queries in order to capture events from diverse data sources, process them, integrate with multiple services and data sources, and publish output to various endpoints in real-time.

411 questions
5
votes
1 answer

Publish statistic from wso2 EI to wso2 Stream Processor

I need to know how is it possible to publish statistics via event publisher from Enteprise Integrator to Stream Processor. I have following implementation of event publisher on my EI
4
votes
2 answers

Not able to execute custom function extension in wso2 cep

I am using wso2cep 4.1.0 and have created custom function extension class with following package name: package org.wso2.siddhi.extension.custom; ..... public class MyFunction extends FunctionExecutor { ..... } Then I have created file :…
Satyam
  • 361
  • 2
  • 5
4
votes
1 answer

Remove event data tables from wso2 Data Analytics Server

I have created some test tables in WSO2-DataAnalyticsServer-3.0.1 by these steps: Edit Event>Streams>Next[presistEvent] then enable Persist Event Stream and Save. This made a table which is showing on InteractiveAnalytics>Data Explorer. I want to…
Reza Ameri
  • 1,803
  • 3
  • 24
  • 32
4
votes
1 answer

Siddhi CEP 3.x newbie questions

I'm new to Siddhi, and I got several questions: Is SiddhiManager thread safe? Is it a good practice one shared instance per JVM? How to define stream and add query at runtime? It seems it only has siddhiManager.createExecutionPlanRuntime(plan)…
gembin
  • 136
  • 1
  • 6
4
votes
0 answers

Intergating WSO2 CEP with HTTP REST API

I'm searching for ways to integrate CEP engine in my application and I would like to know if exists REST API or other tools to integrate it and to access to its functionalities out of management console. I haven't found nothing on documentation.
adellarocca
  • 649
  • 1
  • 5
  • 7
4
votes
2 answers

Which kind of objects are supported by Siddhi for the "object" attribute type?

I am performing some experimentations for a prototype using Siddhi as a CEP engine, and would like to know if the input streams only support flat event data or can also support a JSON-like data hierarchy for queries. Siddhi's documentation refers to…
Alexandre Bourdin
  • 825
  • 1
  • 14
  • 30
3
votes
1 answer

Siddhi CDC Postgres app not taking custom slot.name

I have given following configurations to Debezium Postgres connector and registered it. configuration is as following. { "name": "shipments-connector", "config": { "connector.class":…
Vinoja
  • 94
  • 1
  • 6
3
votes
1 answer

How to use javascript functions inside javascript functions in Siddhi App?

I have been working on a Siddhi App. Inside this app I have JavaScript functions. I have found a problem when trying to use the function inside the function. Lets say: define function sum[JavaScript ] return double { return data[0]+…
Jorge Monroy
  • 408
  • 1
  • 5
  • 16
3
votes
1 answer

Wso2 Stream Mongo Datetime join query

I try to make a query between a stream (contains a datetime) and a store mongodb table on a datetime column. define stream TriggerStream (lastexec string); @info(name = 'ExtractData') from TriggerStream as e right outer join OFFRELOG as o on…
Nicolas
  • 117
  • 1
  • 10
3
votes
1 answer

Siddhi HTTP NoSuchMethodError

This question is about java library of Siddhi - CEP Description: I tried to establish an HTTP source to receive data. There was no error creating the Runtime and starting it. [nioEventLoopGroup-2-1] INFO…
Jin.J
  • 353
  • 1
  • 4
  • 13
3
votes
1 answer

Can I load a list white with table event WSO2

I have a postgres blacklist table, I want to load this table and do a join using the event table of WSO2 DAS. but it does not allow me to use the blacklist eat from in the query. This is my code of sample: @From(eventtable='rdbms',…
3
votes
1 answer

WSO2 CEP Siddhi window and table join are not working with Apache Storm

I have created simple execution plan with storm support using WSO2 CEP v4.1.0. But it will give some exceptions when i use window facilities in Siddhi. And Its not possible to join table with stream with use of storm also. How do I resolve this? Is…
Saveendra Ekanayake
  • 3,153
  • 6
  • 34
  • 44
3
votes
1 answer

what is meta data correlation data and payload data in wso2 cep

what is meta data correlation data and payload data in wso2 cep I understood that these are 3 different types of data types in stream but which one has benefits over another that is not clear from any documentation. Or how can we use it in different…
Anshul Gupta
  • 490
  • 4
  • 8
3
votes
1 answer

wso2: cep: siddhi: how to make time windows persistent

we are currently testing siddhi wso2 cep. we need to be able to restart the wso2 server process without loosing data which has been accumulated in a window (for example time window). Is there a way to make time windows persistent so that the server…
ron
  • 418
  • 4
  • 12
3
votes
1 answer

CEP absence of events using siddhi

Good afternoon. I write as an architect SW Competence Centres into Company Indra (www.indra.com). In this area normally work with CEPs, open-source and commercial, in the open-source domain until now we've always used the Esper CEP, but we have…
1
2 3
27 28