public static TripEvent fromStringOverwriteTime()

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

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

  public static TripEvent fromStringOverwriteTime(String payload) {
    ObjectNode json = (ObjectNode) Jackson.fromJsonString(payload, JsonNode.class);

    DateTime pickupTime = new DateTime(json.get(PICKUP_DATETIME).asText());
    DateTime dropoffTime = new DateTime(json.get(DROPOFF_DATETIME).asText());

    Duration timeDelta = new Duration(dropoffTime, DateTime.now());

    json.put(PICKUP_DATETIME, pickupTime.plus(timeDelta).toString());
    json.put(DROPOFF_DATETIME, dropoffTime.plus(timeDelta).toString());

    return new TripEvent(json.toString());
  }