gistfile1.clj

cascalog.playground> (?<- (stdout) [?person ?age] (age ?person ?age) (< ?age 30))
INFO - using default application jar, may cause class not found exceptions on the cluster
INFO - using application jar: /home/akm/src/clojure/hadoop/lib/cascading-core-1.2-wip-63.jar
INFO - [] starting
INFO - []  source: cascalog.MemorySourceTap@3e0
INFO - []  sink: StdoutTap["SequenceFile[[UNKNOWN]->[ALL]]"]["/tmp/temp69430827573878467652505554465178270"]"]
INFO - []  parallel execution is enabled: false
INFO - []  starting jobs: 1
INFO - []  allocating threads: 1
INFO - [] starting step: (1/1) ...eFile[[UNKNOWN]->[ALL]]"]["/tmp/temp69430827573878467652505554465178270"]"]
INFO - Cannot initialize JVM Metrics with processName=JobTracker, sessionId= - already initialized
INFO - numReduceTasks: 1
INFO - io.sort.mb = 100
INFO - data buffer = 79691776/99614720
INFO - record buffer = 262144/327680
INFO - Starting flush of map output
INFO - Finished spill 0
INFO - Task:attempt_local_0003_m_000000_0 is done. And is in the process of commiting
INFO - 
INFO - Task 'attempt_local_0003_m_000000_0' done.
INFO - 
INFO - Merging 1 sorted segments
INFO - Down to the last merge-pass, with 1 segments left of total size: 91 bytes
INFO - 
INFO - Task:attempt_local_0003_r_000000_0 is done. And is in the process of commiting
INFO - 
INFO - Task attempt_local_0003_r_000000_0 is allowed to commit now
INFO - Saved output of task 'attempt_local_0003_r_000000_0' to file:/tmp/temp69430827573878467652505554465178270
INFO - reduce > reduce
INFO - Task 'attempt_local_0003_r_000000_0' done.
INFO - deleting temp path /tmp/temp69430827573878467652505554465178270/_temporary
INFO - Total input paths to process : 1


RESULTS
-----------------------
david	25
emily	25
kumar	27
alice	28
gary	28
-----------------------
nil
cascalog.playground>