class TencentCloud::Ckafka::V20190819::MySQLParam

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