in long-ride-alerts/src/main/scala/org/apache/flink/training/exercises/longrides/scala/LongRidesExercise.scala [77:81]
def main(args: Array[String]): Unit = {
val job = new LongRidesJob(new TaxiRideGenerator, new PrintSinkFunction)
job.execute()
}