convert raw rain timeseries from pail to stretched version in sequence file

gistfile1.clj

(use 'forma.hadoop.jobs.scatter)
(require '[forma.source.rain :as rain])
(require '[forma.utils :as u])

(let [nodata -9999.0
      src (pail-tap "/mnt/hgfs/robin/delete/timeseries/" "precl" "500" "32")
      out-loc (hfs-seqfile "/mnt/hgfs/robin/delete/rain-redo")]
  (<- [?s-res ?mod-h ?mod-v ?sample ?line ?new-start ?new-rain]
      (src _ ?dc)
      (thrift/unpack ?dc :> _ ?loc ?data ?t-res _)
      (thrift/unpack ?loc :> ?s-res ?mod-h ?mod-v ?sample ?line)
      (thrift/get-field-value ?data :> ?ts-obj)
      (thrift/unpack ?ts-obj :> ?start _ ?ts)
      (thrift/unpack* ?ts :> ?rain)
      (u/replace-from-left* nodata ?rain :default 0 :> ?clean-rain)
      (rain/stretch-rain ?t-res "16" ?start ?clean-rain :> ?new-start ?new-rain)))