View Source Glific.BigQuery (Glific v5.1.6)
Glific BigQuery Dataset and table creation
Link to this section Summary
Functions
Alter bigquery table schema, if required this function should be called from iex
Decoding the credential for bigquery
Refresh the bigquery schema and update all the older versions.
Format dates for the bigquery.
Format all the json values
Ignore the tables for updates operations
Returns the status if the bigquery is enabled for organization.
Insert rows in the bigquery
Merge delta and main tables.
Creating a dataset with messages and contacts as tables
Link to this section Functions
@spec alter_tables(Tesla.Client.t(), non_neg_integer(), String.t(), String.t()) :: :ok
Alter bigquery table schema, if required this function should be called from iex
decode_bigquery_credential(credentials, org_contact, organization_id)
View Source@spec decode_bigquery_credential(map(), map(), non_neg_integer()) :: {:ok, any()} | {:error, any()}
Decoding the credential for bigquery
@spec do_refresh_the_schema(non_neg_integer(), map()) :: {:error, Tesla.Env.t()} | {:ok, Tesla.Env.t()}
Refresh the bigquery schema and update all the older versions.
@spec format_date(DateTime.t() | nil, non_neg_integer()) :: String.t()
Format dates for the bigquery.
Format all the json values
@spec ignore_updates_for_table() :: list()
Ignore the tables for updates operations
@spec is_active?(non_neg_integer()) :: boolean()
Returns the status if the bigquery is enabled for organization.
@spec make_insert_query(map() | list(), String.t(), non_neg_integer(), Keyword.t()) :: :ok
Insert rows in the bigquery
@spec make_job_to_remove_duplicate(String.t(), non_neg_integer()) :: :ok
Merge delta and main tables.
@spec sync_schema_with_bigquery(non_neg_integer()) :: {:ok, any()} | {:error, any()}
Creating a dataset with messages and contacts as tables