(build-topology {:keys [db config] :as app} builder)
Build the Kafka Streams topology.
Build the Kafka Streams topology.
(config & [opts])
Returns the configuration for the app.
Returns the configuration for the app.
(create-partition-table! db {:keys [valid-time] :as dataset})
Create the raster partition table for the dataset
in db
.
Create the raster partition table for the `dataset` in `db`.
(drop-partition-table! db {:keys [valid-time] :as dataset})
Drop the spot weather partition table for the dataset
in db
.
Drop the spot weather partition table for the `dataset` in `db`.
(partition-end-time valid-time)
Returns the partition end time for valid-time
.
Returns the partition end time for `valid-time`.
(partition-start-time valid-time)
Returns the partition start time for valid-time
.
Returns the partition start time for `valid-time`.
(partition-table valid-time)
Returns the partition table name.
Returns the partition table name.
(select-spot-weather db dataset)
Select the spot weather for dataset
.
Select the spot weather for `dataset`.
(update-partition! db dataset)
Update the spot weather partition for dataset
in db
.
Update the spot weather partition for `dataset` in `db`.
(update-spot-weather! db {:keys [id] :as dataset})
Download the dataset
, convert and center it, and finally load it
into the db
.
Download the `dataset`, convert and center it, and finally load it into the `db`.
(worker & [opts])
Returns a new weather spot worker.
Returns a new weather spot worker.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close