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