Flume custome sink written by Clojure.

print_sink.clj

(ns example.print-sink
  (:import [org.apache.flume Sink Sink$Status]
           [org.apache.flume.event EventHelper])
  (:gen-class :name example.PrintSink
              :extends org.apache.flume.sink.AbstractSink
              :exposes-methods {getChannel parentGetChannel}))

(defn -configure [this context])


(defn -process [this]
  (let [ch (. this parentGetChannel)
        tx (. ch getTransaction)
        status (atom Sink$Status/BACKOFF)]
    (. tx begin)
    (try
      (when-let [event (. ch take)]
        (println (EventHelper/dumpEvent event))
        (reset! status Sink$Status/READY))
      (. tx commit)

      (catch Throwable t
        (. tx tollback))
      (finally
       (. tx close)))
    (println @status)
    @status))