       (mpartial set-grouping gs)]))
 
 (defn dsink
-  "Distributed sink for Avro output."
+  "Distributed sink for Avro output, applying the vector of `schemas` as per the
+arguments to `set-output`, and writing to `path`."
   [schemas path]
   (dsink/dsink
    (let [defaults (-> schemas count (repeat :default))]

  [job klass] (lazy-output-format* ^Job job ^Class klass))

(defn set-output
    "Configure `job` output to produce Avro with key schema `ks` and
optional value schema `vs`.  Configures job output format to match
when the output format has not been otherwise explicitly specified."
  ([^Job job ks]

       (FileInputFormat/addInputPath job (fs/path path))))))

(defn shuffle
  "Configuration step for Avro shuffle, with key schema `ks`, optional value
schema `vs`, and optional grouping schema `gs`."
  ([ks] (mpartial set-map-output ks))
  ([ks vs] (mpartial set-map-output ks vs))
  ([ks vs gs]
