clj-headlights.bigtable-io

bigtable-io-read-table

(bigtable-io-read-table pipeline name project bigtable-options)

Inputs: [pipeline :- pcollections/PCollectionType name :- s/Str project :- s/Str bigtable-options :- BigtableOptionsMap]

bigtable-io-read-table-raw

(bigtable-io-read-table-raw pipeline name project {:keys [instance user-agent table]})

Inputs: [pipeline :- pcollections/PCollectionType name :- s/Str project :- s/Str {:keys [instance user-agent table]}]

bigtable-io-write

(bigtable-io-write pcoll name project {:keys [instance user-agent table]})

bigtable-row->clj-map

(bigtable-row->clj-map row)

Inputs: [row :- Row] Returns: BigtableReadRow

BigtableOptionsMap

BigtableReadRow

BigtableWriteRow

build-mutation

(build-mutation mutation)

Inputs: [mutation :- TableMutation] Returns: Mutation

get-cells-data

(get-cells-data cell-list)

get-columns-data

(get-columns-data column-list)

options-builder

(options-builder project instance-id user-agent builder)

row->bigtable-kv

(row->bigtable-kv row)

Inputs: [row :- BigtableWriteRow]

TableMutation