Stack Overflow
Stack Overflow

Questions tagged [wso2-cep]

251 questions
9
votes
3 answers

WSO2 Stream Processor confusion

I have a little bit of confusion about the Stream Processor. I've previously used the CEP and now I'm using the Stream Processor. if I'm not mistaken, the Data Analytics Server, the CEP and the Machine Learner merged into the Stream Processor, is it…
user5919369
  • 111
  • 6
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
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

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
2
votes
1 answer

Siddhi PMML Extension - Installation error

I'm trying to install Siddhi PMML Extension from WSO2 DAS as described [here][1]. I downloaded archive p2-repo.zip, added repository WSO2 GPL Feature Repository. I have an error when I try to install the extension: Cannot complete the install…
Alex
  • 55
  • 3
2
votes
2 answers

WSO2 CEP : 4.2.0 receiver slower than 4.1.0

I have tested HTTP receiver with both WSO2 CEP 4.1.0 & 4.2.0. With same set of data, streams, execution plan(just event count wit 1 min window), publisher(logger) 4.1.0 is able to process 1M/minute but 4.2.0 could go up to 200K-300K/minute. Have…
Obaid
  • 237
  • 2
  • 14
2
votes
1 answer

Handling null values with wso2 CEP

I want to update event table (RDBMS) using additional condition that one column in that is not null. Table name is MSISDNProfileDB and it's in oracle db. from incomingStream#window.length(1) select correlation_MSISDN as MSISDN, …
datahack
  • 477
  • 1
  • 11
  • 32
2
votes
2 answers

What type of EC2 instance is better suitted for Wso2 CEP Standalone?

compute optimized (c3, c4) or a memory optimized (r3) instance for running a stand-alone wso2 cep server? i searched the documentation but could not find anything regarding running this server on ec2
R.Vera
  • 35
  • 6
2
votes
1 answer

Can we use variables in Siddhi SQL statements?

I'm going to use the same value in lots of statements in the SQL Expression. So it is possible to declare and assign the value to a variable at the beginning of the query and refer the value by it? (I'm writing an execution plan in WSO2 DAS)
PasinduJay
  • 487
  • 5
  • 17
2
votes
0 answers

Exception when WSO2CEP deploys execution plan with trigger to Storm

We have WSO2CEP 4.1.0 in cluster distributed mode and Apache Storm. When execution plan of a flow has trigger it can not be deployed to Storm as topology. When I edit execution plan and press 'Add execution plan' button CEP gives me a popup with…
invenit
  • 424
  • 4
  • 11
2
votes
1 answer

Aggregate WSO2 CEP Siddhi events to a single json object

I'm trying to build an execution plan which aggregates different events into one and counts the occurrence (CurrentEventId). The plan looks like the following: define stream inStream (correlation_EventName string, LastEventId int, CurrentEventId…
Seb Krae
  • 311
  • 3
  • 10
2
votes
1 answer

How to convert stream which contains event sequence

I have written a custom http receiver, it get events from another system, and the json sample like…
yeahliu
  • 154
  • 1
  • 8
2
votes
1 answer

WSO2 esb UDP to TCP conversion - Improve performance

I want to convert UDP stream to TCP/HTTP and feed it into a WSO2 CEP. So for UDP to HTTP conversion I used WSO2 ESB. As I can see it is possible to convert around 2000UDP messages into HTTP smoothly with ESB proxy. In that case ESB took around 2.2GB…
lsc
  • 681
  • 3
  • 8
  • 26
1
2 3
…
16 17