cascalog.cascading.util documentation

bench-op
(bench-op m coll)
Invokes the supplied Cascading Function.

cascalog-map
(cascalog-map op-var output-fields)
cascalog-mapcat
(cascalog-mapcat op-var output-fields)
cascalog.cascading.util.proxy$cascading.operation.BaseOperation$Function$da67433c
cascalog.cascading.util.proxy$cascading.operation.ConcreteCall$IPersistentCollection$ad07f3c8
cascalog.cascading.util.proxy$cascading.tuple.TupleEntryCollector$0
collect-to
(collect-to collector v)
default-output
(default-output from-fields to-fields)
Returns a default output field vector for operations that accept
from-fields and return to-fields.
fields
(fields x)
Returns the supplied object as an instance of Cascading Fields.

fields-array
(fields-array fields-seq)
generic-cascading-fields?
(generic-cascading-fields? cfields)
invoke-aggregator
(invoke-aggregator a colls)
invoke-filter
(invoke-filter fil coll)
Invokes the supplied Cascading filter with some tuple. The filter
will return true or false.
invoke-function
(invoke-function m coll)
Invokes the supplied Cascading Function.

pipe
(pipe)(pipe name)
Returns a Pipe of the given name, or if one is not supplied with a
unique random name.
pipes-array
(pipes-array pipes)
roundtrip
(roundtrip obj)
Round trip the supplied object through Cascading's base64
serialization.
taps-array
(taps-array taps)