gistfile1.clj

=> (?<- (stdout) [?a-new]
          ([{:a 1 :b 2}
            {:a 10 :b 20}] ?ds)
     (map ?ds [:a] :> ?a-new))

RESULTS
-----------------------
1
10

=> (?<- (stdout) [?a-new]
      ([{:a 1M :b 2}
        {:a 10M :b 20}] ?ds)
      (map ?ds [:a] :> ?a-new))

RESULTS
-----------------------
1
10


=> (?<- (stdout) [?a-new]
      ([{:a 1N :b 2}
        {:a 10N :b 20}] ?ds)
      (map ?ds [:a] :> ?a-new))

cascading.pipe.OperatorException: [7db78a31-3cb8-4691-8f7...][sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)] operator Every failed executing buffer: FastFirst[decl:ARGS]
        at cascading.pipe.Every$EveryBufferHandler.operate(Every.java:542)
        at cascading.flow.stack.EveryBufferReducerStackElement.collect(EveryBufferReducerStackElement.java:89)
        at cascading.flow.stack.GroupReducerStackElement.operateGroup(GroupReducerStackElement.java:74)
        at cascading.flow.stack.GroupReducerStackElemeuser=> nt.collect(GroupReducerStackElement.java:58)
        at cascading.flow.stack.FlowReducerStack.reduce(FlowReducerStack.java:169)
        at cascading.flow.FlowReducer.reduce(FlowReducer.java:75)
        at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:463)
        at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:411)
        at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:215)
Caused by: java.lang.ClassCastException: clojure.lang.BigInt cannot be cast to java.lang.Comparable
        at cascading.kryo.KryoComparator.compare(KryoComparator.java:15)
        at cascading.tuple.hadoop.TupleElementComparator.compare(TupleElementComparator.java:66)
        at cascading.tuple.hadoop.DelegatingTupleElementComparator.compare(DelegatingTupleElementComparator.java:56)
        at cascading.tuple.hadoop.DeserializerComparator.compareTuples(DeserializerComparator.java:120)
        at cascading.tuple.hadoop.TupleComparator.compare(TupleComparator.java:54)
        at cascading.tuple.hadoop.TupleComparator.compare(TupleComparator.java:30)
        at org.apache.hadoop.mapred.Task$ValuesIterator.readNextKey(Task.java:978)
        at org.apache.hadoop.mapred.Task$ValuesIterator.next(Task.java:932)
        at org.apache.hadoop.mapred.ReduceTask$ReduceValuesIterator.moveToNext(ReduceTask.java:241)
        at org.apache.hadoop.mapred.ReduceTask$ReduceValuesIterator.next(ReduceTask.java:237)
        at cascading.pipe.cogroup.GroupClosure$1.next(GroupClosure.java:83)
        at cascading.pipe.cogroup.GroupClosure$1.next(GroupClosure.java:73)
        at cascading.pipe.cogroup.InnerJoin$JoinIterator.initLastValues(InnerJoin.java:82)
        at cascading.pipe.cogroup.InnerJoin$JoinIterator.next(InnerJoin.java:114)
        at cascading.pipe.cogroup.InnerJoin$JoinIterator.next(InnerJoin.java:48)
        at cascading.tuple.TupleEntryIterator.next(TupleEntryIterator.java:101)
        at cascading.pipe.Every$EveryBufferHandler$2.next(Every.java:523)
        at cascading.pipe.Every$EveryBufferHandler$2.next(Every.java:510)
        at cascalog.FastFirst.operate(FastFirst.java:36)
        at cascading.pipe.Every$EveryBufferHandler.operate(Every.java:534)