   "Coerce from KV to Clojure MapEntry"
   [^KV kv]
   (let [v (.getValue kv)]
-    (if (instance? Reiterable v)
+    (if (instance? Iterable v)
       (MapEntry. (.getKey kv) (seq v))
       (MapEntry. (.getKey kv) v))))
 

                               (fn [transform enum] (.withCompressionType transform enum)))}})

(def text-writer-schema
  {:num-shards {:docstr "Selects the desired number of output shards (file fragments). 0 to let the system decide (recommended)."
                :action (fn [transform shards] (.withNumShards transform shards))}
   :without-sharding {:docstr "Forces a single file output."
                      :action (fn [transform b] (when b (.withoutSharding transform)))}

                       (Sessions/withGapDuration)
                       (Window/into))]
     (apply-transform pcoll transform window-schema options)))
  ([gap ^PCollection pcoll] (session-windows gap {} pcoll)))
