Class: TencentCloud::Dlc::V20210125::TasksInfo

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

Overview

批量顺序执行任务集合

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(tasktype = nil, failuretolerance = nil, sql = nil, config = nil, params = nil) ⇒ TasksInfo

Returns a new instance of TasksInfo.



16283
16284
16285
16286
16287
16288
16289
# File 'lib/v20210125/models.rb', line 16283

def initialize(tasktype=nil, failuretolerance=nil, sql=nil, config=nil, params=nil)
  @TaskType = tasktype
  @FailureTolerance = failuretolerance
  @SQL = sql
  @Config = config
  @Params = params
end

Instance Attribute Details

#ConfigObject

Parameters:

  • TaskType:

    任务类型,SQLTask:SQL查询任务。SparkSQLTask:Spark SQL查询任务

  • FailureTolerance:

    容错策略。Proceed:前面任务出错/取消后继续执行后面的任务。Terminate:前面的任务出错/取消之后终止后面任务的执行,后面的任务全部标记为已取消。

  • SQL:

    base64加密后的SQL语句,用“;”号分隔每个SQL语句,一次最多提交50个任务。严格按照前后顺序执行

  • Config:

    任务的配置信息,当前仅支持SparkSQLTask任务。

  • Params:

    任务的用户自定义参数信息



16281
16282
16283
# File 'lib/v20210125/models.rb', line 16281

def Config
  @Config
end

#FailureToleranceObject

Parameters:

  • TaskType:

    任务类型,SQLTask:SQL查询任务。SparkSQLTask:Spark SQL查询任务

  • FailureTolerance:

    容错策略。Proceed:前面任务出错/取消后继续执行后面的任务。Terminate:前面的任务出错/取消之后终止后面任务的执行,后面的任务全部标记为已取消。

  • SQL:

    base64加密后的SQL语句,用“;”号分隔每个SQL语句,一次最多提交50个任务。严格按照前后顺序执行

  • Config:

    任务的配置信息,当前仅支持SparkSQLTask任务。

  • Params:

    任务的用户自定义参数信息



16281
16282
16283
# File 'lib/v20210125/models.rb', line 16281

def FailureTolerance
  @FailureTolerance
end

#ParamsObject

Parameters:

  • TaskType:

    任务类型,SQLTask:SQL查询任务。SparkSQLTask:Spark SQL查询任务

  • FailureTolerance:

    容错策略。Proceed:前面任务出错/取消后继续执行后面的任务。Terminate:前面的任务出错/取消之后终止后面任务的执行,后面的任务全部标记为已取消。

  • SQL:

    base64加密后的SQL语句,用“;”号分隔每个SQL语句,一次最多提交50个任务。严格按照前后顺序执行

  • Config:

    任务的配置信息,当前仅支持SparkSQLTask任务。

  • Params:

    任务的用户自定义参数信息



16281
16282
16283
# File 'lib/v20210125/models.rb', line 16281

def Params
  @Params
end

#SQLObject

Parameters:

  • TaskType:

    任务类型,SQLTask:SQL查询任务。SparkSQLTask:Spark SQL查询任务

  • FailureTolerance:

    容错策略。Proceed:前面任务出错/取消后继续执行后面的任务。Terminate:前面的任务出错/取消之后终止后面任务的执行,后面的任务全部标记为已取消。

  • SQL:

    base64加密后的SQL语句,用“;”号分隔每个SQL语句,一次最多提交50个任务。严格按照前后顺序执行

  • Config:

    任务的配置信息,当前仅支持SparkSQLTask任务。

  • Params:

    任务的用户自定义参数信息



16281
16282
16283
# File 'lib/v20210125/models.rb', line 16281

def SQL
  @SQL
end

#TaskTypeObject

Parameters:

  • TaskType:

    任务类型,SQLTask:SQL查询任务。SparkSQLTask:Spark SQL查询任务

  • FailureTolerance:

    容错策略。Proceed:前面任务出错/取消后继续执行后面的任务。Terminate:前面的任务出错/取消之后终止后面任务的执行,后面的任务全部标记为已取消。

  • SQL:

    base64加密后的SQL语句,用“;”号分隔每个SQL语句,一次最多提交50个任务。严格按照前后顺序执行

  • Config:

    任务的配置信息,当前仅支持SparkSQLTask任务。

  • Params:

    任务的用户自定义参数信息



16281
16282
16283
# File 'lib/v20210125/models.rb', line 16281

def TaskType
  @TaskType
end

Instance Method Details

#deserialize(params) ⇒ Object



16291
16292
16293
16294
16295
16296
16297
16298
16299
16300
16301
16302
16303
16304
16305
16306
16307
16308
16309
16310
16311
# File 'lib/v20210125/models.rb', line 16291

def deserialize(params)
  @TaskType = params['TaskType']
  @FailureTolerance = params['FailureTolerance']
  @SQL = params['SQL']
  unless params['Config'].nil?
    @Config = []
    params['Config'].each do |i|
      kvpair_tmp = KVPair.new
      kvpair_tmp.deserialize(i)
      @Config << kvpair_tmp
    end
  end
  unless params['Params'].nil?
    @Params = []
    params['Params'].each do |i|
      kvpair_tmp = KVPair.new
      kvpair_tmp.deserialize(i)
      @Params << kvpair_tmp
    end
  end
end