src/clj/backtype/storm/bootstrap.clj

(ns backtype.storm.bootstrap)

(defmacro bootstrap []
  '(do
      (import (quote [backtype.storm Constants]))
      (import (quote [backtype.storm.testing FeederSpout TestPlannerBolt TestPlannerSpout AckFailDelegate AckTracker]))
      (import (quote [backtype.storm.utils Utils LocalState Time TimeCacheMap
                      TimeCacheMap$ExpiredCallback BufferFileInputStream]))
      (import (quote [backtype.storm.serialization KryoTupleSerializer KryoTupleDeserializer]))
      (import (quote [backtype.storm.spout ISpout SpoutOutputCollector ISpoutOutputCollector ShellSpout]))
      (import (quote [backtype.storm.tuple Tuple Fields MessageId]))
      (import (quote [backtype.storm.task IBolt IOutputCollector
                      OutputCollector OutputCollectorImpl IInternalOutputCollector
                      TopologyContext ShellBolt]))
      (import (quote [backtype.storm.drpc CoordinatedBolt
                      CoordinatedBolt$SourceArgs KeyedFairBolt]))
      (import (quote [backtype.storm.daemon Shutdownable]))
      (require (quote [backtype.storm.messaging.loader :as msg-loader]))
      (require (quote [backtype.storm.messaging.protocol :as msg]))
      (use (quote [backtype.storm config util log clojure timer]))
      (use (quote [clojure.contrib.seq :only [find-first]]))
      (require (quote [backtype.storm [thrift :as thrift] [cluster :as cluster]
                                      [event :as event] [process-simulator :as psim]]))
      (require (quote [clojure.set :as set]))
      (require (quote [backtype.storm [stats :as stats]]))
      (import (quote [org.apache.log4j PropertyConfigurator Logger]))

      (import (quote [backtype.storm.generated Nimbus Nimbus$Processor
                      Nimbus$Iface StormTopology ShellComponent
                      NotAliveException AlreadyAliveException
                      InvalidTopologyException ClusterSummary TopologyInfo
                      TopologySummary TaskSummary TaskStats TaskSpecificStats
                      SpoutStats BoltStats ErrorInfo SupervisorSummary
                      KillOptions RebalanceOptions JavaObject JavaObjectArg]))
      (import (quote [backtype.storm.daemon.common StormBase Assignment
                      TaskInfo SupervisorInfo WorkerHeartbeat TaskHeartbeat]))
      (import (quote [backtype.storm.grouping CustomStreamGrouping]))
      (import (quote [java.io File FileOutputStream FileInputStream]))
      (import (quote [java.util List Random Map HashMap]))
      (import (quote [org.apache.commons.io FileUtils]))
      (import (quote [java.util ArrayList]))
      ))