class TencentCloud::Ckafka::V20190819::EsParam

def deserialize(params)
  @Resource = params['Resource']
  @Port = params['Port']
  @UserName = params['UserName']
  @Password = params['Password']
  @SelfBuilt = params['SelfBuilt']
  @ServiceVip = params['ServiceVip']
  @UniqVpcId = params['UniqVpcId']
  @DropInvalidMessage = params['DropInvalidMessage']
  @Index = params['Index']
  @DateFormat = params['DateFormat']
  @ContentKey = params['ContentKey']
  @DropInvalidJsonMessage = params['DropInvalidJsonMessage']
  @DocumentIdField = params['DocumentIdField']
  @IndexType = params['IndexType']
  unless params['DropCls'].nil?
    @DropCls = DropCls.new
    @DropCls.deserialize(params['DropCls'])
  end
  @DatabasePrimaryKey = params['DatabasePrimaryKey']
  unless params['DropDlq'].nil?
    @DropDlq = FailureParam.new
    @DropDlq.deserialize(params['DropDlq'])
  end
  unless params['RecordMappingList'].nil?
    @RecordMappingList = []
    params['RecordMappingList'].each do |i|
      esrecordmapping_tmp = EsRecordMapping.new
      esrecordmapping_tmp.deserialize(i)
      @RecordMappingList << esrecordmapping_tmp
    end
  end
  @DateField = params['DateField']
  @RecordMappingMode = params['RecordMappingMode']
end