models.rb in tencentcloud-sdk-ckafka-3.0.391

- old
+ new

@@ -6658,22 +6658,25 @@
         # @type RebalanceTime: Integer
         # @param PublicNetwork: 时间戳
         # @type PublicNetwork: Integer
         # @param DynamicDiskConfig: 动态硬盘扩容策略配置
         # @type DynamicDiskConfig: :class:`Tencentcloud::Ckafka.v20190819.models.DynamicDiskConfig`
+        # @param MaxMessageByte: 实例级别单条消息大小（单位byte)
+        # @type MaxMessageByte: Integer
 
-        attr_accessor :InstanceId, :MsgRetentionTime, :InstanceName, :Config, :DynamicRetentionConfig, :RebalanceTime, :PublicNetwork, :DynamicDiskConfig
+        attr_accessor :InstanceId, :MsgRetentionTime, :InstanceName, :Config, :DynamicRetentionConfig, :RebalanceTime, :PublicNetwork, :DynamicDiskConfig, :MaxMessageByte
         
-        def initialize(instanceid=nil, msgretentiontime=nil, instancename=nil, config=nil, dynamicretentionconfig=nil, rebalancetime=nil, publicnetwork=nil, dynamicdiskconfig=nil)
+        def initialize(instanceid=nil, msgretentiontime=nil, instancename=nil, config=nil, dynamicretentionconfig=nil, rebalancetime=nil, publicnetwork=nil, dynamicdiskconfig=nil, maxmessagebyte=nil)
           @InstanceId = instanceid
           @MsgRetentionTime = msgretentiontime
           @InstanceName = instancename
           @Config = config
           @DynamicRetentionConfig = dynamicretentionconfig
           @RebalanceTime = rebalancetime
           @PublicNetwork = publicnetwork
           @DynamicDiskConfig = dynamicdiskconfig
+          @MaxMessageByte = maxmessagebyte
         end
 
         def deserialize(params)
           @InstanceId = params['InstanceId']
           @MsgRetentionTime = params['MsgRetentionTime']
@@ -6690,10 +6693,11 @@
           @PublicNetwork = params['PublicNetwork']
           unless params['DynamicDiskConfig'].nil?
             @DynamicDiskConfig = DynamicDiskConfig.new
             @DynamicDiskConfig.deserialize(params['DynamicDiskConfig'])
           end
+          @MaxMessageByte = params['MaxMessageByte']
         end
       end
 
       # ModifyInstanceAttributes返回参数结构体
       class ModifyInstanceAttributesResponse < TencentCloud::Common::AbstractModel
@@ -7179,22 +7183,26 @@
         # 注意：此字段可能返回 null，表示取不到有效值。
         # @type IsUpdate: Boolean
         # @param ClusterId: 当type为TDSQL_C_MYSQL时
         # 注意：此字段可能返回 null，表示取不到有效值。
         # @type ClusterId: String
+        # @param SelfBuilt: 是否是自建的集群
+        # 注意：此字段可能返回 null，表示取不到有效值。
+        # @type SelfBuilt: Boolean
 
-        attr_accessor :Resource, :Port, :ServiceVip, :UniqVpcId, :UserName, :Password, :IsUpdate, :ClusterId
+        attr_accessor :Resource, :Port, :ServiceVip, :UniqVpcId, :UserName, :Password, :IsUpdate, :ClusterId, :SelfBuilt
         
-        def initialize(resource=nil, port=nil, servicevip=nil, uniqvpcid=nil, username=nil, password=nil, isupdate=nil, clusterid=nil)
+        def initialize(resource=nil, port=nil, servicevip=nil, uniqvpcid=nil, username=nil, password=nil, isupdate=nil, clusterid=nil, selfbuilt=nil)
           @Resource = resource
           @Port = port
           @ServiceVip = servicevip
           @UniqVpcId = uniqvpcid
           @UserName = username
           @Password = password
           @IsUpdate = isupdate
           @ClusterId = clusterid
+          @SelfBuilt = selfbuilt
         end
 
         def deserialize(params)
           @Resource = params['Resource']
           @Port = params['Port']
@@ -7202,10 +7210,11 @@
           @UniqVpcId = params['UniqVpcId']
           @UserName = params['UserName']
           @Password = params['Password']
           @IsUpdate = params['IsUpdate']
           @ClusterId = params['ClusterId']
+          @SelfBuilt = params['SelfBuilt']
         end
       end
 
       # MySQL类型入参
       class MySQLParam < TencentCloud::Common::AbstractModel
@@ -7473,22 +7482,26 @@
         # 注意：此字段可能返回 null，表示取不到有效值。
         # @type ClusterId: String
         # @param IsUpdate: 是否更新到关联的Datahub任务
         # 注意：此字段可能返回 null，表示取不到有效值。
         # @type IsUpdate: Boolean
+        # @param SelfBuilt: 是否为自建集群
+        # 注意：此字段可能返回 null，表示取不到有效值。
+        # @type SelfBuilt: Boolean
 
