   [job klass] (lazy-output-format* ^Job job ^Class klass))
 
 (defn set-output
-    "Configure `job` output to produce Avro with key schema `ks` and
+  "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]

      (mpartial set-grouping gs)]))

(defn dsink
  "Distributed sink for Avro output."
  [schemas path]
  (dsink/dsink
   (let [defaults (-> schemas count (repeat :default))]

  [x] (or (instance? Schema x) (keyword? x)))

(defn dseq
  "Distributed sequence of Avro input, applying the vector of `schemas` as per
the arguments to `set-input`, and reading from `paths`."
  [schemas & paths]
  (dseq/dseq
   (fn [^Job job]
