cascalog.cascading.types documentation

->ClojureFlow
(->ClojureFlow source-map sink-map trap-map tails pipe name)
Positional factory function for class cascalog.cascading.types.ClojureFlow.

IGenerator
Accepts some type and returns a ClojureFlow that can be used as a
generator. The idea is that a clojure flow can always be used
directly as a generator.
ISink
ITuple
array-of
(array-of t)
generator
(generator x)
generator?
(generator? x)
Returns true if the supplied item can be used as a Cascalog
generator, false otherwise.
map->ClojureFlow
(map->ClojureFlow m__5818__auto__)
Factory function for class cascalog.cascading.types.ClojureFlow, taking a map of keywords to field values.

to-sink
(to-sink this)
Returns a Cascading tap into which Cascalog can sink the supplied
data.
to-tuple
(to-tuple this)
Returns a tupled representation of the supplied thing.