in flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/events/es/TripDuration.java [25:32]
public TripDuration(String location, String airportCode, long sumTripDuration, double avgTripDuration, long timestamp) {
super(timestamp);
this.location = location;
this.airportCode = airportCode;
this.avgTripDuration = avgTripDuration;
this.sumTripDuration = sumTripDuration;
}