nathanmarz/cascalog — Issue #30: Predicate constants are restricted by java serialization
Author: sritchie
Created: 2011-12-07 22:10:12+00:00
State: open
Labels: Bug

This is a problem at the cascading level. Ideally Cascading would use Kryo to send these constants around in the JobConf. Or is the decision to serialize in the JobConf a cascalog issue?

(defn square [x] (* x x))

(def src
[[(range 5 10)]
[(range 1 5)]])

(??<- [?out-seq]
(src ?xs)
(map #'square ?xs :> ?out-seq)
(:distinct false))