?\,SrSSKJrJrJrJr SSKJr SSKJ r SSK J r SSK Jr SSK Jr SSK Jr S rS \R$S \R&R(4S jrSDS\R$S \R&R(S\\\R,S\\S\\S\\4 SjjrSES \R$S\R&R(S\\S\\S\\S\\4 SjjrSFS \R$S\R&R8S\\S\\4SjjrS\R$S\R&R(4SjrS\R$S\R&R(4S jrS \R$S\R&R(S!\\4S"jr S \R$S\R&R(4S#jr!SGS \R$S\R&R(S$\S%\\S&\\S'\\S(\\S)\\S*\\S+\\S,\\S-\\S.\\S/\\\\4S0\\\\\4S1\\S2\\S3\\S4\\S5\\\\44(S6jjr"SHS \R$S\R&R(S&\\S'\\S(\\S)\\S*\\S+\\S,\\S-\\S.\\S7\\\\4S8\\\S0\\\\\4S1\\S9\\S3\\S:\S;\\\\4S<\\\S=\4*S>jjr#S \R$S\R&R(4S?jr$SIS \R$S\R&R(S:\S9\\4S@jjr%S \R$S\R&R(4SAjr&SJS \R$S\R&R(SB\4SCjjr'g )Kz&The BigQuery CLI table client library.)DictListOptionalcast) discovery) table_reader)utils)bq_error) bq_id_utils)bq_processor_utilsexternalCatalogTableOptions apiclient table_dictcUR5R"S0UD6R5nURS05$)Nschema)tablesgetexecute)rr table_infos #platform/bq/clients/client_table.pyget_table_schemars:!%%3 3;;=* " %%N insert_clientinsertsskip_invalid_rowsignore_unknown_valuestemplate_suffixcSnUR5R"SS[UUU[[ Xb55S90UD6nUR 5$)a/Insert rows into a table. Arguments: insert_client: The apiclient used to make the request. table_dict: table reference into which rows are to be inserted. inserts: array of InsertEntry tuples where insert_id can be None. skip_invalid_rows: Optional. Attempt to insert any valid rows, even if invalid rows are present. ignore_unknown_values: Optional. Ignore any values in a row that are not present in the schema. template_suffix: Optional. The suffix used to generate the template table's name. Returns: result of the operation. cl[URS9nUR(aURUS'U$)N)jsoninsertId)dictrecord insert_id)insertencodeds r_encode_insert)insert_table_rows.._encode_insert2s. &G ",,gj Nrbody)skipInvalidRowsignoreUnknownValuestemplateSuffixrowsr) tabledata insertAllr#listmapr)rrrrrrr(ops rinsert_table_rowsr4s]2  ** +3(C01   " r table_ref start_rowmax_rowsselected_fieldsmax_rows_per_requestcUc [S5eUc [S5e[R"XU5nURUUUS9$)aQConvenience method to get the schema and rows from a table. Arguments: apiclient: The apiclient used to make the request. table_ref: table reference. start_row: first row to read. max_rows: number of rows to read. selected_fields: a subset of fields to return. max_rows_per_request: the maximum number of rows to read per request. Returns: A tuple where the first item is the list of fields and the second item a list of rows. Raises: ValueError: will be raised if start_row is not explicitly provided. ValueError: will be raised if max_rows is not explicitly provided. zstart_row is requiredzmax_rows is required)r8) ValueErrorbq_table_readerTableTableReaderReadSchemaAndRows)rr5r6r7r8r9rs rread_schema_and_rowsr?Ds`4 , --  + ,, 11y,  ' '% ( r reference max_results page_tokenc>[R"U[RRSS9 [R "XU5nUR 5R"S0UD6R5nURS/5nUbSU;a[U5U:aU[U5- US'USUS'UR 5R"S0UD6R5nURURS/55 SU;a[U5U:aMU$)z/List the tables associated with this reference. list_tablesmethodr nextPageToken maxResults pageTokenr) r typecheckApiClientHelperDatasetReferencer PrepareListRequestrr1rrlenextend)rr@rArBrequestresultresultss rrDrDls!!22   1 1j '     " " -W - 5 5 7& JJx $' V #G {(B)CL8gl#O4gk!&&1199;f nnVZZ"-. V #G {(B .riampolicy_clientc [R"U[RRSS9 SUR<SUR <SUR <3nUR5RUS9R5$)a3Gets IAM policy for the given table resource. Arguments: iampolicy_client: The apiclient used to make the request. reference: the TableReference for the table resource. Returns: The IAM policy attached to the given table resource. Raises: BigqueryTypeError: if reference is not a TableReference. get_table_iam_policyrE projects/ /datasets//tables/)resource) r rJrKTableReference projectId datasetIdtableIdr getIamPolicyr)rSr@formatted_resources rrUrUss !!00 #  |/|0wyrc[R"U[RRSS9 SUR<SUR <SUR <3nSU0nUR5RXCS9R5$)agSets IAM policy for the given table resource. Arguments: iampolicy_client: The apiclient used to make the request. reference: the TableReference for the table resource. policy: The policy string in JSON format. Returns: The updated IAM policy attached to the given table resource. Raises: BigqueryTypeError: if reference is not a TableReference. set_table_iam_policyrErVrWrXpolicy)r*rY) r rJrKrZr[r\r]r setIamPolicyr)rSr@rbr_rPs rraras|$!!00 #  v '||>wyrreturnc[R"U[RRSS9 UR 5R "S0[ U5D6R5S$![Ra gf=f)z*Returns the region of a table as a string.get_table_regionrElocationNr r rJrKrZrrr#rr BigqueryNotFoundErrorrr@s rrfrfss !!00       ! ! 4DO 4 < < >z JJ  ' ' s9A**BBc[R"U[RRSS9 UR 5R "S0[ U5D6R5$![Ra gf=f)z!Returns true if the table exists. table_existsrEFrrhrjs rrlrlsn !!00       ! ! 4DO 4 < < >>  ' ' s6A''A>=A>ignore_existingr description display_name expiration view_querymaterialized_view_queryenable_refreshrefresh_interval_ms max_stalenessuse_legacy_sqllabels clusteringrequire_partition_filterdestination_kms_keyrgtable_constraints resource_tagsc[R"U[RRSS9 [R "U5nUbSU0US'UbUUS'UbUUS'UbUUS'UbS U0nUbUUS 'UUS 'UbUUS 'UbS U0nU bU US 'U bU US'UUS'U b U bU US'U US'U bU US'Ub[ R"U5US'UbUUS'UbUUS'UbUUS'UbUUS'UbUUS'UbSU0US'UbUUS'UbUUS'UbUUS'[XU5 g![Ra U(degf=f)a. Create a table corresponding to TableReference. Args: apiclient: The apiclient used to make the request. reference: the TableReference to create. ignore_existing: (boolean, default False) If False, raise an exception if the dataset already exists. schema: an optional schema for tables. description: an optional description for tables or views. display_name: an optional friendly name for the table. expiration: optional expiration time in milliseconds since the epoch for tables or views. view_query: an optional Sql query for views. materialized_view_query: an optional standard SQL query for materialized views. enable_refresh: for materialized views, an optional toggle to enable / disable automatic refresh when the base table is updated. refresh_interval_ms: for materialized views, an optional maximum frequency for automatic refreshes. max_staleness: INTERVAL value that determines the maximum staleness allowed when querying a materialized view or an external table. By default no staleness is allowed. external_data_config: defines a set of external resources used to create an external table. For example, a BigQuery table backed by CSV files in GCS. biglake_config: specifies the configuration of a BigLake managed table. external_catalog_table_options: Specifies the configuration of an external catalog table. view_udf_resources: optional UDF resources used in a view. use_legacy_sql: The choice of using Legacy SQL for the query is optional. If not specified, the server will automatically determine the dialect based on query information, such as dialect prefixes. If no prefixes are found, it will default to Legacy SQL. labels: an optional dict of labels to set on the table. time_partitioning: if set, enables time based partitioning on the table and configures the partitioning. clustering: if set, enables and configures clustering on the table. range_partitioning: if set, enables range partitioning on the table and configures the partitioning. require_partition_filter: if set, partition filter is required for queiries over this table. destination_kms_key: User specified KMS key for encryption. location: an optional location for which to create tables or views. table_constraints: an optional primary key and foreign key configuration for the table. resource_tags: an optional dict of tags to attach to the table. Raises: BigqueryTypeError: if reference is not a TableReference. BigqueryDuplicateError: if reference exists and ignore_existing is False. create_tablerENfieldsr friendlyNamernexpirationTimequeryuserDefinedFunctionResourcesview useLegacySql enableRefreshrefreshIntervalMsmaterializedView maxStalenessexternalDataConfigurationbiglakeConfigurationr rwtimePartitioningrxrangePartitioningrequirePartitionFilter kmsKeyNameencryptionConfigurationrgr{ resourceTags) r rJrKrZr ConstructObjectInfobq_frontend_utilsGetJson_execute_insert_table_requestr BigqueryDuplicateError)rr@rmrrnrorprqrrrsrtruexternal_data_configbiglake_configexternal_catalog_table_optionsview_udf_resourcesrvrwtime_partitioningrxrange_partitioningryrzrgr{r|r* view_argsmaterialized_view_argss rr~r~s^!!00  7  1 1) 'd=)d J'i  '4F 01d6l  #$2 .!* ')@A  #2@/  (6I23!7d '  ",^*>d &'!%3d !"%1,=,E,E (-d ()d8n$!2d %d<%"4d +'?d #$&)57J(Kd $%!d:$"3d  *d>!)=  ( (    sC:D++E  E  labels_to_setlabel_keys_to_removeetagautodetect_schematags_to_attachtags_to_removeclear_all_tagsc[R"U[RRSS9 0nU(a [ XS9n[ R "U5nSnUbSU0US'O U(dSUS'UbUUS'UbUUS 'UbUUS 'UbUS :XaSUS 'OUUS 'UbS U0n U bU U S'UbUU S'U US'0n!UbUU!S 'UbUU!S'U bU U!S'U!(aU!US'U b U US'U bU US'SU;a0US'[[[[[4US5n"U"c [S5eU(aUR5H un#n$U$U"U#'M U(aUHn#SU"U#'M UbUUS'UbUUS'UbU0:XaSUS'OUUS'UbUUS'UbUUS'UbUUS'0n%U(aSU;aUSHn&SU%U&'M OU=(d /Hn&SU%U&'M U=(d 0H n&UU&U%U&'M U%US'U bD[ XS9nUR[05 [R "U[U 5U['[#UUUUUS9 g) a Updates a table. Args: apiclient: The apiclient used to make the request. reference: the TableReference to update. schema: an optional schema for tables. description: an optional description for tables or views. display_name: an optional friendly name for the table. expiration: optional expiration time in milliseconds since the epoch for tables or views. Specifying 0 removes expiration time. view_query: an optional Sql query to update a view. materialized_view_query: an optional Standard SQL query for materialized views. enable_refresh: for materialized views, an optional toggle to enable / disable automatic refresh when the base table is updated. refresh_interval_ms: for materialized views, an optional maximum frequency for automatic refreshes. max_staleness: INTERVAL value that determines the maximum staleness allowed when querying a materialized view or an external table. By default no staleness is allowed. external_data_config: defines a set of external resources used to create an external table. For example, a BigQuery table backed by CSV files in GCS. external_catalog_table_options: Specifies the configuration of an external catalog table. view_udf_resources: optional UDF resources used in a view. use_legacy_sql: The choice of using Legacy SQL for the query is optional. If not specified, the server will automatically determine the dialect based on query information, such as dialect prefixes. If no prefixes are found, it will default to Legacy SQL. labels_to_set: an optional dict of labels to set on this table. label_keys_to_remove: an optional list of label keys to remove from this table. time_partitioning: if set, enables time based partitioning on the table and configures the partitioning. range_partitioning: if set, enables range partitioning on the table and configures the partitioning. clustering: if set, enables clustering on the table and configures the clustering spec. require_partition_filter: if set, partition filter is required for queiries over this table. etag: if set, checks that etag in the existing table matches. encryption_configuration: Updates the encryption configuration. location: an optional location for which to update tables or views. autodetect_schema: an optional flag to perform autodetect of file schema. table_constraints: an optional primary key and foreign key configuration for the table. tags_to_attach: an optional dict of tags to attach to the table tags_to_remove: an optional list of tag keys to remove from the table clear_all_tags: if set, clears all the tags attached to the table Raises: BigqueryTypeError: if reference is not a TableReference. update_tablerErjFNrrrrrnrrrrrrrrrrrrwzMissing labels in table.rrrxrrgr{r)rr@tablerr)r rJrKrZ_execute_get_table_requestr rrrstrrr;items setdefault*_EXTERNAL_CATALOG_TABLE_OPTIONS_FIELD_NAMEr!UpdateExternalCatalogTableOptions_execute_patch_table_request)'rr@rrnrorprqrrrsrtrurrrrvrrrrrxryrencryption_configurationrgrr{rrrexisting_tablermaybe_skip_schemarr table_labels label_key label_valuer|tags' rrrzs:h!!00  .0N  0 0 ;% (E(O E(O)'?E #$(E.&E-Q $e  *e *%I%2Di./!"0iE&M(&=7#.<?+$2E./ 6E %)=E %& +eN UE(Od3 -.h@, / 00"/"5"5"7 ; +l9#8) $l9*" 1E #!3E R eL&eL)&>E "#  E*"!2E -.8n-mC.##mC$  !r !c',M#" (%#//NH"M;; E F *  45  )  rcpUR5R"S0[U5D6R5$)Nr)rrr#rrjs rrr?s.       2$y/ 2 : : <rsQ,--%3/$-J*&!!&++::&)-,0%) (%%(++::((-99: ;( ~ ( $D> ( c] (\ $"%)*. %!!%**99%}%sm % c] % #3- %V"& $ !!**;;# 4((**99B!((!**99!H !! **99 c]  !! **99 &" !%"& $ $-1%))-#'#'%)'+15/3)-"'+.25L !!L **99L L  SM L # L 3- L  L  L &c]L TNL "#L C=L "TN#L $ T#s(^ $%L (c49n-.)L ,'tn-L ."#/L 0sm1L 2 }3L 4DcN+5L d !%"& $ $-1%))-#'#'%).20415/3!"#/3*. ;B!!B**99B# B 3- B  B B&c]BTNB"#BC=BTNB DcN+!B"#49-#B(c49n-.)B*'tn+B, 3--B0sm1B23B6T#s(^,7B8T#Y'9B:;BJ=!!=**99=$ !!**99  3- :!!**99# !! **99  r