flink-siddhi
flink-siddhi copied to clipboard
haoch
A CEP library to run Siddhi within Apache Flink™ Streaming Application
Hi. I use CEP SQL like every(1) followed by 2. ( every(1)->2 ) The input data like below: `1 1 1 2` And my expect output is: `{1,2} {1,2} {1,2}`...
When multiple QueryHandlers sharing the same Output Stream are registered with Siddhi, is there a way to tell which Query triggered the output results ? Based on the query that...
From OperationControlEvent.java public static OperationControlEvent enableQuery(String queryId) { return new OperationControlEvent(Action.DISABLE_QUERY, queryId); } public static OperationControlEvent disableQuery(String queryId) { return new OperationControlEvent(Action.ENABLE_QUERY, queryId); }
In ```StreamSchema``` there are methods ```isRowType()``` and is ```isCompositeType()```. But they are not used in ```StreamSerializer```, which makes it impossible to create SiddhiStream for those types.
Hello, Current release of flink-siddhi is using 1.2-SNAPSHOT flink right? I'm getting the following error which seems to be a class from previous versions (until 1.1.4 this class was there):...
[](https://infosecwriteups.com/want-to-take-over-the-java-ecosystem-all-you-need-is-a-mitm-1fc329d898fb) --- This is a security fix for a high severity vulnerability in your [Apache Maven](https://maven.apache.org/) `pom.xml` file(s). The build files indicate that this project is resolving dependencies over HTTP...
Hello! I observed that the are differences between https://github.com/apache/bahir-flink/tree/master/flink-library-siddhi and https://github.com/haoch/flink-siddhi . In the first repository the full package "control" (https://github.com/haoch/flink-siddhi/tree/master/core/src/main/java/org/apache/flink/streaming/siddhi/control) is missing. It seems to me that current repository,...
