jSrSSKJr SSKJr SSKJr SSKrSSKJr SSKJ r SSKJ r SSK r SSK r SS K Jr SS K Jr SS K Jr SS K Jr SS K Jr SSK Jr SSK Jr SSKJr SSKJr SSKJ r SSKJr SSKJr SSKJr SSKJr SSKJr SSKJ r SSKJ!r! SSKJ"r" "SS\RF5r$g)zThe BigQuery CLI make command.)absolute_import)division)print_functionN)Optional)app)flags)client_connection)client_data_transfer)client_dataset)client_reservation)client_row_access_policy) client_table)utils)bigquery_command)bq_cached_client)utils_data_transfer) utils_flags)utils_formatting)utils_id)bq_error) bq_id_utils)bq_processor_utilsc^\rSrSrSrSrS\S\R4U4Sjjr S\S\4S jr SS \S \S \ \ 4S jjr SrU=r$)Make(zCreates a dataset or a table.z9mk [-d] OR mk [-t] []namefvc >[[U] X5 [R"SSSSUS9 [R"SSSSUS9 [R"S SS S US9 [R"S SS US9 [R "SSSUS9 [R "SSSUS9 [R "SSSUS9 [R "SSSUS9 [R "SSSSUS9 [R "SSSUS9 [R "SSSUS9 [R"S SS!US9 [R "S"SS#US9 [R "S$SS%US9 [R "S&SS'US9 [R "S(SS)US9 [R "S*SS+US9 [R "S,SS-US9 [R"S.SS/US9 [R"US9Ul [R "S0SS1US9 [R "S2SS3US9 [R "S4SS5US9 [R "S6SS7US9 [R "S8SS9US9 [R "S:SS;US9 [R "SSS?US9 [R "S@SSAUS9 [R"SBSSC/SDUS9 [R"SESSF/SGUS9 [R "SHSSIUS9 [R"SJSSKUS9 [R "SLSSMUS9 [R"SNSSOUS9 [R "SPSSQUS9 [R "SRSSSUS9 [R"STSSUUS9 [R "SVSSWUS9 [R "SXSSYUS9 [R "SZSS[US9 [R "S\SS]US9 [R"S^SS_US9 [R"S`SSaUS9 [R "SbSScUS9 [R "SdSSeUS9 [R"SfSSgUS9 [R "ShSSiUS9 [R "SjSSkUS9 [R "SlSSmUS9 [R "SnSSoUS9 [R"SpSSqUS9 [R"SrSSsUS9 [R"StS/SuQSvUS9 [R"SwS/SxQSyUS9 [R "SzSS{US9 [R"S|SS}US9 [R"S~SSUS9 [R"SSSUS9 [R "SSSUS9 [R "SSSUS9 [R "SSSUS9 [R "SSSUS9 [R"SS/SQSUS9 [R"SS/SQSUS9 [R "SSSUS9 [R"SSSUS9 [R"SS/SQSUS9 [R "SSSUS9 [R"SS/SQSUS9 [R "SSSUS9 [R"SS/SQSUS9 [R"SSSUS9 [R "SSSUS9 [R"SSSUS9 [R"SS[RSSR[R5-US9 [R "SSSUS9 [R "SSSUS9 [R "SSSUS9 [R "SSSUS9 [R"SSSUS9 [R"SSSUS9 [R "SSSUS9 [R "SSSUS9 [R "SSSUS9 [R"SSSUS9 [R "SSSUS9 [R "SSSUS9 [R "SSSUS9 [R "SSSUS9 [R"SSSUS9 [R"SS[ R"US9 [R "SSSUS9 [R"SSSS/SUS9 [R"SSSS/SUS9 [R"SSSS/SUS9 [R"SSSUS9 [R "SSSUS9 [R"SSSS/SUS9 [R "SSSUS9 [R "SSSUS9 [R "SSSUS9 [R$"US9Ul[R("US9Ul[R,"US9Ul[R0"US9Ul[R4"US9Ul[R8"US9Ul[R<"US9Ul[R@"US9Ul![RD"US9Ul#[RH"US9Ul%[R"SSSUS9 [R "SSSUS9 URMU5 g)NforceFzIBypass existence checks and ignore errors that the object already exists.f) short_name flag_valuesdatasetzCreate dataset with this name.dtablezCreate table with this name.ttransfer_configzCreate transfer config.)r"target_datasetz6Target dataset for the created transfer configuration. display_namezBDisplay name for the created transfer configuration or connection. data_sourcez3Data source for the created transfer configuration.refresh_window_daysrz;Refresh window days for the created transfer configuration.paramszqParameters for the created transfer configuration in JSON format. For example: --params='{"param":"param_value"}'pservice_account_namez>Service account used as the credential on the transfer config.notification_pubsub_topiczKPub/Sub topic used for notification after transfer run completed or failed. transfer_runz'Creates transfer runs for a time range. start_timezStart time of the range of transfer runs. The format for the time stamp is RFC3339 UTC "Zulu". Example: 2019-01-20T06:50:0Z. Read more: https://developers.google.com/protocol-buffers/docs/reference/google.protobuf#google.protobuf.Timestamp end_timezExclusive end time of the range of transfer runs. The format for the time stamp is RFC3339 UTC "Zulu". Example: 2019-01-20T06:50:0Z. Read more: https://developers.google.com/protocol-buffers/docs/reference/google.protobuf#google.protobuf.Timestamp run_timezSpecific time for a transfer run. The format for the time stamp is RFC3339 UTC "Zulu". Example: 2019-01-20T06:50:0Z. Read more: https://developers.google.com/protocol-buffers/docs/reference/google.protobuf#google.protobuf.Timestamp schedule_start_timeaJTime to start scheduling transfer runs for the given transfer configuration. If empty, the default value for the start time will be used to start runs immediately.The format for the time stamp is RFC3339 UTC "Zulu". Read more: https://developers.google.com/protocol-buffers/docs/reference/google.protobuf#google.protobuf.Timestampschedule_end_timeaKTime to stop scheduling transfer runs for the given transfer configuration. If empty, the default value for the end time will be used to schedule runs indefinitely.The format for the time stamp is RFC3339 UTC "Zulu". Read more: https://developers.google.com/protocol-buffers/docs/reference/google.protobuf#google.protobuf.TimestampscheduleaData transfer schedule. If the data source does not support a custom schedule, this should be empty. If empty, the default value for the data source will be used. The specified times are in UTC. Examples of valid format: 1st,3rd monday of month 15:30, every wed,fri of jan,jun 13:15, and first sunday of quarter 00:00. See more explanation about the format here: https://cloud.google.com/appengine/docs/flexible/python/scheduling-jobs-with-cron-yaml#the_schedule_formatno_auto_schedulingzKDisables automatic scheduling of data transfer runs for this configuration.schemazNEither a filename or a comma-separated list of fields in the form name[:type]. descriptionz0Description of the dataset, table or connection. data_locationzaGeographic location of the data. See details at https://cloud.google.com/bigquery/docs/locations. expirationz1Expiration time, in seconds from now, of a table.default_table_expirationzDefault lifetime, in seconds, for newly-created tables in a dataset. Newly-created tables will have an expiration time of the current time plus this value.default_partition_expirationa(Default partition expiration for all partitioned tables in the dataset, in seconds. The storage in a partition will have an expiration time of its partition time plus this value. If this property is set, partitioned tables created in the dataset will use this instead of default_table_expiration.external_table_definitionafSpecifies a table definition to use to create an external table. The value can be either an inline table definition or a path to a file containing a JSON table definition. The format of inline definition is "schema@format=uri@connection", where "schema@", "format=", and "connection" are optional and "format"has the default value of "CSV" if not specified. connection_idzThe connection specifying the credentials to be used to read external storage. The connection_id can have the form ".." or "projects//locations//connections/". storage_urizThe fully qualified location prefix of the external folder where the table data of a BigLake table is stored. The "*" wildcard character is not allowed. The URI should be in the format "gs://bucket/path_to_table/". file_formatPARQUETz@The file format the table data of a BigLake table is stored in. table_formatICEBERGzOThe table format the metadata only snapshots of a BigLake table are stored in. viewz Create view with this SQL query.view_udf_resourcezThe URI or local filesystem path of a code file to load and evaluate immediately as a User-Defined Function resource used by the view.materialized_viewzE[Experimental] Create materialized view with this Standard SQL query.enable_refreshz~Whether to enable automatic refresh of the materialized views when the base table is updated. If not set, the default is true.refresh_interval_mszMilliseconds that must have elapsed since last refresh until the materialized view can be automatically refreshed again. If not set, the default value is "1800000" (30 minutes). max_stalenessasINTERVAL value that determines the maximum staleness allowed when querying a materialized view or an external table. By default no staleness is allowed. Examples of valid max_staleness values: 1 day: "0-0 1 0:0:0"; 1 hour: "0-0 0 1:0:0".See more explanation about the INTERVAL values: https://cloud.google.com/bigquery/docs/reference/standard-sql/data-types#interval_typeuse_legacy_sqlzThe 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.time_partitioning_typezEnables time based partitioning on the table and set the type. The default value is DAY, which will generate one partition per day. Other supported values are HOUR, MONTH, and YEAR.time_partitioning_expirationzEnables time based partitioning on the table and sets the number of seconds for which to keep the storage for the partitions in the table. The storage in a partition will have an expiration time of its partition time plus this value.time_partitioning_fieldzEnables time based partitioning on the table and the table will be partitioned based on the value of this field. If time based partitioning is enabled without this value, the table will be partitioned based on the loading time.destination_kms_keyz;Cloud KMS key for encryption of the destination table data.labelzAA label to set on the table or dataset. The format is "key:value"require_partition_filterzaWhether to require partition filter for queries over this table. Only apply to partitioned table.clustering_fieldsz]Comma-separated list of field names that specifies the columns on which a table is clustered.range_partitioninga Enables range partitioning on the table. The format should be "field,start,end,interval". The table will be partitioned based on the value of the field. Field must be a top-level, non-repeated INT64 field. Start, end, and interval are INT64 values defining the ranges.row_access_policyzCreates a row access policy. policy_idz/Policy ID used to create row access policy for. target_tablez.The table to create the row access policy for.granteeszComma separated list of iam_member users or groups that specifies the initial members that the row-level access policy should be created with.filter_predicatezTA SQL boolean expression that represents the rows defined by this row access policy. reservationz4Creates a reservation described by this identifier. capacity_commitmentzxCreates a capacity commitment. You do not need to specify a capacity commitment id, this will be assigned automatically.plan)FLEXMONTHLYANNUAL THREE_YEARzCommitment plan for this capacity commitment. Plans cannot be deleted before their commitment period is over. Options include: FLEX MONTHLY ANNUAL THREE_YEAR renewal_plan)r]r^r_r`NONEzThe plan this capacity commitment is converted to after committed period ends. Options include: NONE FLEX MONTHLY ANNUAL THREE_YEAR NONE can only be used in conjunction with --edition, while FLEX and MONTHLY cannot be used together with --edition.slotsz=The number of baseline slots associated with the reservation.multi_region_auxiliaryzIf true, capacity commitment or reservation is placed in the organizations auxiliary region which is designated for disaster recovery purposes. Applicable only for US and EU locations. Available only for allow-listed projects.use_idle_slotsTzIf true, any query running in this reservation will be able to use idle slots from other reservations. Used if ignore_idle_slots is None.ignore_idle_slotszgIf false, any query running in this reservation will be able to use idle slots from other reservations.max_concurrencyz6Deprecated, please use target_job_concurrency instead. concurrencytarget_job_concurrencyzSets a soft upper bound on the number of jobs that can run concurrently in the reservation. Default value is 0 which means that concurrency target will be automatically computed by the system.autoscale_max_slotszVNumber of slots to be scaled when needed. Autoscale will be enabled when setting this.job_type) QUERYPIPELINE ML_EXTERNAL BACKGROUNDSPARK CONTINUOUSBACKGROUND_CHANGE_DATA_CAPTURE BACKGROUND_COLUMN_METADATA_INDEXBACKGROUND_SEARCH_INDEX_REFRESHaQType of jobs to create reservation assignment for. Options include: QUERY PIPELINE Note if PIPELINE reservations are created, then load jobs will just use the slots from this reservation and slots from shared pool won't be used. ML_EXTERNAL BigQuery ML jobs that use services external to BQ for model training will use slots from this reservation. Slots used by these jobs are not preemptible, i.e., they are not available for other jobs running in the reservation. These jobs will not utilize idle slots from other reservations. BACKGROUND BACKGROUND_CHANGE_DATA_CAPTURE BigQuery CDC background merge will use BACKGROUND_CHANGE_DATA_CAPTURE reservations to execute if created, but will fall back to using BACKGROUND reservations if one does not exist. BACKGROUND_COLUMN_METADATA_INDEX BACKGROUND_SEARCH_INDEX_REFRESH SPARK BigQuery Spark jobs that use services external to BQ for executing SPARK procedure job. Slots used by these jobs are not preemptible, i.e., they are not available for other jobs running in the reservation. These jobs will not utilize idle slots from other reservations.priority)HIGH INTERACTIVEBATCHzReservation assignment default job priority. Only available for whitelisted reservations. Options include: HIGH INTERACTIVE BATCHreservation_idzlReservation ID used to create reservation assignment for. Used in conjunction with --reservation_assignment.reservation_assignmentz Create a reservation assignment. assignee_type)PROJECTFOLDER ORGANIZATIONzType of assignees for the reservation assignment. Options include: PROJECT FOLDER ORGANIZATION Used in conjunction with --reservation_assignment. assignee_idzxProject/folder/organization ID, to which the reservation is assigned. Used in conjunction with --reservation_assignment.edition)STANDARD ENTERPRISEENTERPRISE_PLUSzType of editions for the reservation or capacity commitment. Options include: STANDARD ENTERPRISE ENTERPRISE_PLUS Used in conjunction with --reservation or --capacity_commitment. STANDARD cannot be used together with --capacity_commitment. max_slotszThe overall max slots for the reservation. It needs to be specified together with --scaling_mode. It cannot be used together with --autoscale_max_slots. It is a private preview feature. scaling_mode)AUTOSCALE_ONLYIDLE_SLOTS_ONLY ALL_SLOTSaThe scaling mode for the reservation. Available only for reservations enrolled in the Max Slots Preview. It needs to be specified together with --max_slots. It cannot be used together with --autoscale_max_slots. Options include: AUTOSCALE_ONLY IDLE_SLOTS_ONLY ALL_SLOTSreservation_groupz:Creates a reservation group described by this identifier. reservation_group_namezReservation group name used to create reservation for, it can be full path or just the reservation group name. Used in conjunction with --reservation. connectionzCreate a connection.connection_typez Connection type. Valid values: z propertiesz%Connection properties in JSON format.connection_credentialz%Connection credential in JSON format.connector_configurationz6Connection configuration for connector in JSON format. iam_role_idzxperimental] IAM role id. federated_awsz"[Experimental] Federated identity.federated_azurez,[Experimental] Federated identity for Azure. tenant_idz[Experimental] Tenant id.federated_app_client_idzt[Experimental] The application (client) id of the Active Directory application to use with Azure federated identity.default_kms_keyzDefines default KMS key name for all newly objects created in the dataset. Table/Model creation request can override this default.use_avro_logical_typeszIf sourceFormat is set to "AVRO", indicates whether to enable interpreting logical types into their corresponding types (ie. TIMESTAMP), instead of only using their raw types (ie. INTEGER).source_datasetzYWhen set to a dataset reference, creates a Linked Dataset pointing to the source dataset.external_sourcezExternal source that backs this dataset. Currently only AWS Glue databases are supported (format aws-glue://) external_catalog_dataset_optionsaOptions defining open source compatible datasets living in the BigQuery catalog. Contains metadata of open source database or default storage location represented by the current dataset. The value can be either an inline JSON or a path to a file containing a JSON definition.external_catalog_table_optionsa"Options defining the metadata of an open source compatible table living in the BigQuery catalog. Contains metadata of open source table including serializer/deserializer information, table schema, etc. The value can be either an inline JSON or a path to a file containing a JSON definition.parquet_enum_as_stringzHInfer Parquet ENUM logical type as STRING (instead of BYTES by default).parquet_enable_list_inferencemax_time_travel_hourszOptional. Define the max time travel in hours. The value can be from 48 to 168 hours (2 to 7 days). The default value is 168 hours if this is not set.storage_billing_modelLOGICALPHYSICALzOptional. Sets the storage billing model for the dataset. LOGICAL - switches to logical billing model PHYSICAL - switches to physical billing model.metadata_cache_mode AUTOMATICMANUALzEnables metadata cache for an external table with a connection. Specify AUTOMATIC to automatically refresh the cached metadata. Specify MANUAL to stop the automatic refresh.object_metadata DIRECTORYSIMPLEzObject Metadata Type used to create Object Tables. SIMPLE is the only supported value to create an Object Table containing a directory listing of objects found at the uri in external_data_definition.!preserve_ascii_control_characterszLWhether to preserve embedded Ascii Control characters in CSV External table reference_file_schema_urizfprovide a reference file with the table schema, currently enabled for the formats: AVRO, PARQUET, ORC.file_set_spec_typeFILE_SYSTEM_MATCHNEW_LINE_DELIMITED_MANIFESTaUSpecifies how to discover files given source URIs. Options include: FILE_SYSTEM_MATCH: expand source URIs by listing files from the underlying object store. This is the default behavior. NEW_LINE_DELIMITED_MANIFEST: indicate the source URIs provided are new line delimited manifest files, where each line contains a URI with no wild-card. kms_key_namez'Cloud KMS key name used for encryption.add_tagszTags to attach to the dataset or table. The format is namespaced key:value pair like "1234567/my_tag_key:my_tag_value,test-project123/environment:production" sourcez,Path to file with JSON payload for an updatemigration_workflowzCreate a migration workflow. config_filezAThe file containing the JSON of the migration workflow to create.)'superr__init__rDEFINE_boolean DEFINE_stringDEFINE_integer DEFINE_boolfrontend_flagsdefine_event_driven_scheduleevent_driven_schedule_flag DEFINE_enumDEFINE_multi_stringrCONNECTION_TYPESjoinfrontend_utils"PARQUET_LIST_INFERENCE_DESCRIPTIONdefine_null_markernull_marker_flagdefine_null_markersnull_markers_flagdefine_time_zonetime_zone_flagdefine_date_formatdate_format_flagdefine_datetime_formatdatetime_format_flagdefine_time_formattime_format_flagdefine_timestamp_formattimestamp_format_flag!define_timestamp_target_precisiontimestamp_target_precision_flagdefine_source_column_matchsource_column_match_flagdefine_parquet_map_target_typeparquet_map_target_type_flag_ProcessCommandRc)selfrr __class__s $platform/bq/frontend/command_make.pyr Make.__init__-s  $t(      (   &  4!:  @    L    =    E     <   H   #     1     ?     ?     ?     >    >    `       33C #      :     <   ;   "  ,  &  $   #  <     {     .     J       6B      O     F    7    ~     B      <  &  * !  1  E    K   "  +    &    P  &    9    8            >     >     2     L'*  G      *         .   @    @      K         I8W,Z        =    *    - @     =   5 J    G     "  D        d2  +++ **'88 9 :   /    /   ! @   t:   ,    6   T6B !  <    K     P        6  *     (  )      )  ' 99        J 9  h 8  h K +    #  7   ;<    1     i    6 +=="MD+??BOD(99bID*=="MD . E E!D+=="MD!/!G!G"D 88RH (%3$M$M%D! 55"E %  &    K   2 object_name referencec*[U<SU<S35 g)N 'z' successfully created.)print)rrrs rprintSuccessMessageMake.printSuccessMessages    r identifierr9returnc 4[RR5nSnUR(a'UR(a[ R "S5e[R"URURUR5(a[ R "S5eUR(a[R"X1S9nG OUR(a[R"X1S9nG OUR(a[R"X1S9nG OUR(a[R"UUR UR"S9n[$R&"UUUR(R+S5UR,S9 UR5S UR"5 G OUR6(GaeSn[R8"UU[:R<R>S 9nUR@b.[BRD"[:RFRH5 URJnUcURL(+nURNnUc%URPb URPO URRn[TRV"URY5[:RZR>UUR\UUR^UUR`URbURdURfUR@S 9 nUb[Rh"XdSS9 G OURj(a[Rl"UU[:R<R>SS9n[TRn"URY5UUR^UR\URpURrUR`S9nUb[Rh"XdSS9 G OURt(a[R8"U[:R<R>URvS9n[TRx"URY5UURzUR|UR~URS9n[R"X6SS9n[Rh"XdSS9 G OUR(a[BRD"[:RFRH5 [R"UU[:R<R>S 9n[TR"URY5US9n[Rh"XdSS9 GO\UR(GaUR5n S[R"US9R-nSn UR(a"[R"X@RU 5n O[0R2"S5e0n U (dBURS :wa2UR(d![R"X@RU 5n UR=(d [:R<R>n URR(aURR>OSUlQ[R"URURURURURS!9n [R"UR5UURURURURURU URURURU U S"9 nUR5S#U5 GOBUR(Ga[BR"5n[R"X15n[RRUS$9nUR=(d UR=(a URnUR(+=(d UR(+=(a UR(+nU(dU(a[ R "S%5e[[[R[R"UR5UURURURS&955n[R"U[RRS'US(S)9 UHnURU5 M UR5 GOUR(GaURnU=(d URnU(dS*n[ R "U5eURS+:Xa]UR(aL[R"UR5UlxUR(d[ R "S,5eURS-:XaUR(aUR(aXUR(d[ R "S.5e[R"URUR5UlxO%[R"UR5UlxURnU(dURS/:XaS0nU(dURS1:XaS0nUnU=(d URnU(dS2n[ R "U5e[GR"UGR5[:GRR>[:R<R>URUUGRURUGRUUGR URS39 nU(aW[GR "UUSS9nG[S4U-5 [GR"U[:GRR>S59 GOUGR(a[:R<R>(d[ R "S65eUGR(d[ R "S75eSnUGRS8S9U[:R<R>UGR[:GRR>[:GRR>S:.S;9 OUR(dU(dQ[GR"X1S9nUGR(a)U(a"[GR "UGR5 Of[GR""X1S9n[GR$"U[RGR&[RGR(4SS?9 G[+U[RGR&5(GaUR(a[ R "S@5eUGR,(a(UGR(a[ R "SA5eUGR.(a[ R "SB5eUGR0b[ R "SC5eUGR2(dcG[4GR6"UGR8USD9(a<SEU<SF3nUGR:(d[0R2"U5eG[U5 gSnUGR<bUGR<SG-nSnUGR>bUGR>SG-nUR=(d [:R<R>n SnUGR@b"[GRB"UGR@5nUGRD(a![GR"X0GRDS9nOSnUGRF(a(UGRD(a[ R "SH5eUGRHb[ R "SI5eUGRF(aJUGRJ(d8UGRFGRMSJ5(d[ R "SK5eSnUGRNb#G[PGRR"UGRN5n[GRT"UGRUGR,5uUln UGRUGR2SL.n!U (aU SM:wdU SN:waU U!SO'UGRWSPS9UU!SQ9 G[4GRX"S0SRUGR8_SSU_STUGR2_SUUGR_SVU _SWU_SXU_SYU _SZUGRZ_S[U_S\U_S]UGRF_S^UGRJ_S_UGR\_S`UGR^_SaUGR`_SbU_6 UR5ScU5 gG[+U[RGR(5(GaUGRD(a[ R "Sd5eSen"UR(aSfn"UR(aSgn"UGR2(dfG[bGRd"UGR8USD9(a?U"<ShU<Si3nUGR:(d[0R2"U5eG[U5 gU(a[GRf"U5nOSnSn#SnUGR@b"[GRB"UGR@5nUR(a[ R "Sj5eUGR<(a[ R "Sk5eUGR\b[ R "Sl5eUGR.(a2G[iUGR.G[jGRj"5-5SG-n#UR=(d Sn$UR=(d Sn%Sn&UGR0Gb[GRl"UGR0UGRnUGRpUGRrUGRtUGRvUGRxUGRzUGR|UGR~R>UGRR>UGRR>UGRR>UGRR>UGRR>UGRR>UGRR>UGRR>UGRR>Sm9n&UGRbSnU&;a[ R "So5eSpU&;a[GR"U&Sp5U&Sp'Sn'UGRJ=(a! UGR=(a UGRn(UGRJ=(d5 UGR=(d! UGR=(d UGRn)U((a4UGRJUGRUGRUGRSq.n'OU)(a/n*UGRJ(dU*GRS^5 UGR(dU*GRSr5 UGR(dU*GRSs5 StGRU*5n*[ R "SuU*Sv35eSn+UGR(a"[GR"UGR5n+[GR"UGRUGRUGRSUGR5n,[GR"UGR5n-[GR"UGR5n.Sn/SnUGRNb#G[PGRR"UGRN5nG[bGR"S0SRUGR8_SSU_STS>_SwU_SUUGR_SxU#_SyU$_SzU%_S{UGR_S|UGR_S}UGR_S~U+_SUGR_SU&_SU'_SUGRH_S[U_SU,_SU-_SU._SUGR_SUR_SU/_SbU_6 UR5U"U5 gg![.a;n[0R2"SUR"<S UR <S U<35eSnAff=f![.a#n[0R2"SU<S U<35eSnAff=f![.a#n[0R2"SU<S U<35eSnAff=f![.a#n[0R2"SU<S U<35eSnAff=f![.a#n[0R2"SU<S U<35eSnAff=f)aCreate a dataset, table, view, or transfer configuration with this name. See 'bq help mk' for more information. Examples: bq mk new_dataset bq mk new_dataset.new_table bq --dataset_id=new_dataset mk table bq mk -t new_dataset.newtable name:integer,value:string bq mk --view='select 1 as num' new_dataset.newview (--view_udf_resource=path/to/file.js) bq mk --materialized_view='select sum(x) as sum_x from dataset.table' new_dataset.newview bq mk -d --data_location=EU new_dataset bq mk -d --source_dataset=src_dataset new_dataset (requires allowlisting) bq mk -d --external_source=aws-glue:// --connection_id= new_dataset bq mk --transfer_config --target_dataset=dataset --display_name=name -p='{"param":"value"}' --data_source=source --schedule_start_time={schedule_start_time} --schedule_end_time={schedule_end_time} bq mk --transfer_run --start_time={start_time} --end_time={end_time} projects/p/locations/l/transferConfigs/c bq mk --transfer_run --run_time={run_time} projects/p/locations/l/transferConfigs/c bq mk --reservation --project_id=project --location=us reservation_name bq mk --reservation_assignment --reservation_id=project:us.dev --job_type=QUERY --assignee_type=PROJECT --assignee_id=myproject bq mk --reservation_assignment --reservation_id=project:us.dev --job_type=QUERY --assignee_type=FOLDER --assignee_id=123 bq mk --reservation_assignment --reservation_id=project:us.dev --job_type=QUERY --assignee_type=ORGANIZATION --assignee_id=456 bq mk --reservation_group --project_id=project --location=us reservation_group_name bq mk --connection --connection_type='CLOUD_SQL' --properties='{"instanceId" : "instance", "database" : "db", "type" : "MYSQL" }' --connection_credential='{"username":"u", "password":"p"}' --project_id=proj --location=us --display_name=name new_connection bq mk --row_access_policy --policy_id=new_policy --target_table='existing_dataset.existing_table' --grantees='user:user1@google.com,group:group1@google.com' --filter_predicate='Region="US"' bq mk --source=file.json bq mk --migration_workflow --location=us --config_file=file.json NzCannot specify both -d and -t.zJCannot specify more than one of --schema or --view or --materialized_view.) id_fallbacksr)rtable_identifierrV,)bqclientpolicy_referencerXrYz$Failed to create row access policy 'z' on 'z': zRow access policy)rrdefault_location) client api_versionrrcrfrrirdrjrrrzFailed to create reservation 'show) custom_format )rrrdefault_capacity_commitment_id)rrrrcr\rardz)Failed to create capacity commitment in ')rrr)rrrkrur{rr)rpathz)Failed to create reservation assignment ')reservation_group_clientrz$Failed to create reservation group 'z projects/)rFzA data source must be provided. loadtesting)r7r2r3disable_auto_schedulingevent_driven_schedule) transfer_clientrr+r(r*r,r- auth_infor/rPr0 schedule_argslocationzTransfer configuration)transferConfigNamezKNeed to specify either both --start_time and --end_time or only --run_time.)rrr2r3r4maker) print_format object_infoz?Need to specify --connection_type or --connector_configuration.AWSz-Non-federated AWS connections are deprecated.AzurezGMust specify --federated_app_client_id for federated Azure connections.CLOUD_RESOURCEz{}rpz9Need to specify --properties or --connector_configuration) r project_idrrrrr*r:r@rrz"Connection %s successfully created) flag_formatz:Need to specify location for creating migration workflows.z=Need to specify config file for creating migration workflows.migration_workflowsmk)rrsyncsynchronous_mode)command_flags_for_this_resourcezInvalid identifier 'z ' for mk.T)is_usage_errorz%Cannot specify schema with a dataset.z)Cannot specify description with a source.z+Cannot specify an expiration for a dataset.z:Cannot specify an external_table_definition for a dataset.) apiclientrz Dataset 'z' already exists.iz7Cannot specify both external_source and linked dataset.z' could not be created; a table with this name already exists.z)Cannot specify data location for a table.z.Cannot specify default expiration for a table.zrQ ParseLabelsrrrr@ startswithrbq_utils ParseTags ProcessSourcePossiblyDelegateToGcloudAndExit CreateDatasetrrrrr table_exists ReadSchemainttimeGetExternalDataConfigrrrrrrrrrrrrrrrrrrrRParseFileSetSpecTyperArDrBappendrrGParseUdfResourcesParseTimePartitioningrMrNrOParseClusteringrSParseRangePartitioningrT create_tablerIrJrKrL)0rrr9rrerignore_idle_argrhr credentialsrrr transfer_name formatterformatted_identifierincompatible_optionsincomplete_optionsresultsresultconnection_type_definederrorparam_propertiesproperties_definedcreated_connectionmessagedefault_table_exp_msdefault_partition_exp_msrrrrrrr<view_query_argmaterialized_view_query_argrr has_all_required_biglake_config has_some_required_biglake_configmissing_fieldsrr!r"rTr#s0 r RunWithArgsMake.RunWithArgssj $ $ ( ( *FI vv$&& NN; <<// TYY 6 6 NN 8  vv!33i !33i   !33i   !==,,NNi   99&]]((-!22   2DNNC   k!99#,,22i   & & 2  5 5$$77 00  " $ 3 33/11  !!-''  )::113 ,,22**-LL#.#'#>#> $ 8 8nn**#'#>#>  $  && &   ! !!@@#,,22), i  (AA113LL****#'#>#>   && &   $ $ #;;%..44** )DD113]]]],,((  $EE&&9  && &     33  " " 5 5 $@@!%..44 )??%+%C%C%E  && &     557o  - -6 B L Lik  )99 '' $$%FGGi-/++'AA '' ##>x'8'8'>'>h , , 4 4  ) ) / /  +??==--))"&"9"9 $ : : m+AA 779&&,,(("66#88"66$($B$B%m 7G   668i.LL --EE1Fi // *T]] MMoo  2T]]!2  !3nn "   77"=="("?"?"A%!__====   g**   % % : :aj  &&!oo  $ 4 4 ! AT%A%A% M nnU##   &4+;+;,II    !!NO O   (T^^   --.. /ccnnd:: $//IInn $/$"6"6:J"J$"6"6'"A+-M1M1M KnnU##,==002((..$$**..% $ : :((&&"(("&">">  #::&8&@  2Y>?GG HOO,A,A      $ $nn H     nn K  i ""   "++11!--//55"*";";"A"A + #  z!55i    **9+>+>?!..i ))::))88 0: ;)[88IIJJ nnDEE )))nnHII nnJKK ' ' 3nn H  jjjn::$$5>?vvv&&w/ / . ! & & 2#<x'8'8'>'>hf  ++DJJ7   #2#F#F,?,?$  $(   $"5"5"5nn E    , , 8nn J      !!!%%001HII..N m  " **4==9 ,::   DKKd))::)% x4'8t+;6>' 3 ***I + ""$$**&&    '; +C!..$<..**,0+P+P!% : : !% : :!"&#& y)4 I{::II J J   nnKLLk   ) jjjl77$$     vvv&&w/ / .   ++F3jf  ++DJJ7  nnHII & & &nnMNN . . :nn J   499;67$> yy(Dn$($:$:$Bd!! ' ' 3-CC  * *  ' '  ' '  . .  $ $   2 2  * *  # #  ! ! ' '  " " ( (    % %  ! ! ' '  % % + +  ! ! ' '  & & , ,  ) ) / /$($E$E$K$K'+'K'K'Q'Q' *  ) ) 5 %)= =    4 411&'89 0 1 n    6 6$($5$5&               ' )!//++++ --   ,!!!    0    .     ~ .>2nn%n%55E F      +==  " " )>>  % %  + +  & &   ' ' "11$2H2HIj)@@  ! !m  " **4==9 $$  &&   $#>,,#66**0,, 4( *.)L)L!"#$.%& '(0)*$(#@#@+, $77-../0&14 {I6} K}  $$~~t00! 5   T $$7A1 E   2 $$BLa P   : $$BLa P   * $$=G K   s:Ac>6DAe+AAe61B3Af&8BAgc> Aed6Ad>d>Aee Ae3eAe.e.Ae3e6 Af#fAffAf#f& Agf0AggAgg Ahg Ag>g>Ah)rrr:rrrrrrrrrrr)r)r))__name__ __module__ __qualname____firstlineno____doc__usagestrr FlagValuesrrrrsr__static_attributes__ __classcell__)rs@rrr(sk% I%_ 3_ E$4$4_ BSS13V 7V 7*-V 7}V 7V 7rr)%r __future__rrrrttypingrabslrrr1rlclientsr r r r r rrr)frontendrrrrrrrrrJrrr BigqueryCmdrr$rrrsn$&% %("&, ,%%,,( %2$E7  ' 'E7r