@@ -302,10 +302,10 @@ def update!(**args)
302302 end
303303
304304 # Configuration for a Bigtable subscription. The Pub/Sub message will be written
305- # to a Bigtable row as follows: - row key: subscription name and message ID
306- # delimited by # . - columns: message bytes written to a single column family "
307- # data" with an empty-string column qualifier. - cell timestamp: the message
308- # publish timestamp.
305+ # to a Bigtable row as follows: - row key: subscription name, message ID hash,
306+ # and message ID delimited by `#` . - columns: message bytes written to a single
307+ # column family ` data` with an empty-string column qualifier. - cell timestamp:
308+ # the message publish timestamp.
309309 class BigtableConfig
310310 include Google ::Apis ::Core ::Hashable
311311
@@ -552,6 +552,32 @@ def update!(**args)
552552 end
553553 end
554554
555+ # Configuration for compressing/decompressing message data using a user-
556+ # specified compression algorithm.
557+ class Compression
558+ include Google ::Apis ::Core ::Hashable
559+
560+ # Required. Specifies the compression algorithm to use.
561+ # Corresponds to the JSON property `compressionAlgorithm`
562+ # @return [String]
563+ attr_accessor :compression_algorithm
564+
565+ # Required. Specifies whether to compress or decompress the message.
566+ # Corresponds to the JSON property `compressionMode`
567+ # @return [String]
568+ attr_accessor :compression_mode
569+
570+ def initialize ( **args )
571+ update! ( **args )
572+ end
573+
574+ # Update properties of this object
575+ def update! ( **args )
576+ @compression_algorithm = args [ :compression_algorithm ] if args . key? ( :compression_algorithm )
577+ @compression_mode = args [ :compression_mode ] if args . key? ( :compression_mode )
578+ end
579+ end
580+
555581 # A data exchange is a container that lets you share data. Along with the
556582 # descriptive information about the data exchange, it contains listings that
557583 # reference shared datasets.
@@ -1124,10 +1150,10 @@ class GooglePubsubV1Subscription
11241150 attr_accessor :bigquery_config
11251151
11261152 # Configuration for a Bigtable subscription. The Pub/Sub message will be written
1127- # to a Bigtable row as follows: - row key: subscription name and message ID
1128- # delimited by # . - columns: message bytes written to a single column family "
1129- # data" with an empty-string column qualifier. - cell timestamp: the message
1130- # publish timestamp.
1153+ # to a Bigtable row as follows: - row key: subscription name, message ID hash,
1154+ # and message ID delimited by `#` . - columns: message bytes written to a single
1155+ # column family ` data` with an empty-string column qualifier. - cell timestamp:
1156+ # the message publish timestamp.
11311157 # Corresponds to the JSON property `bigtableConfig`
11321158 # @return [Google::Apis::AnalyticshubV1::BigtableConfig]
11331159 attr_accessor :bigtable_config
@@ -1670,6 +1696,12 @@ class MessageTransform
16701696 # @return [Google::Apis::AnalyticshubV1::AiInference]
16711697 attr_accessor :ai_inference
16721698
1699+ # Configuration for compressing/decompressing message data using a user-
1700+ # specified compression algorithm.
1701+ # Corresponds to the JSON property `compression`
1702+ # @return [Google::Apis::AnalyticshubV1::Compression]
1703+ attr_accessor :compression
1704+
16731705 # Optional. If true, the transform is disabled and will not be applied to
16741706 # messages. Defaults to `false`.
16751707 # Corresponds to the JSON property `disabled`
@@ -1697,6 +1729,7 @@ def initialize(**args)
16971729 # Update properties of this object
16981730 def update! ( **args )
16991731 @ai_inference = args [ :ai_inference ] if args . key? ( :ai_inference )
1732+ @compression = args [ :compression ] if args . key? ( :compression )
17001733 @disabled = args [ :disabled ] if args . key? ( :disabled )
17011734 @enabled = args [ :enabled ] if args . key? ( :enabled )
17021735 @javascript_udf = args [ :javascript_udf ] if args . key? ( :javascript_udf )
0 commit comments