Hi, Let me explain why I want to do that, so you can also see if it is reasonable or not. I want to do local processing on the Data source node (that is what Edgent is for, am I right?). Nevertheless, I want to execute my query using a data flow Engine (Flink) on the cluster [1]. So, instead of filter my data on the cluster I aim to do it early with Apache Edgent [2].
If you look the code you will see that I am publishing data with MQTT using Edgent and consuming with MQTT connector on my Flink program. So, suppose I want to execute a simple filter on the flink program. However, I know that I can do this on Edgent. I just want to pass some parameters to my edgent program and the Stream accepts it at runtime. Is it possible? ps: If not, I am also willing to receive some advice to implement it on the source code. [1] https://github.com/felipegutierrez/explore-flink/blob/master/src/main/java/org/sense/flink/examples/stream/SensorsReadingMqttEdgentQEP.java [2] https://github.com/felipegutierrez/explore-rpi/blob/master/src/main/java/org/sense/edgent/app/TempSensorMqttApp.java Kind Regards, Felipe *--* *-- Felipe Gutierrez* *-- skype: felipe.o.gutierrez* *--* *https://felipeogutierrez.blogspot.com <https://felipeogutierrez.blogspot.com>*
