                        (delta-cntr (str "blocked-" t-id) blocked)))))))))
 
 (def cli-options
-  [["-h" "--help"]
+  [["-b" "--batch-size BATCH-SIZE"
+    "The number of data instances to be generated for one batch."
+    :default 2000
+    :parse-fn #(Integer/parseInt %)]
+   ["-d" "--batch-delay BATCH-DELAY"
+    "The delay in ms between generating batches."
+    :default 1
+    :parse-fn #(Integer/parseInt %)]
+   ["-h" "--help"]
    ["-i" "--in-data IN-DATA"
     "The input data to be used."
     :default nil

                          (fn []
                            (proc-fn in-data)
                            (.inc out-cntr)))
                      (not (nil? in-data)) (let [in-fn (get-in-fn pipeline)]
                                             (fn []
                                         ;      (doseq [i (repeat 2000 0)]
                                                 (in-fn in-data)
                                                 (.inc in-cntr))
                                           )
                                         ;      (sleep 1)))
                      :default (fn [] (.inc out-cntr))))
          thread-info-fn (create-thread-info-fn)
          stats-fn (fn []

                                           fn-mapping
                                           sample-pcap-processing-definition-json))
                       out-fn))
          batch-delay (:batch-delay options)
          batch-size (:batch-size options)
          in-loop (ProcessingLoop.
                    "DataGenerationLoop"
                    (cond
