class TencentCloud::Ckafka::V20190819::MySQLParam
MySQL类型入参
def deserialize(params)
def deserialize(params) @Database = params['Database'] @Table = params['Table'] @Resource = params['Resource'] @SnapshotMode = params['SnapshotMode'] @DdlTopic = params['DdlTopic'] @DataSourceMonitorMode = params['DataSourceMonitorMode'] @DataSourceMonitorResource = params['DataSourceMonitorResource'] @DataSourceIncrementMode = params['DataSourceIncrementMode'] @DataSourceIncrementColumn = params['DataSourceIncrementColumn'] @DataSourceStartFrom = params['DataSourceStartFrom'] @DataTargetInsertMode = params['DataTargetInsertMode'] @DataTargetPrimaryKeyField = params['DataTargetPrimaryKeyField'] unless params['DataTargetRecordMapping'].nil? @DataTargetRecordMapping = [] params['DataTargetRecordMapping'].each do |i| recordmapping_tmp = RecordMapping.new recordmapping_tmp.deserialize(i) @DataTargetRecordMapping << recordmapping_tmp end end @TopicRegex = params['TopicRegex'] @TopicReplacement = params['TopicReplacement'] @KeyColumns = params['KeyColumns'] @DropInvalidMessage = params['DropInvalidMessage'] unless params['DropCls'].nil? @DropCls = DropCls.new @DropCls.deserialize(params['DropCls']) end @OutputFormat = params['OutputFormat'] @IsTablePrefix = params['IsTablePrefix'] @IncludeContentChanges = params['IncludeContentChanges'] @IncludeQuery = params['IncludeQuery'] @RecordWithSchema = params['RecordWithSchema'] @SignalDatabase = params['SignalDatabase'] @IsTableRegular = params['IsTableRegular'] @SignalTable = params['SignalTable'] @DateTimeZone = params['DateTimeZone'] @SelfBuilt = params['SelfBuilt'] end
def initialize(database=nil, table=nil, resource=nil, snapshotmode=nil, ddltopic=nil, datasourcemonitormode=nil, datasourcemonitorresource=nil, datasourceincrementmode=nil, datasourceincrementcolumn=nil, datasourcestartfrom=nil, datatargetinsertmode=nil, datatargetprimarykeyfield=nil, datatargetrecordmapping=nil, topicregex=nil, topicreplacement=nil, keycolumns=nil, dropinvalidmessage=nil, dropcls=nil, outputformat=nil, istableprefix=nil, includecontentchanges=nil, includequery=nil, recordwithschema=nil, signaldatabase=nil, istableregular=nil, signaltable=nil, datetimezone=nil, selfbuilt=nil)
def initialize(database=nil, table=nil, resource=nil, snapshotmode=nil, ddltopic=nil, datasourcemonitormode=nil, datasourcemonitorresource=nil, datasourceincrementmode=nil, datasourceincrementcolumn=nil, datasourcestartfrom=nil, datatargetinsertmode=nil, datatargetprimarykeyfield=nil, datatargetrecordmapping=nil, topicregex=nil, topicreplacement=nil, keycolumns=nil, dropinvalidmessage=nil, dropcls=nil, outputformat=nil, istableprefix=nil, includecontentchanges=nil, includequery=nil, recordwithschema=nil, signaldatabase=nil, istableregular=nil, signaltable=nil, datetimezone=nil, selfbuilt=nil) @Database = database @Table = table @Resource = resource @SnapshotMode = snapshotmode @DdlTopic = ddltopic @DataSourceMonitorMode = datasourcemonitormode @DataSourceMonitorResource = datasourcemonitorresource @DataSourceIncrementMode = datasourceincrementmode @DataSourceIncrementColumn = datasourceincrementcolumn @DataSourceStartFrom = datasourcestartfrom @DataTargetInsertMode = datatargetinsertmode @DataTargetPrimaryKeyField = datatargetprimarykeyfield @DataTargetRecordMapping = datatargetrecordmapping @TopicRegex = topicregex @TopicReplacement = topicreplacement @KeyColumns = keycolumns @DropInvalidMessage = dropinvalidmessage @DropCls = dropcls @OutputFormat = outputformat @IsTablePrefix = istableprefix @IncludeContentChanges = includecontentchanges @IncludeQuery = includequery @RecordWithSchema = recordwithschema @SignalDatabase = signaldatabase @IsTableRegular = istableregular @SignalTable = signaltable @DateTimeZone = datetimezone @SelfBuilt = selfbuilt end