in rides-and-fares/src/solution/java/org/apache/flink/training/solutions/ridesandfares/RidesAndFaresSolution.java [130:138]
public void open(Configuration config) {
rideState =
getRuntimeContext()
.getState(new ValueStateDescriptor<>("saved ride", TaxiRide.class));
fareState =
getRuntimeContext()
.getState(new ValueStateDescriptor<>("saved fare", TaxiFare.class));
}