Load json from Netflix PigPen

core.clj

(ns pigpen-exp.core
  (:require [pigpen.core :as pig]
            [pigpen.raw :as raw]
            [clojure.data.json])
  (:gen-class))

(defmacro load-json
  "Loads json data from a file. Each line should contain one value and
will be parsed using clojure.data.json/read-str into a value. Keys are
converted to keywords.

  Example:

    (load-json \"input.json\")

  See also: pigpen.core/load-clj
"
  [location]
  `(->
     (raw/load$ ~location '~['value] raw/default-storage {:cast "chararray"})
     (raw/bind$ '(pigpen.pig/map->bind
                  #(clojure.data.json/read-str % :key-fn clojure.core/keyword))
                {:requires '[clojure.data.json], :field-type-in :native})))