alpinegizmo opened a new pull request #31: URL: https://github.com/apache/flink-training/pull/31
This is a draft. So far I've only redone the LongRideAlerts exercise. I'm looking for feedback before making analogous changes to the other TaxiRide/TaxiFare exercises. My goal is for the exercises and tests to serve as better examples of how to structure Flink apps so they can be tested, and to minimize the impact of the quirks of the setup here (namely that the tests are used to test both exercises and solutions, and both java and scala). It's also my intention to (eventually) add a test harness test for the process function in the long rides exercise, but I haven't done that yet. I would also like to (eventually) update the data generators to use the new Source interfaces, and move the watermarking onto the sources, but for now I've added a WatermarkStrategy to the exercise and solution, instead of having the data generators call emitWatermark (which has been pretty confusing). -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
