class TencentCloud::Ckafka::V20190819::CreateDatahubTaskRequest

def deserialize(params)
  @TaskName = params['TaskName']
  @TaskType = params['TaskType']
  unless params['SourceResource'].nil?
    @SourceResource = DatahubResource.new
    @SourceResource.deserialize(params['SourceResource'])
  end
  unless params['TargetResource'].nil?
    @TargetResource = DatahubResource.new
    @TargetResource.deserialize(params['TargetResource'])
  end
  unless params['TransformParam'].nil?
    @TransformParam = TransformParam.new
    @TransformParam.deserialize(params['TransformParam'])
  end
  unless params['PrivateLinkParam'].nil?
    @PrivateLinkParam = PrivateLinkParam.new
    @PrivateLinkParam.deserialize(params['PrivateLinkParam'])
  end
  @SchemaId = params['SchemaId']
  unless params['TransformsParam'].nil?
    @TransformsParam = TransformsParam.new
    @TransformsParam.deserialize(params['TransformsParam'])
  end
  @TaskId = params['TaskId']
  unless params['Tags'].nil?
    @Tags = []
    params['Tags'].each do |i|
      tag_tmp = Tag.new
      tag_tmp.deserialize(i)
      @Tags << tag_tmp
    end
  end
end

def initialize(taskname=nil, tasktype=nil, sourceresource=nil, targetresource=nil, transformparam=nil, privatelinkparam=nil, schemaid=nil, transformsparam=nil, taskid=nil, tags=nil)
  @TaskName = taskname
  @TaskType = tasktype
  @SourceResource = sourceresource
  @TargetResource = targetresource
  @TransformParam = transformparam
  @PrivateLinkParam = privatelinkparam
  @SchemaId = schemaid
  @TransformsParam = transformsparam
  @TaskId = taskid
  @Tags = tags
end