               vcf-step
               ([:tmp-dirs vcf-path]
                  (?- (hfs-seqfile vcf-path)
-                     (<- [?subpail ?chunk]
-                         ((constrained-tap pail-path "vcf" s-res "00") ?subpail ?chunk))))
-
+                     (<- [?subpail ?data-chunk]
+                         ((constrained-tap pail-path "vcf" s-res "00") ?subpail ?data-chunk))))
+
+              
               ndvi-step
               ([:tmp-dirs ndvi-path]
                  (?- (hfs-seqfile ndvi-path)

         (>= ?vcf 25))))

(defn static-src [{:keys [vcf-limit]} pail-path]
  (let [[vcf hansen ecoid gadm border]
        (map (comp static-tap (partial split-chunk-tap pail-path))
             [["vcf"] ["hansen"] ["ecoid"] ["gadm"] ["border"]])]

(ns forma.hadoop.jobs.scatter
  "Namespace for arbitrary queries."
  (:use cascalog.api
        [forma.source.tilesets :only (tile-set country-tiles)]
        [forma.hadoop.pail :only (to-pail ?pail- split-chunk-tap)]
        [cascalog.checkpoint :only (workflow)]
        [clojure.math.numeric-tower :only (round)])
  (:require [cascalog.ops :as c]
            [forma.reproject :as r]
            [forma.schema :as schema]
            [forma.trends.stretch :as stretch]
