gardnervickers

15-Dec-10 10:39:17 Gardner-Vickers-Mac.local INFO [onyx.log.zookeeper] - Stopping ZooKeeper client connection
Exception updating the ns-cache #error {
 :cause Task clojure.lang.Agent$Action@e382ea9 rejected from java.util.concurrent.ThreadPoolExecutor@44771cf1[Terminated, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 4]
 :via
 [{:type java.util.concurrent.RejectedExecutionException
   :message Task clojure.lang.Agent$Action@e382ea9 rejected from java.util.concurrent.ThreadPoolExecutor@44771cf1[Terminated, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 4]
   :at [java.util.concurrent.ThreadPoolExecutor$AbortPolicy rejectedExecution ThreadPoolExecutor.java 2047]}]
 :trace
 [[java.util.concurrent.ThreadPoolExecutor$AbortPolicy rejectedExecution ThreadPoolExecutor.java 2047]
  [java.util.concurrent.ThreadPoolExecutor reject ThreadPoolExecutor.java 823]

gardnervickers

Onyx: Windowing, triggers and refinements.

With Onyx 0.8, we gain the ability to do state management. Onyx introduces windowing, as described in Google's Dataflow Model paper. ¹

We will discuss windowing, triggers, and refinements and how they interact. Showing the different types of windows and triggers. When not providing concrete implementations, we will provide practical problems each type solves.

Time

---

There are two notions of time discussed in the literature.

gardnervickers

 {:ip "192.168.204.125", :reacheable? false}
 {:ip "192.168.204.126", :reacheable? false}
 {:ip "192.168.204.253", :reacheable? false}
 {:ip "192.168.204.254", :reacheable? false}
 {:ip "192.168.248.119", :reacheable? false}
 {:ip "192.168.248.163", :reacheable? false}
 {:ip "192.168.248.217", :reacheable? false}
 {:ip "192.168.248.227", :reacheable? false}
 {:ip "192.168.248.232", :reacheable? false}
 {:ip "192.168.248.235", :reacheable? false}

gardnervickers

(defn start-go-peer
  "Applies XF"
  ([in-chan xf] (start-go-peer in-chan xf (chan)))
  ([in-chan xf out-chan] (start-go-peer in-chan xf out-chan 1))
  ([in-chan xf out-chan parallelism]
   (let [running? (atom true)]
     (do (async/pipeline parallelism out-chan xf in-chan)
         {:fauonyx/out out-chan
          :fauonyx/in  in-chan

gardnervickers

[:pdf-table
  [10 20 15]
  ["foo" [:chunk {:style :bold} "bar"] [:phrase "baz"]]
  [[:pdf-cell "foo"] [:pdf-cell "foo"] [:pdf-cell "foo"]]
  [[:pdf-cell "foo"] [:pdf-cell "foo"] [:pdf-cell "foo"]]]

gardnervickers

mv lib lib2                                   // Moved the symlink
cp lib2 ~/jars                                // copied the jars from lib2 to ~/jars
cp -r lib2 ~/jars                             // recursive copy ^^
cp -r lib2 ~/jars                             // recursive copy ^^
sudo cp -r lib2 ~/jars                        // recursive copy ^^ sudo
find lib2 -user root -exec cp {} ~/lib/{} \;  // copy jars owned by root to ~/lib in my local
find lib2/ -user root -exec cp {} ~/lib/{} \; // sudo copy jars owned by root to ~/lib in my local
ls lib2
mv lib2 lib                                   // reset lib2 to lib

gardnervickers

function setjdk() {
  if [ $# -ne 0 ]; then
   removeFromPath '/System/Library/Frameworks/JavaVM.framework/Home/bin'
   if [ -n "${JAVA_HOME+x}" ]; then
    removeFromPath $JAVA_HOME
   fi
   export JAVA_HOME=`/usr/libexec/java_home -v $@`
   export PATH=$JAVA_HOME/bin:$PATH
  fi
 }

gardnervickers

export GOVC_RESOURCE_POOL='*/Resources'

gardnervickers

(defn gen-contact-table
  [size]
  (mapv (fn [i]
          {:name (str (rand-nth ["Gardner" "Mike" "Matt" "Jordan" "Vinny" "Jacob"])
                      " "
                      (rand-nth ["Vickers" "Heskie" "Dawson" "Carol" "Stark"]))
           :email (rand-nth ["gardner@vickers.me" "test@test.com" "fakemail@inva.lid"])
           :position (rand-nth ["floor-sweeper" "cart-pusher" "president"])
           :company (rand-nth ["mcdonalds" "carousel" "medlyfe" "YoloCorp"])
           :expertise [(rand-nth ["avaya" "nortel" "cisco" "alarmtraq"])

gardnervickers

 ;; Code
 [[:in :concat-names]
  [:concat-names :parse-dates]
  [:parse-dates :time-left]
  [:time-left :notify-near-expiration]
  [:notify-near-expiration :out]
  [:time-left :out]]

;; What the code means
          :in ; Read data line-by-line from a file