       (fill-domain sink data2)
       (check-results tmp data3))))
 
-(deftest test-source
+(fact "test-source"
   (with-fs-tmp [fs tmp]
     (let [pairs [[(barr 0) (barr 0 2)]
                  [(barr 1) (barr 1 1)]

(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]
