haoch flink-siddhi issues

haoch / flink-siddhi

A CEP library to run Siddhi within Apache Flink™ Streaming Application (Not maintained)

Apache License 2.0

243 stars 96 forks source link

issues

Newest

Newest Most commented Recently updated Oldest Least commented Least recently updated

Support dynamic partition and ad-hoc cep runtime

#28 wujinhu closed 5 years ago
5
What are the advantages of siddhi over flink-cep

#27 shidayang opened 5 years ago
7
how to use group by in flink-siddhi

#26 yangqiangqiang0327 closed 5 years ago
3
flink-siddhi group by how to use

#25 yangqiangqiang0327 closed 5 years ago
0
Are there any flink-siddhi test demos

#24 yangqiangqiang0327 closed 5 years ago
2
有没有一个测试demo

#23 yangqiangqiang0327 closed 5 years ago
3
fix custom function cannot use in returns() bug

#22 tammypi closed 5 years ago
1
custom function cannot use in retturn()

#21 tammypi opened 5 years ago
2
CEP output is less than expect

#20 coder20170628 opened 5 years ago
6
Support Dynamic Route Partitioner

#19 haoch opened 5 years ago
1
upgrade version of flink and siddhi

#18 wujinhu closed 5 years ago
0
Support Siddhi QueryCallback

#17 aagupta1 opened 5 years ago
9
Returning Query Id in Output

#16 aagupta1 opened 5 years ago
1
Updated readme

#15 wittyameta closed 5 years ago
1
KryoSerializer Exception

#14 zhuan77241 opened 5 years ago
4
[Question]Why need to do siddhi snapshot when processing each element ?

#13 JasonChoi27 opened 6 years ago
1
Implement basic management API for dynamical CEP stream processor

#12 haoch opened 6 years ago
0
[DISCUSS] How to enable dynamic pattern ?

#11 JasonChoi27 opened 6 years ago
5
[DISCUSS] What use cases are using flink-siddhi?

#10 haoch opened 6 years ago
6
Fixing enable query and disable query operation control events

#9 aagupta1 closed 6 years ago
1
OperationControlEvent enableQuery disables the query instead of enabling it.

#8 aagupta1 opened 6 years ago
3
Fix a small mistake in README

#7 kisimple closed 6 years ago
1
[MINOR] Fix a typo

#6 kisimple closed 6 years ago
1
StreamSerializer fails on compositeTypes and rowTypes

#5 Wosin opened 6 years ago
2
https://github.com/haoch/flink-siddhi/issues/3

#4 nragon closed 7 years ago
0
Flink 1.2 Snapshot

#3 nragon opened 7 years ago
1
Leverage Eagle Policy Interpreter to convert siddhi query to distributed execution plan

#2 haoch opened 7 years ago
1
minor fix: fixed an issue in pom.xml

#1 aparup closed 7 years ago
1