Github user haoch closed the pull request at:
https://github.com/apache/flink/pull/2487
---
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2487#discussion_r78449235
--- Diff:
flink-contrib/flink-siddhi/src/main/java/org/apache/flink/contrib/siddhi/operator/SiddhiOperatorContext.java
---
@@ -0,0 +1,162 @@
+/*
+
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2487#discussion_r78447224
--- Diff:
flink-contrib/flink-siddhi/src/main/java/org/apache/flink/contrib/siddhi/operator/AbstractSiddhiOperator.java
---
@@ -0,0 +1,265 @@
+/*
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2487#discussion_r78447005
--- Diff:
flink-contrib/flink-siddhi/src/main/java/org/apache/flink/contrib/siddhi/operator/AbstractSiddhiOperator.java
---
@@ -0,0 +1,265 @@
+/*
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2487#discussion_r78446790
--- Diff:
flink-contrib/flink-siddhi/src/main/java/org/apache/flink/contrib/siddhi/SiddhiStream.java
---
@@ -0,0 +1,224 @@
+/*
+ * Licensed to the
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2487#discussion_r78446628
--- Diff:
flink-contrib/flink-siddhi/src/main/java/org/apache/flink/contrib/siddhi/SiddhiCEP.java
---
@@ -0,0 +1,116 @@
+/*
+ * Licensed to the
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2487#discussion_r78446460
--- Diff:
flink-contrib/flink-siddhi/src/main/java/org/apache/flink/contrib/siddhi/SiddhiCEP.java
---
@@ -0,0 +1,116 @@
+/*
+ * Licensed to the
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2487#discussion_r78446582
--- Diff:
flink-contrib/flink-siddhi/src/main/java/org/apache/flink/contrib/siddhi/SiddhiCEP.java
---
@@ -0,0 +1,116 @@
+/*
+ * Licensed to the
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2487#discussion_r78446343
--- Diff:
flink-contrib/flink-siddhi/src/main/java/org/apache/flink/contrib/siddhi/SiddhiCEP.java
---
@@ -0,0 +1,116 @@
+/*
+ * Licensed to the
Github user apivovarov commented on a diff in the pull request:
https://github.com/apache/flink/pull/2487#discussion_r78270764
--- Diff:
flink-contrib/flink-siddhi/src/main/java/org/apache/flink/contrib/siddhi/SiddhiCEP.java
---
@@ -0,0 +1,118 @@
+/*
+ * Licensed to the
Github user apivovarov commented on a diff in the pull request:
https://github.com/apache/flink/pull/2487#discussion_r78270757
--- Diff:
flink-contrib/flink-siddhi/src/main/java/org/apache/flink/contrib/siddhi/SiddhiCEP.java
---
@@ -0,0 +1,118 @@
+/*
+ * Licensed to the
Github user apivovarov commented on a diff in the pull request:
https://github.com/apache/flink/pull/2487#discussion_r78270750
--- Diff:
flink-contrib/flink-siddhi/src/main/java/org/apache/flink/contrib/siddhi/SiddhiCEP.java
---
@@ -0,0 +1,118 @@
+/*
+ * Licensed to the
GitHub user haoch opened a pull request:
https://github.com/apache/flink/pull/2487
[FLINK-4520][flink-siddhi] Integrate Siddhi as a light-weight Streaming CEP
Library
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list
13 matches
Mail list logo