Skip to content

Instantly share code, notes, and snippets.

Keybase proof

I hereby claim:

  • I am danlarkin on github.
  • I am danlarkin (https://keybase.io/danlarkin) on keybase.
  • I have a public key whose fingerprint is 2E9B 9621 EB86 78E9 6D56 F749 0B2B 9E23 2D59 9370

To claim this, I am signing this object:

(defn interleave-all [c1 c2]
(lazy-seq
(let [s1 (seq c1) s2 (seq c2)]
(when (or s1 s2)
(cons (first s1) (cons (first s2)
(interleave-all (rest s1) (rest s2))))))))
=> (interleave [1 2 3] '[a b])
(1 a 2 b)
(send-off (agent 1) (fn [_]
(send-off (agent 2) (fn [_]
(println "Hey!")))
(Thread/sleep 4000)))
;; "Hey!" doesn't print for 4 seconds.
;; This is because actions to agent 2 won't be dispatched until agent 1 has finished its current action.
;; Why?
~ $
~ $
~ $
~ $
~ $
~ $
~ $
% ~ $
~ $
~ $
Tarragon:logparser dan$ hadoop jar build/logparser.jar data/apache.200.txt logparser-output
09/08/28 12:54:29 INFO flow.MultiMapReducePlanner: using application jar: /Users/dan/Downloads/logparser/build/logparser.jar
09/08/28 12:54:29 INFO flow.Flow: [parser] starting
09/08/28 12:54:29 INFO flow.Flow: [parser] source: Lfs["TextLine[['offset', 'line']->[ALL]]"]["data/apache.200.txt"]"]
09/08/28 12:54:29 INFO flow.Flow: [parser] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["logparser-output"]"]
Exception in thread "main" cascading.flow.FlowException: unhandled exception
at cascading.flow.Flow.complete(Flow.java:646)
at logparser.Main.main(Unknown Source)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
(ns clojure-http.http
(:use [clojure.contrib.java-utils :only [as-str]]
[clojure.contrib.duck-streams :only [read-lines]]
[clojure.contrib.str-utils :only [str-join]])
(:import (java.net URL HttpURLConnection)))
;(java.io InputStreamReader)))
(defn create-url
"If url is an instance of java.net.URL then returns it without
modification, otherwise tries to instantiate a java.net.URL with
ant \
-Dclojure.jar=/Users/dan/clojure/src/clojure/clojure.jar \
-Dcontrib.jar=/Users/dan/clojure/src/clojure-contrib/clojure-contrib.jar \
-Dring.jar=/Users/dan/clojure/src/ring/src \
-Dfnparse.jar=/Users/dan/clojure/src/fnparse/src \
-Dcljbacktrace.jar=/Users/dan/clojure/src/clj-backtrace/src \
-Dservlet.jar=/Users/dan/clojure/src/jars/servlet-api-2.5-6.1.14.jar \
-Djetty.jar=/Users/dan/clojure/src/jars/jetty-6.1.14.jar \
-Djettyutil.jar=/Users/dan/clojure/src/jars/jetty-util-6.1.14.jar \
-Dcommonsio.jar=/Users/dan/clojure/src/jars/commons-io-1.4.jar