Github user medcv commented on a diff in the pull request:
https://github.com/apache/flink/pull/6136#discussion_r194052688
--- Diff:
flink-examples/flink-examples-cep/src/main/java/org/apache/flink/cep/examples/java/monitoring/TemperatureMonitoring.java
---
@@ -0,0 +1,147 @@
Github user kisimple commented on a diff in the pull request:
https://github.com/apache/flink/pull/6136#discussion_r193941724
--- Diff:
flink-examples/flink-examples-cep/src/main/java/org/apache/flink/cep/examples/java/monitoring/TemperatureMonitoring.java
---
@@ -0,0 +1,147 @@
Github user medcv commented on a diff in the pull request:
https://github.com/apache/flink/pull/6136#discussion_r193934789
--- Diff:
flink-examples/flink-examples-cep/src/main/scala/org/apache/flink/cep/examples/scala/monitoring/TemperatureMonitoring.scala
---
@@ -0,0 +1,107 @@
Github user medcv commented on a diff in the pull request:
https://github.com/apache/flink/pull/6136#discussion_r193934744
--- Diff:
flink-examples/flink-examples-cep/src/main/java/org/apache/flink/cep/examples/java/monitoring/TemperatureMonitoring.java
---
@@ -0,0 +1,147 @@
GitHub user kisimple opened a pull request:
https://github.com/apache/flink/pull/6136
FLINK-4303] [CEP] Add CEP examples
## What is the purpose of the change
Currently neither CEP Java nor CEP Scala contain a runnable example. This
PR fixes the problem by adding a
