Greetings, First, thanks to DataArtisans for putting together Apache Flink® Training documentation. Its proving to be a practical way to learn both Flink and Scala. In compiling our exercise writing to Kafka, I am getting following error "missing parameter type" where the parameter 'r' seems not to be recognized in filter method. Code snippet as follows: val rides = env.addSource(new TaxiRideSource(input, maxEventsDelay, streamServingSpeed))
val filteredRides = rides.filter(r => GeoUtils.isInNYC(r.startLon, r.startLat) && GeoUtils.isInNYC(r.endLon, r.endLat))Any advice would be appreciated. Thanks
