cascalog.cascading.stats
Namespace implementing stats processing for the Cascading planner.
Namespace implementing stats processing for the Cascading planner.
*flow-process*clj
*op-call*clj
clojure-fileclj
Returns a stats handler that prints the final stats map to the supplied file (or output stream, etc, see clojure.java.io/writer) as a Clojure data structure.
Returns a stats handler that prints the final stats map to the supplied file (or output stream, etc, see clojure.java.io/writer) as a Clojure data structure.
counter-mapclj
(counter-map stats)Inputs: [stats :- CascadingStats] Returns: CounterMap
Digests the supplied stats object and returns a map of
Inputs: [stats :- CascadingStats] Returns: CounterMap Digests the supplied stats object and returns a map of
CounterGroupclj
CounterMapclj
Clojure representation of Cascading's counters.
Clojure representation of Cascading's counters.
CounterNameclj
default-groupclj
This is the default group name for any stats recorded in the course of a Cascalog job.
This is the default group name for any stats recorded in the course of a Cascalog job.
inc!clj
(inc! counter)(inc! group counter)Inputs: ([counter :- CounterName] [group :- CounterGroup counter :- CounterName])
Increments the supplied counter in the supplied group by 1. Only takes effect in the context of a Cascading flow.
Inputs: ([counter :- CounterName] [group :- CounterGroup counter :- CounterName]) Increments the supplied counter in the supplied group by 1. Only takes effect in the context of a Cascading flow.
inc-by!clj
(inc-by! counter value)(inc-by! group counter value)Inputs: ([counter :- CounterName value :- s/Int] [group :- CounterGroup counter :- CounterName value :- s/Int])
Increments the supplied counter in the supplied group by, you guessed it, the supplied amount. Only takes effect in the context of a Cascading flow.
Inputs: ([counter :- CounterName value :- s/Int] [group :- CounterGroup counter :- CounterName value :- s/Int]) Increments the supplied counter in the supplied group by, you guessed it, the supplied amount. Only takes effect in the context of a Cascading flow.
json-fileclj
Returns a stats handler that prints the final stats map to the supplied file (or output stream, etc, see clojure.java.io/writer) as a JSON data structure.
Returns a stats handler that prints the final stats map to the supplied file (or output stream, etc, see clojure.java.io/writer) as a JSON data structure.
map->jsonclj
(map->json m)My own little JSON fn to prevent pulling in a JSON library.
My own little JSON fn to prevent pulling in a JSON library.
map-byclj
(map-by f xs)Takes a value-generating function and a sequence and returns a map with the original seq elements as keys, and (f key) as each value.
Takes a value-generating function and a sequence and returns a map with the original seq elements as keys, and (f key) as each value.
stats-mapclj
(stats-map stats)Inputs: [stats :- CascadingStats] Returns: StatsMap
Returns a Clojure map of relevant stats from the Cascading stats object.
Inputs: [stats :- CascadingStats] Returns: StatsMap Returns a Clojure map of relevant stats from the Cascading stats object.
StatsMapclj
Clojure representation of the cascading.stats.CascadingStats data structure.
Clojure representation of the cascading.stats.CascadingStats data structure.
stdoutclj
(stdout)(stdout group)Inputs: ([] [group :- CounterGroup])
Inputs: ([] [group :- CounterGroup])
to-fileclj
(to-file path json?)Inputs: [path json? :- s/Bool]
path is passed to clojure.java.io/writer, so the argument can be a Writer, BufferedWriter, OutputStream, File, URI, URL, Socket, and String.
Inputs: [path json? :- s/Bool] path is passed to clojure.java.io/writer, so the argument can be a Writer, BufferedWriter, OutputStream, File, URI, URL, Socket, and String.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close