public static TripEvent adaptTime()

in kinesis-taxi-stream-producer/src/main/java/com/amazonaws/flink/refarch/events/TripEvent.java [45:56]

• 12 lines of code
• 4 McCabe index (conditional complexity)

  public static TripEvent adaptTime(TripEvent event, AdaptTimeOption adaptTimeOption) {
    switch (adaptTimeOption) {
      case ORIGINAL:
        return event;
      case INVOCATION:
        return fromStringShiftOrigin(event.payload, DELTA_TO_FIRST_DROPOFF_TIME);
      case INGESTION:
        return fromStringOverwriteTime(event.payload);
      default:
        throw new IllegalArgumentException();
    }
  }