datasplash.bq — datasplash 0.7.4

->schema clj

(->schema defs)

(->schema defs transform-keys)

->time-partitioning clj

(->time-partitioning {:keys [type expiration-ms field require-partition-filter]
                      :or {type :day}})

auto-parse-val clj

(auto-parse-val v)

bqize-keys clj

(bqize-keys m)

Recursively transforms all map keys to BQ-valid strings.

clean-name clj

(clean-name s)

clj->table-row clj

(clj->table-row hmap)

clj-nested->table-row clj

(clj-nested->table-row hmap)

coerce-by-bq-val clj

(coerce-by-bq-val v)

create-disposition-enum clj

custom-output-fn clj

(custom-output-fn cust-fn)

format-fn clj

get-bq-table-schema clj

(get-bq-table-schema table-spec)

Beware, uses bq util to get the schema!

read-bq clj

(read-bq options p)

read-bq-raw clj

(read-bq-raw {:keys [query table standard-sql?] :as options} p)

retry-policy-enum clj

schema-update-options-enum clj

table-row->clj clj

(table-row->clj row)

(table-row->clj {:keys [auto-parse]} row)

write-bq-table clj

(write-bq-table to pcoll)

(write-bq-table to options pcoll)

write-bq-table-raw clj

(write-bq-table-raw to pcoll)

(write-bq-table-raw to options pcoll)

write-bq-table-schema clj

write-disposition-enum clj

write-method-enum clj