           (my-println-f (str "finished, " @n-docs " rows"))
           {:generated @n-docs})))))
 
-;(extract-to-csv (str data-folder "green_tripdata_2013-08.csv.gz"))
+;(extract-to-csv (data-folder "green_tripdata_2013-08.csv.gz"))
 ;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;
 
 (def es-types

            drop-extra-fields))))

(comment
  (let [file (->> "yellow_tripdata_2010-02.csv.gz" (str data-folder))]
    (with-open [in (-> file clojure.java.io/input-stream java.util.zip.GZIPInputStream.)]
      (->> in io/reader line-seq (take 4)))))

(comment
  (let [file (->> "yellow_tripdata_2010-02.csv.gz" (str data-folder))]
    (u/read-csv-with-mapping :gz file csv-mapping
      (->> (rows->docs file rows) (take 3) clojure.pprint/pprint))))


(defmacro my-println-f [& forms]
  `(my-println ~'file ": " ~@forms))

(let [default (if (-> "os.name" System/getProperty (subs 0 7) (= "Windows"))
                "C:/nikon/projects/clojure/nyc-taxi-data/data"
                "/home/wrecked/projects/taxi-rides/data")]
  (defn data-folder
    ([]  (data-folder ""))
    ([f] (str (u/getenv "TAXI_DATA_FOLDER" default) "/" f))))

(defn find-files [re] (->> (data-folder) io/file file-seq (filter #(re-find re (.getName ^java.io.File %))) sort))

(let [mapping (into {"date" :keyword} (zipmap ["prcp" "snwd" "snow" "tmax" "tmin" "awnd"] (repeat :float)))
      mapping (into {} (for [[k v] mapping] [(keyword k) [v (keyword (str "weather-" k))]]))
      avg-wind-fix (fn [row] (update row :weather-awnd #(if-not (neg? %) %)))]
  (u/read-csv-with-mapping :csv "central_park_weather.csv" mapping
    (def weather
      (->> (for [row rows]
               [(:weather-date row)
