Class: TencentCloud::Dts::V20211206::KafkaOption

Inherits:
Common::AbstractModel
  • Object
show all
Defined in:
lib/v20211206/models.rb

Overview

目标端为kafka时添加的同步选项字段

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(datatype = nil, topictype = nil, ddltopicname = nil, topicrules = nil, dataoption = nil) ⇒ KafkaOption

Returns a new instance of KafkaOption.



4646
4647
4648
4649
4650
4651
4652
 
# File 'lib/v20211206/models.rb', line 4646

def initialize(datatype=nil, topictype=nil, ddltopicname=nil, topicrules=nil, dataoption=nil)
  @DataType = datatype
  @TopicType = topictype
  @DDLTopicName = ddltopicname
  @TopicRules = topicrules
  @DataOption = dataoption
end

Instance Attribute Details

#DataOption ⇒ Object

Parameters:

  • DataType: —

    投递到kafka的数据类型，如Avro,Json,canal-pb,canal-json,debezium

  • TopicType: —

    同步topic策略，如Single（集中投递到单topic）,Multi (自定义topic名称)

  • DDLTopicName: —

    用于存储ddl的topic

  • TopicRules: —

    单topic和自定义topic的描述

  • DataOption: —

    其他附加信息，对于特定数据类型可设置额外参数，比如针对Canal兼容的功能支持：“canalOfficialFormat”:“on”表示打开Canal兼容功能，默认不带。



4644
4645
4646
 
# File 'lib/v20211206/models.rb', line 4644

def DataOption
  @DataOption
end

#DataType ⇒ Object

Parameters:

  • DataType: —

    投递到kafka的数据类型，如Avro,Json,canal-pb,canal-json,debezium

  • TopicType: —

    同步topic策略，如Single（集中投递到单topic）,Multi (自定义topic名称)

  • DDLTopicName: —

    用于存储ddl的topic

  • TopicRules: —

    单topic和自定义topic的描述

  • DataOption: —

    其他附加信息，对于特定数据类型可设置额外参数，比如针对Canal兼容的功能支持：“canalOfficialFormat”:“on”表示打开Canal兼容功能，默认不带。



4644
4645
4646
 
# File 'lib/v20211206/models.rb', line 4644

def DataType
  @DataType
end

#DDLTopicName ⇒ Object

Parameters:

  • DataType: —

    投递到kafka的数据类型，如Avro,Json,canal-pb,canal-json,debezium

  • TopicType: —

    同步topic策略，如Single（集中投递到单topic）,Multi (自定义topic名称)

  • DDLTopicName: —

    用于存储ddl的topic

  • TopicRules: —

    单topic和自定义topic的描述

  • DataOption: —

    其他附加信息，对于特定数据类型可设置额外参数，比如针对Canal兼容的功能支持：“canalOfficialFormat”:“on”表示打开Canal兼容功能，默认不带。



4644
4645
4646
 
# File 'lib/v20211206/models.rb', line 4644

def DDLTopicName
  @DDLTopicName
end

#TopicRules ⇒ Object

Parameters:

  • DataType: —

    投递到kafka的数据类型，如Avro,Json,canal-pb,canal-json,debezium

  • TopicType: —

    同步topic策略，如Single（集中投递到单topic）,Multi (自定义topic名称)

  • DDLTopicName: —

    用于存储ddl的topic

  • TopicRules: —

    单topic和自定义topic的描述

  • DataOption: —

    其他附加信息，对于特定数据类型可设置额外参数，比如针对Canal兼容的功能支持：“canalOfficialFormat”:“on”表示打开Canal兼容功能，默认不带。



4644
4645
4646
 
# File 'lib/v20211206/models.rb', line 4644

def TopicRules
  @TopicRules
end

#TopicType ⇒ Object

Parameters:

  • DataType: —

    投递到kafka的数据类型，如Avro,Json,canal-pb,canal-json,debezium

  • TopicType: —

    同步topic策略，如Single（集中投递到单topic）,Multi (自定义topic名称)

  • DDLTopicName: —

    用于存储ddl的topic

  • TopicRules: —

    单topic和自定义topic的描述

  • DataOption: —

    其他附加信息，对于特定数据类型可设置额外参数，比如针对Canal兼容的功能支持：“canalOfficialFormat”:“on”表示打开Canal兼容功能，默认不带。



4644
4645
4646
 
# File 'lib/v20211206/models.rb', line 4644

def TopicType
  @TopicType
end

Instance Method Details

#deserialize(params) ⇒ Object 



4654
4655
4656
4657
4658
4659
4660
4661
4662
4663
4664
4665
4666
4667
4668
4669
4670
4671
4672
4673
4674
 
# File 'lib/v20211206/models.rb', line 4654

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
  unless params['DataOption'].nil?
    @DataOption = []
    params['DataOption'].each do |i|
      keyvaluepairoption_tmp = KeyValuePairOption.new
      keyvaluepairoption_tmp.deserialize(i)
      @DataOption << keyvaluepairoption_tmp
    end
  end
end