Parkour 0.6.3 API documentation

->DSink

Positional factory function for class parkour.io.dsink.DSink.

dsink

Return distributed sink represented by job configuration step `step` and
producing the distributed sequence `dseq` once generated.  Result is a config
step which returns `dseq` when called as a zero-argument function.  When `dseq`
is not provided, and `step` is not already a distributed sink, the resulting
sink produces the `nil` dseq.

dsink-dseq

Force `step` to a dsink, then return its corresponding dseq.

dsink?

True iff `x` is a distributed sink.

output-paths

Vector of output-paths produced by job or configuration step `step`.

output-paths*

Internal implementation multimethod for `output-paths`.

set-default-shape!

Set default sink shape for `conf` to `shape`.

sink-for

Local sink for writing tuples as written via `dsink`.  Must `.close` to
flush, as via `with-open`.

with-dseq

macro

Evaluate `body` forms, write tuples from resulting collection to the local
sink produced from `dsink`, and return `dsink`'s associated dseq.

with-dseq*

Function form of `with-dseq`.