U2SrSSKJr SSKJr SSKJr SSKrSSKJr SSKJ r SSK J r SS K J r SS K Jr SS KJr SSKrS rS rSrSrSrSrSrSrSrSrSrSrSrSrSr Sr!Sr"Sr#Sr$Sr%S r&S!r'S"r(S#r)S$r*S%r+S&r,S'r-S(r.g))zBigtable tables API helper.)absolute_import)division)unicode_literalsN)encoding)util)base) exceptions)yaml)timescURS5n[U5S:wd US(d&[R"SSR U55eUSS:Xa/[ R "5R[USS5S9$USS :Xa.[ R "5R[US5S 9$[R"SSR U55e) zParses GC rules from a rule string. Args: rule: A string representing a GC rule, e.g. `maxage=10d` Returns: A GcRule object. Raises: BadArgumentExpection: the input is mal-formatted. =--column-familiesz'Invalid union or intersection rule: {0}rmaxage)maxAge maxversions)maxNumVersions) splitlenr BadArgumentExceptionformatrGetAdminMessagesGcRuleConvertDurationToSecondsint)rule rule_partss -lib/googlecloudsdk/api_lib/bigtable/tables.pyParseSingleRuler szz#*_A  ) )188>  ]h  " ) )' 1 7JK * !} %  " ) )Z]9K ) LL  ) )188> c[U5S:wa)[R"SSSRU5-5e/nUHnUR [ U55 M U$)zParses GC rules from a rule list of 2 elements. Args: rule_list: A string list containing 2 elements. Returns: A list of GcRule objects. Raises: BadArgumentExpection: the input list is mal-formatted. rrz$Invalid union or intersection rule:  )rr rjoinappendr ) rule_listresultsrs rParseBinaryRuler(@s` ^q  ) ).)1DD  'd NN?4() .r!cURS5nUSn[U5nUS:dX"R5:wa&[R"SSR U55eUS:XaUS4$US(d&[R"SSR U55eUSnURS5nURS 5n[U5S:Xa\[U5S:XaMU[ R"5R[ R"5R[U5S 9S 94$[U5S:Xa\[U5S:XaMU[ R"5R[ R"5R[U5S 9S 94$[U5S:Xa$[U5S:XaU(a U[U54$g[R"SSR U55e) ajParses family name and GC rules from the string expression. Args: expr: A string express contains family name and optional GC rules in the format of `family_name[:gc_rule]`, such as `my_family:maxage=10d`. Returns: A family name and a GcRule object defined in the Bigtable admin API. Raises: BadArgumentExpection: the input string is mal-formatted. :rrrz+Input column family ({0}) is mal-formatted.rNz||z&&)rules)union) intersection) rrstripr rrrrrUnionr( Intersectionr )expr expr_listfamily expr_list_lengc_rule union_listintersection_lists r ParseExprr8Zsjjo) Q<&i.-Q&LLN2  ) )5<[R"[R"U55$![Ra%n[R "U[ U55eSnAf[Ra%n[R "U[ U55eSnAff=f)a[Convert a string of duration in any form to seconds. Args: duration: A string of any valid form of duration, such as `10d`, `1w`, `36h` arg_name: The name of the argument that the duration is passed in. Returns: A string of duration counted in seconds, such as `1000s` Raises: BadArgumentExpection: the input duration is mal-formatted. N)r FormatDurationForJson ParseDurationDurationSyntaxErrorr rstrDurationValueError)durationarg_nameduration_errors rrrs   & &u':':8'D EE  " "  ) ) N   ! !  ) ) N s!),B A  B7 BBcX/nUHwn[U5up4[R"5RUS9nUR [R"5R R RX5S95 My [R"5R R US9$)a4Parses column families value object from the string list. Args: family_list: A list that contains one or more strings representing family name and optional GC rules in the format of `family_name[:gc_rule]`, such as `my_family_1,my_family_2:maxage=10d`. Returns: A column families value object. )gcRule)rEvalue)additionalProperties)r8rr ColumnFamilyr%TableColumnFamiliesValueAdditionalProperty) family_listr'r1r3r5 column_familys rParseColumnFamiliesr]s 'doOF))+888HM NN %%99LL M     & & : :" ; r!c[US5$)zParses change stream retention period from the string. Args: retention_period: Change stream retention period in the format of `3d` for 3 days. Returns: A string of duration counted in seconds, such as `259200s` --change-stream-retention-periodr)retention_periods r ParseChangeStreamRetentionPeriodrbs ": r!c[US5$)a Parses tiered storage config duration from the string. Args: duration: Tiered storage config duration in the format of a valid gcloud datetime duration string, such as `10d`, `1w`, `36h`. Returns: A string of duration counted in seconds, such as `259200s` ---tiered-storage-infrequent-access-older-thanr`rPs r ParseTieredStorageConfigDurationrfs "? r!cURnU(a$URU5S:Xa US-U-UlU$XlU$)zAdding a new field to the update mask of the updateTableRequest. Args: field: the field to be updated. req: the original updateTableRequest. Returns: req: the updateTableRequest with update mask refreshed. r,) updateMaskcount)fieldrB update_masks rAddFieldToUpdateMaskrm sG+1$"S(50cn *N *r!cUR(a [SU5nUR(a [SU5nUR(dUR(a [SU5nUR (a [SU5n[ US5(a:UR(a [SU5nUR(a [SU5nUR(dUR(a [SU5nU$) aRefresh the update mask of the updateTableRequest according to the input arguments. Args: unused_ref: the gcloud resource (unused). args: the input arguments. req: the original updateTableRequest. Returns: req: the updateTableRequest with update mask refreshed. changeStreamConfigz"changeStreamConfig.retentionPeriodautomatedBackupPolicyz%automatedBackupPolicy.retentionPeriodclear_tiered_storage_configtieredStorageConfigz7tieredStorageConfig.infrequentAccess.includeIfOlderThan rowKeySchema) $clear_change_stream_retention_periodrmchange_stream_retention_periodenable_automated_backupdisable_automated_backup!automated_backup_retention_periodhasattrrq+tiered_storage_infrequent_access_older_thanrow_key_schema_definition_fileclear_row_key_schema unused_refrArBs rRefreshUpdateMaskr s .. 3S 9C (( CS IC !!T%B%B 6 ? @@r!cUR(a9[URUR5URRlU$)z)Handles row key schema create table args.)r{#ParseRowKeySchemaFromDefinitionFile row_key_schema_pre_encoded_bytesr;r:rsr}s r!HandleRowKeySchemaCreateTableArgsr`s@ ((+  / /  1 1   - *r!cUR(a/[URUR5URlUR (aSUlU$)z)Handles row key schema update table args.T)r{rrr:rsr|ignoreWarningsr}s r!HandleRowKeySchemaUpdateTableArgsrlsF ((@ ++ --CII  C *r!cU(a+SU;d%SUS;dSUSS;dUSSS(dU$[USSS5USSS'U$)z6Encodes binary fields in the row key schema in Base64.rdelimitedBytes delimiter)r)row_key_schemas r&Base64EncodeBinaryFieldsInRowKeySchemarzs}  > )  !; ; N:67GH H J '(8 9+ F >JZ !12;??.-.{; r!c[R"5Rn[R"U5nU(d [ U5 [ R"X#5nU$![R[R4an[R"SU5eSnAf[an[SRX55eSnAff=f)a4Parses row key schema from the definition file. Args: definition_file: The path to the definition file. File must be in YAML or JSON format. pre_encoded: Whether all the binary fields in the row key schema (e.g. encoding.delimited_bytes.delimiter) are pre-encoded in Base64. Returns: A struct type object representing the row key schema. Raises: BadArgumentException if the definition file is not found, can't be read, or is not a valid YAML or JSON file. ValueError if the YAML/JSON object cannot be parsed as a valid row key schema. z --row-key-schema-definition-fileNzA!!$CB C)CC)/__doc__ __future__rrrrapitools.base.pyrgooglecloudsdk.api_lib.bigtablergooglecloudsdk.callioperr googlecloudsdk.corer googlecloudsdk.core.utilr rr r(r8rCrIrr]rbrfrmrrrrrrrrrrrrrrrrrrrrr!rrs"&' %0(.$* @4;| "  66   & DG $NB!H"J  " 4 >,1A    &$r!