                (HashModScheme.)
                4))
 
-(defn populate [idx]
-  (with-open [shard (.createShard spec "/Users/sritchie/Desktop/helper" idx)]
+(defn populate [root idx]
+  (with-open [shard (.createShard spec root idx)]
     (doseq [x (range 1000)]
       (.index shard (KeyValDocument. x 10)))))
 
 ;; or, you can create a domain store directly:
-(def store
-  (DomainStore. "/Users/sritchie/Desktop/helper"
-                (DomainSpec. (JavaBerkDB.)
-                             (HashModScheme.)
-                             4)))
+(defn store []
+  (with-fs-tmp [_ tmp]
+    (DomainStore. tmp (DomainSpec. (JavaBerkDB.)
+                                   (HashModScheme.)
+                                   4))))

(ns elephantdb.cascading.integration-test
  (:use clojure.test
        midje.sweet
        elephantdb.common.testing
        [clojure.string :only (join)])
  (:require [elephantdb.keyval.testing :as t])
  (:import [cascading.pipe Pipe]

    (doall (for [wrapper (iterator-seq it)]
             (into [] (.getTuple wrapper))))))

(tabular
 (fact "connect-test"
   (with-fs-tmp [_ src-tmp sink-tmp]     
     (let [sink (ElephantDBTap. sink-tmp
                                (DomainSpec. (JavaBerkDB.) (HashModScheme.) 4)
                                (mk-options))]
       (fill-domain sink ?xs))))
 ?xs
 [[1 2] [3 4]]
 [["key" "val"] ["ham" "burger"]])

(defn read-etap-with-flow [path]
  (with-fs-tmp [fs tmp-path]
