clojure-hadoop.wrap
clojure-map-readerclj
(clojure-map-reader wkey wvalue)Returns a [key value] pair by calling read-string on the string representations of the Writable key and value.
Returns a [key value] pair by calling read-string on the string representations of the Writable key and value.
clojure-reduce-readerclj
(clojure-reduce-reader wkey wvalues)Returns a [key seq-of-values] pair by calling read-string on the string representations of the Writable key and values.
Returns a [key seq-of-values] pair by calling read-string on the string representations of the Writable key and values.
clojure-writerclj
(clojure-writer context key value)Sends key and value to the Context by calling pr-str on key and value and wrapping them in Hadoop Text objects.
Sends key and value to the Context by calling pr-str on key and value and wrapping them in Hadoop Text objects.
string-map-readerclj
(string-map-reader wkey wvalue)Returns a [key value] pair by calling .toString on the Writable key and value.
Returns a [key value] pair by calling .toString on the Writable key and value.
wrap-mapclj
(wrap-map f)(wrap-map f reader)(wrap-map f reader writer)Returns a function implementing the Mapper.map interface.
f is a function of two arguments, key and value.
f must return a sequence of pairs like [[key1 value1] [key2 value2] ...]
When f is called, context is bound to the Hadoop Reporter.
reader is a function that receives the Writable key and value from Hadoop and returns a [key value] pair for f.
writer is a function that receives each [key value] pair returned by f and sends the appropriately-type arguments to the Hadoop Context.
If not given, reader and writer default to clojure-map-reader and clojure-writer, respectively.
Returns a function implementing the Mapper.map interface. f is a function of two arguments, key and value. f must return a *sequence* of *pairs* like [[key1 value1] [key2 value2] ...] When f is called, *context* is bound to the Hadoop Reporter. reader is a function that receives the Writable key and value from Hadoop and returns a [key value] pair for f. writer is a function that receives each [key value] pair returned by f and sends the appropriately-type arguments to the Hadoop Context. If not given, reader and writer default to clojure-map-reader and clojure-writer, respectively.
wrap-reduceclj
(wrap-reduce f)(wrap-reduce f writer)(wrap-reduce f reader writer)Returns a function implementing the Reducer.reduce interface.
f is a function of two arguments. First argument is the key, second argument is a function, which takes no arguments and returns a lazy sequence of values.
f must return a sequence of pairs like [[key1 value1] [key2 value2] ...]
When f is called, context is bound to the Hadoop Reporter.
reader is a function that receives the Writable key and value from Hadoop and returns a [key values-function] pair for f.
writer is a function that receives each [key value] pair returned by f and sends the appropriately-typed arguments to the Hadoop Context.
If not given, reader and writer default to clojure-reduce-reader and clojure-writer, respectively.
Returns a function implementing the Reducer.reduce interface. f is a function of two arguments. First argument is the key, second argument is a function, which takes no arguments and returns a lazy sequence of values. f must return a *sequence* of *pairs* like [[key1 value1] [key2 value2] ...] When f is called, *context* is bound to the Hadoop Reporter. reader is a function that receives the Writable key and value from Hadoop and returns a [key values-function] pair for f. writer is a function that receives each [key value] pair returned by f and sends the appropriately-typed arguments to the Hadoop Context. If not given, reader and writer default to clojure-reduce-reader and clojure-writer, respectively.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close