Cascalog test with HBase

hbase.clj

(ns test.hbase
  (:require (cascalog [workflow :as w]
                      [ops :as c]
                      [vars :as v]))
  (:import (org.apache.hadoop.hbase.util Bytes)
           (com.twitter.maple.hbase HBaseTap HBaseScheme)
           (cascading.hbase ByteHolder)))

(use '[cascalog api playground])
(bootstrap-emacs)

(defn hbase-tap [table-name key-field column-family & value-fields]
  (let [scheme (HBaseScheme. (w/fields key-field) column-family (w/fields value-fi\
elds))]
    (HBaseTap. table-name scheme)))

(defn as-string [^ByteHolder bytes]
    (.toString bytes))

(let [age-table (hbase-tap "age-table" "?person" "cf" "?age")]
    (?<- (stdout) [?p ?a] (age-table ?p ?age) (as-string ?age :> ?a)))