datasplash.examples — datasplash 0.7.4

-main clj

(-main job & args)

CombinePerKeyOptions clj

count-words clj

(count-words p)

DatastoreWordCountOptions clj

DeDupOptions clj

FilterOptions clj

format-count clj

(format-count [k v])

make-ancestor-key clj

(make-ancestor-key {:keys [kind namespace]})

make-ancestor-kind-query clj

(make-ancestor-kind-query {:keys [kind namespace] :as opts})

MaxPerKeyOptions clj

PubSubOptions clj

run-combine-per-key clj

(run-combine-per-key str-args)

run-datastore-word-count clj

(run-datastore-word-count str-args)

run-dedup clj

(run-dedup str-args)

run-filter clj

(run-filter str-args)

run-max-per-key clj

(run-max-per-key str-args)

run-pub-sub clj

(run-pub-sub str-args)

run-standard-sql-query clj

(run-standard-sql-query str-args)

run-word-count clj

(run-word-count str-args)

StandardSQLOptions clj

stream-forwarded-interactions-from-pubsub clj

(stream-forwarded-interactions-from-pubsub pipeline
                                           read-transformed-subscription)

stream-interactions-from-pubsub clj

(stream-interactions-from-pubsub pipeline read-topic write-transformed-topic)

tokenize clj

(tokenize l)

WordCountOptions clj