cascading maple query

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

(use '[cascalog api playground])

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

(defn to-string [bytes]
  (if (= nil bytes)
    ""
    (String. bytes)))

(defn trial-query
  []
  (let [h-table (hbase-tap "test" "row1" "cf" "a")]
    (?<- (stdout)
         [!l !l1]
         (h-table !name !temp)
         (to-string !name :> !l)
         (to-string !temp :> !l1))))