 
 (defn produces
   "Returns a chatty checker that tests for equality between two
-  sequences of tuples."
+  sequences of tuples. Accepts an optional property map as the second
+  parameter."
   [expected]
   (chatty-checker [actual]
                   (= (set expected)

            ElephantDBTap$Args KeyValTailAssembly KeyValGateway]
           [org.apache.hadoop.mapred JobConf]))

;; ## Key-Value

(defn kv-spec


(defn connect!
  "Connect the supplied source and sink with the supplied pipe."
  [pipe source sink]
  (doto (.connect (flow-connector) source sink pipe)
    (.complete)))

(defn tuple-seq
