in common/src/main/java/org/apache/flink/training/exercises/common/datatypes/TaxiRide.java [49:62]
public TaxiRide(long rideId, boolean isStart) {
DataGenerator g = new DataGenerator(rideId);
this.rideId = rideId;
this.isStart = isStart;
this.eventTime = isStart ? g.startTime() : g.endTime();
this.startLon = g.startLon();
this.startLat = g.startLat();
this.endLon = g.endLon();
this.endLat = g.endLat();
this.passengerCnt = g.passengerCnt();
this.taxiId = g.taxiId();
this.driverId = g.driverId();
}