public void open()

in long-ride-alerts/src/solution/java/org/apache/flink/training/solutions/longrides/LongRidesSolution.java [107:111]

• 5 lines of code
• 1 McCabe index (conditional complexity)

        public void open(Configuration config) {
            ValueStateDescriptor<TaxiRide> rideStateDescriptor =
                    new ValueStateDescriptor<>("ride event", TaxiRide.class);
            rideState = getRuntimeContext().getState(rideStateDescriptor);
        }