class TencentCloud::Dts::V20211206::KafkaOption
目标端为kakfa时添加的同步选项字段
def deserialize(params)
def deserialize(params) @DataType = params['DataType'] @TopicType = params['TopicType'] @DDLTopicName = params['DDLTopicName'] unless params['TopicRules'].nil? @TopicRules = [] params['TopicRules'].each do |i| topicrule_tmp = TopicRule.new topicrule_tmp.deserialize(i) @TopicRules << topicrule_tmp end end end
def initialize(datatype=nil, topictype=nil, ddltopicname=nil, topicrules=nil)
def initialize(datatype=nil, topictype=nil, ddltopicname=nil, topicrules=nil) @DataType = datatype @TopicType = topictype @DDLTopicName = ddltopicname @TopicRules = topicrules end