alpinegizmo opened a new pull request #11: URL: https://github.com/apache/flink-training/pull/11
Goal here is to remove the dependency on these datasets, and to simplify the experience for those doing these exercises. This removes the need to download the datasets and to configure the code to use them. It also lets us delete the old sources, which were quite complex. I also updated the TaxiRide and TaxiFare classes so that they can be serialized with the POJO serializer (by converting the DateTime fields to Instant), and removed joda-time. ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected]
