public static TripEvent fromStringShiftOrigin()

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

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

  public static TripEvent fromStringShiftOrigin(String payload, Duration timeDelta) {
    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());

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

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