Skip to content

Commit 96d3f7e

Browse files
committed
Add new default-sink arity for mr/sink.
1 parent 3a4974b commit 96d3f7e

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

src/clojure/parkour/mapreduce.clj

+3-2
Original file line numberDiff line numberDiff line change
@@ -99,8 +99,9 @@ keyword indicating a built-in sinking function. Supported keywords are `:none`,
9999
[kind coll] (snk/sink-as kind coll))
100100

101101
(defn sink
102-
"Emit all tuples from `coll` to `sink`."
103-
[sink coll] ((snk/sink-fn coll) sink coll))
102+
"Emit all tuples from `coll` to `sink`, or to `*context*` if not provided."
103+
([coll] (sink *context* coll))
104+
([sink coll] ((snk/sink-fn coll) sink coll)))
104105

105106
(defn collfn
106107
"Task function adapter for collection-function-like functions. The adapted

0 commit comments

Comments
 (0)