-        attr_accessor :Resource, :Port, :ServiceVip, :UniqVpcId, :UserName, :Password, :ClusterId, :IsUpdate
+        attr_accessor :Resource, :Port, :ServiceVip, :UniqVpcId, :UserName, :Password, :ClusterId, :IsUpdate, :SelfBuilt
         
-        def initialize(resource=nil, port=nil, servicevip=nil, uniqvpcid=nil, username=nil, password=nil, clusterid=nil, isupdate=nil)
+        def initialize(resource=nil, port=nil, servicevip=nil, uniqvpcid=nil, username=nil, password=nil, clusterid=nil, isupdate=nil, selfbuilt=nil)
           @Resource = resource
           @Port = port
           @ServiceVip = servicevip
           @UniqVpcId = uniqvpcid
           @UserName = username
           @Password = password
           @ClusterId = clusterid
           @IsUpdate = isupdate
+          @SelfBuilt = selfbuilt
         end
 
         def deserialize(params)
           @Resource = params['Resource']
           @Port = params['Port']
@@ -7496,10 +7509,11 @@
           @UniqVpcId = params['UniqVpcId']
           @UserName = params['UserName']
           @Password = params['Password']
           @ClusterId = params['ClusterId']
           @IsUpdate = params['IsUpdate']
+          @SelfBuilt = params['SelfBuilt']
         end
       end
 
       # PostgreSQL类型入参
       class PostgreSQLParam < TencentCloud::Common::AbstractModel
@@ -7786,10 +7800,36 @@
             end
           end
         end
       end
 
+      # 数据处理ROW输出格式配置
+      class RowParam < TencentCloud::Common::AbstractModel
+        # @param RowContent: 行内容，KEY_VALUE，VALUE
+        # @type RowContent: String
+        # @param KeyValueDelimiter: key和value间的分隔符
+        # 注意：此字段可能返回 null，表示取不到有效值。
+        # @type KeyValueDelimiter: String
+        # @param EntryDelimiter: 元素建的分隔符
+        # 注意：此字段可能返回 null，表示取不到有效值。
+        # @type EntryDelimiter: String
+
+        attr_accessor :RowContent, :KeyValueDelimiter, :EntryDelimiter
+        
+        def initialize(rowcontent=nil, keyvaluedelimiter=nil, entrydelimiter=nil)
+          @RowContent = rowcontent
+          @KeyValueDelimiter = keyvaluedelimiter
+          @EntryDelimiter = entrydelimiter
+        end
+
+        def deserialize(params)
+          @RowContent = params['RowContent']
+          @KeyValueDelimiter = params['KeyValueDelimiter']
+          @EntryDelimiter = params['EntryDelimiter']
+        end
+      end
+
       # 数据处理——数据处理参数
       class SMTParam < TencentCloud::Common::AbstractModel
         # @param Key: 数据处理KEY
         # @type Key: String
         # @param Operate: 操作，DATE系统预设-时间戳，CUSTOMIZE自定义，MAPPING映射，JSONPATH
@@ -8735,24 +8775,28 @@
         # 注意：此字段可能返回 null，表示取不到有效值。
         # @type Result: String
         # @param SourceType: 数据来源
         # 注意：此字段可能返回 null，表示取不到有效值。
         # @type SourceType: String
-        # @param OutputFormat: 输出格式
+        # @param OutputFormat: 输出格式，JSON，ROW，默认为JSON
         # 注意：此字段可能返回 null，表示取不到有效值。
         # @type OutputFormat: String
+        # @param RowParam: 输出格式为ROW必填
+        # 注意：此字段可能返回 null，表示取不到有效值。
+        # @type RowParam: :class:`Tencentcloud::Ckafka.v20190819.models.RowParam`
 
-        attr_accessor :Content, :FieldChain, :FilterParam, :FailureParam, :Result, :SourceType, :OutputFormat
+        attr_accessor :Content, :FieldChain, :FilterParam, :FailureParam, :Result, :SourceType, :OutputFormat, :RowParam
         
-        def initialize(content=nil, fieldchain=nil, filterparam=nil, failureparam=nil, result=nil, sourcetype=nil, outputformat=nil)
+        def initialize(content=nil, fieldchain=nil, filterparam=nil, failureparam=nil, result=nil, sourcetype=nil, outputformat=nil, rowparam=nil)
           @Content = content
           @FieldChain = fieldchain
           @FilterParam = filterparam
           @FailureParam = failureparam
           @Result = result
           @SourceType = sourcetype
           @OutputFormat = outputformat
+          @RowParam = rowparam
         end
 
         def deserialize(params)
           @Content = params['Content']
           unless params['FieldChain'].nil?
@@ -8776,9 +8820,13 @@
             @FailureParam.deserialize(params['FailureParam'])
           end
           @Result = params['Result']
           @SourceType = params['SourceType']
           @OutputFormat = params['OutputFormat']
+          unless params['RowParam'].nil?
+            @RowParam = RowParam.new
+            @RowParam.deserialize(params['RowParam'])
+          end
         end
       end
 
       # 用户实体
       class User < TencentCloud::Common::AbstractModel