         "dedup" (run-dedup args)
         "filter" (run-filter args)
         "combine-per-key" (run-combine-per-key args)
-        "max-per-key" (run-max-per-key args))
+        "max-per-key" (run-max-per-key args)
+        "datastore-word-count" (run-datastore-word-count args))
       (ds/run-pipeline)))

                         results)
      (ds/write-edn-file output results))))

;;;;;;;;;;
;; Main ;;
;;;;;;;;;;

  (:require [clojure.string :as str]
            [datasplash
             [api :as ds]
             [bq :as bq]
             [datastore :as dts]]
            [clojure.edn :as edn])
  (:import [java.util UUID])
  (:gen-class))

;;;;;;;;;;;;;;;
