cascalog.cascading.util — cascalog/cascalog-core 3.0.0

bench-op clj

(bench-op m coll)

Invokes the supplied Cascading Function.

cascalog-map clj

(cascalog-map op-var output-fields)

cascalog-mapcat clj

(cascalog-mapcat op-var output-fields)

collect-to clj

(collect-to collector v)

default-output clj

(default-output from-fields to-fields)

Returns a default output field vector for operations that accept from-fields and return to-fields.

fields clj

(fields x)

Returns the supplied object as an instance of Cascading Fields.

fields-array clj

(fields-array fields-seq)

generic-cascading-fields? clj

(generic-cascading-fields? cfields)

invoke-aggregator clj

(invoke-aggregator a colls)

invoke-filter clj

(invoke-filter fil coll)

Invokes the supplied Cascading filter with some tuple. The filter will return true or false.

invoke-function clj

(invoke-function m coll)

Invokes the supplied Cascading Function.

pipe clj

(pipe)

(pipe name)

Returns a Pipe of the given name, or if one is not supplied with a unique random name.

pipes-array clj

(pipes-array pipes)

roundtrip clj

(roundtrip obj)

Round trip the supplied object through Cascading's base64 serialization.

taps-array clj

(taps-array taps)