                          (into           (weather (-> doc :pickup-dt (subs 0 8)))))))]
         (for [doc docs :when (pos? (:travel-km doc))]
           (-> doc
-              (update :travel-km   mile2km)
-              (assoc :pickup-pos   (if (:pickup-lon  doc) (mapv doc [:pickup-lon  :pickup-lat])))
-              (assoc :dropoff-pos  (if (:dropoff-lon doc) (mapv doc [:dropoff-lon :dropoff-lat])))
-              (assoc :dlat-km      (delta-km (:pickup-lat doc) (:dropoff-lat doc)))
-              (assoc :dlon-km      (delta-km (:pickup-lon doc) (:dropoff-lon doc)))
-              (assoc :pickup-time  (to-time (:pickup-dt  doc)))
-              (assoc :dropoff-time (to-time (:dropoff-dt doc)))
+              (assoc  :company       "Green")
+              (update :travel-km     mile2km)
+              (assoc  :pickup-pos    (if (:pickup-lon  doc) (mapv doc [:pickup-lon  :pickup-lat])))
+              (assoc  :dropoff-pos   (if (:dropoff-lon doc) (mapv doc [:dropoff-lon :dropoff-lat])))
+              (assoc  :dlat-km       (delta-km (:pickup-lat doc) (:dropoff-lat doc)))
+              (assoc  :dlon-km       (delta-km (:pickup-lon doc) (:dropoff-lon doc)))
+              (assoc  :pickup-time   (to-time (:pickup-dt  doc)))
+              (assoc  :dropoff-time  (to-time (:dropoff-dt doc)))
+              (update :paid-ehail   #(or % 0.0))
               (#(assoc % :travel-h   (let [pickup-time  (:pickup-time  %)
                                            dropoff-time (:dropoff-time %)]
                                        (if (and dropoff-time pickup-time (not= dropoff-time pickup-time))

   "Lpep_dropoff_datetime"   [:basic-datetime  :dropoff-dt]
   "Store_and_fwd_flag"      [:keyword         :store-flag]
   "RateCodeID"              [:int             :rate-code-id]
   "Pickup_longitude"        [:latlon          :pickup-lon      :skip-in-es]
   "Pickup_latitude"         [:latlon          :pickup-lat      :skip-in-es]
   "Dropoff_longitude"       [:latlon          :dropoff-lon     :skip-in-es]
   "Dropoff_latitude"        [:latlon          :dropoff-lat     :skip-in-es]
   "Passenger_count"         [:int             :n-passengers]
   "Trip_distance"           [:float           :travel-km]
   "Fare_amount"             [:float           :paid-fare]

                                                  (if (pos? delta) delta (+ delta 24))))))))
             ;(update :pickup-time  to-int-str)
             ;(update :dropoff-time to-int-str)
              (#(assoc % :speed-kmph (if-let [travel-h (:travel-h %)] (if (> travel-h 0.17) (round (/ (:travel-km %) travel-h))))))
              (#(if (< (dist (:dlat-km %) (:dlon-km %)) 0.2) (reduce dissoc % [:dlat-km :dlon-km]) %))
              drop-fields)))))
;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;
