org.purefn.sentenza.annotate — org.purefn/sentenza 0.2.1

Various annotations of metadata that can be added to transducers to modify how they are used in the pipeline.

cored clj

(cored xf n)

Marks the transducer as a stateless and therefore parallelizable over multiple cores.

cored? clj

(cored? xf)

Checks whether a given transducer is marked as stateless.

has-meta clj

(has-meta xf & ks)

Checks whether a transducer has all of the given metadata keys.

name-of clj

(name-of xf)

Fetches the human readable name for a transducer.

named clj

(named xf name)

Marks the transducer with a human readable name, useful for monitoring.

paral clj

(paral xf)

Returns the number of threads to spin up for a threading transducer.

size clj

(size xf)

sized clj

(sized xf size)

Describes the size of the channel buffer this transducer's results will accumulate into. Defaults to 500 if unset.

threaded clj

(threaded xf)

(threaded xf n)

Marks a transducer as blocking by setting its metadata. Also takes the number of threads to spin up, defaults to 16.

threaded? clj

(threaded? xf)

Checks whether a given transducer is marked as blocking.

warned clj

(warned xf msg)

Adds a warning function as metadata to the transducer

warner clj

(warner xf)

Returned the warner function from the transducer's metadata.