Class: TencentCloud::Ckafka::V20190819::TransformsParam

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

Overview

数据处理参数

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(content = nil, fieldchain = nil, filterparam = nil, failureparam = nil, result = nil, sourcetype = nil, outputformat = nil, rowparam = nil, keepmetadata = nil, batchanalyse = nil) ⇒ TransformsParam

Returns a new instance of TransformsParam.



12292
12293
12294
12295
12296
12297
12298
12299
12300
12301
12302
12303
 
# File 'lib/v20190819/models.rb', line 12292

def initialize(content=nil, fieldchain=nil, filterparam=nil, failureparam=nil, result=nil, sourcetype=nil, outputformat=nil, rowparam=nil, keepmetadata=nil, batchanalyse=nil)
  @Content = content
  @FieldChain = fieldchain
  @FilterParam = filterparam
  @FailureParam = failureparam
  @Result = result
  @SourceType = sourcetype
  @OutputFormat = outputformat
  @RowParam = rowparam
  @KeepMetadata = keepmetadata
  @BatchAnalyse = batchanalyse
end

Instance Attribute Details

#BatchAnalyse ⇒ Object

Parameters:

  • Content: —

    原始数据

  • FieldChain: —

    处理链

  • FilterParam: —

    过滤器

  • FailureParam: —

    失败处理

  • Result: —

    测试结果

  • SourceType: —

    数据来源

  • OutputFormat: —

    输出格式，JSON，ROW，默认为JSON

  • RowParam: —

    输出格式为ROW必填

  • KeepMetadata: —

    是否保留数据源Topic元数据信息（源Topic、Partition、Offset），默认为false

  • BatchAnalyse: —

    数组解析



12290
12291
12292
 
# File 'lib/v20190819/models.rb', line 12290

def BatchAnalyse
  @BatchAnalyse
end

#Content ⇒ Object

Parameters:

  • Content: —

    原始数据

  • FieldChain: —

    处理链

  • FilterParam: —

    过滤器

  • FailureParam: —

    失败处理

  • Result: —

    测试结果

  • SourceType: —

    数据来源

  • OutputFormat: —

    输出格式，JSON，ROW，默认为JSON

  • RowParam: —

    输出格式为ROW必填

  • KeepMetadata: —

    是否保留数据源Topic元数据信息（源Topic、Partition、Offset），默认为false

  • BatchAnalyse: —

    数组解析



12290
12291
12292
 
# File 'lib/v20190819/models.rb', line 12290

def Content
  @Content
end

#FailureParam ⇒ Object

Parameters:

  • Content: —

    原始数据

  • FieldChain: —

    处理链

  • FilterParam: —

    过滤器

  • FailureParam: —

    失败处理

  • Result: —

    测试结果

  • SourceType: —

    数据来源

  • OutputFormat: —

    输出格式，JSON，ROW，默认为JSON

  • RowParam: —

    输出格式为ROW必填

  • KeepMetadata: —

    是否保留数据源Topic元数据信息（源Topic、Partition、Offset），默认为false

  • BatchAnalyse: —

    数组解析



12290
12291
12292
 
# File 'lib/v20190819/models.rb', line 12290

def FailureParam
  @FailureParam
end

#FieldChain ⇒ Object

Parameters:

  • Content: —

    原始数据

  • FieldChain: —

    处理链

  • FilterParam: —

    过滤器

  • FailureParam: —

    失败处理

  • Result: —

    测试结果

  • SourceType: —

    数据来源

  • OutputFormat: —

    输出格式，JSON，ROW，默认为JSON

  • RowParam: —

    输出格式为ROW必填

  • KeepMetadata: —

    是否保留数据源Topic元数据信息（源Topic、Partition、Offset），默认为false

  • BatchAnalyse: —

    数组解析



12290
12291
12292
 
# File 'lib/v20190819/models.rb', line 12290

def FieldChain
  @FieldChain
end

#FilterParam ⇒ Object

Parameters:

  • Content: —

    原始数据

  • FieldChain: —

    处理链

  • FilterParam: —

    过滤器

  • FailureParam: —

    失败处理

  • Result: —

    测试结果

  • SourceType: —

    数据来源

  • OutputFormat: —

    输出格式，JSON，ROW，默认为JSON

  • RowParam: —

    输出格式为ROW必填

  • KeepMetadata: —

    是否保留数据源Topic元数据信息（源Topic、Partition、Offset），默认为false

  • BatchAnalyse: —

    数组解析



12290
12291
12292
 
# File 'lib/v20190819/models.rb', line 12290

def FilterParam
  @FilterParam
end

#KeepMetadata ⇒ Object

Parameters:

  • Content: —

    原始数据

  • FieldChain: —

    处理链

  • FilterParam: —

    过滤器

  • FailureParam: —

    失败处理

  • Result: —

    测试结果

  • SourceType: —

    数据来源

  • OutputFormat: —

    输出格式，JSON，ROW，默认为JSON

  • RowParam: —

    输出格式为ROW必填

  • KeepMetadata: —

    是否保留数据源Topic元数据信息（源Topic、Partition、Offset），默认为false

  • BatchAnalyse: —

    数组解析



12290
12291
12292
 
# File 'lib/v20190819/models.rb', line 12290

def KeepMetadata
  @KeepMetadata
end

#OutputFormat ⇒ Object

Parameters:

  • Content: —

    原始数据

  • FieldChain: —

    处理链

  • FilterParam: —

    过滤器

  • FailureParam: —

    失败处理

  • Result: —

    测试结果

  • SourceType: —

    数据来源

  • OutputFormat: —

    输出格式，JSON，ROW，默认为JSON

  • RowParam: —

    输出格式为ROW必填

  • KeepMetadata: —

    是否保留数据源Topic元数据信息（源Topic、Partition、Offset），默认为false

  • BatchAnalyse: —

    数组解析



12290
12291
12292
 
# File 'lib/v20190819/models.rb', line 12290

def OutputFormat
  @OutputFormat
end

#Result ⇒ Object

Parameters:

  • Content: —

    原始数据

  • FieldChain: —

    处理链

  • FilterParam: —

    过滤器

  • FailureParam: —

    失败处理

  • Result: —

    测试结果

  • SourceType: —

    数据来源

  • OutputFormat: —

    输出格式，JSON，ROW，默认为JSON

  • RowParam: —

    输出格式为ROW必填

  • KeepMetadata: —

    是否保留数据源Topic元数据信息（源Topic、Partition、Offset），默认为false

  • BatchAnalyse: —

    数组解析



12290
12291
12292
 
# File 'lib/v20190819/models.rb', line 12290

def Result
  @Result
end

#RowParam ⇒ Object

Parameters:

  • Content: —

    原始数据

  • FieldChain: —

    处理链

  • FilterParam: —

    过滤器

  • FailureParam: —

    失败处理

  • Result: —

    测试结果

  • SourceType: —

    数据来源

  • OutputFormat: —

    输出格式，JSON，ROW，默认为JSON

  • RowParam: —

    输出格式为ROW必填

  • KeepMetadata: —

    是否保留数据源Topic元数据信息（源Topic、Partition、Offset），默认为false

  • BatchAnalyse: —

    数组解析



12290
12291
12292
 
# File 'lib/v20190819/models.rb', line 12290

def RowParam
  @RowParam
end

#SourceType ⇒ Object

Parameters:

  • Content: —

    原始数据

  • FieldChain: —

    处理链

  • FilterParam: —

    过滤器

  • FailureParam: —

    失败处理

  • Result: —

    测试结果

  • SourceType: —

    数据来源

  • OutputFormat: —

    输出格式，JSON，ROW，默认为JSON

  • RowParam: —

    输出格式为ROW必填

  • KeepMetadata: —

    是否保留数据源Topic元数据信息（源Topic、Partition、Offset），默认为false

  • BatchAnalyse: —

    数组解析



12290
12291
12292
 
# File 'lib/v20190819/models.rb', line 12290

def SourceType
  @SourceType
end

Instance Method Details

#deserialize(params) ⇒ Object 



12305
12306
12307
12308
12309
12310
12311
12312
12313
12314
12315
12316
12317
12318
12319
12320
12321
12322
12323
12324
12325
12326
12327
12328
12329
12330
12331
12332
12333
12334
12335
12336
12337
12338
12339
 
# File 'lib/v20190819/models.rb', line 12305

def deserialize(params)
  @Content = params['Content']
  unless params['FieldChain'].nil?
    @FieldChain = []
    params['FieldChain'].each do |i|
      fieldparam_tmp = FieldParam.new
      fieldparam_tmp.deserialize(i)
      @FieldChain << fieldparam_tmp
    end
  end
  unless params['FilterParam'].nil?
    @FilterParam = []
    params['FilterParam'].each do |i|
      filtermapparam_tmp = FilterMapParam.new
      filtermapparam_tmp.deserialize(i)
      @FilterParam << filtermapparam_tmp
    end
  end
  unless params['FailureParam'].nil?
    @FailureParam = FailureParam.new
    @FailureParam.deserialize(params['FailureParam'])
  end
  @Result = params['Result']
  @SourceType = params['SourceType']
  @OutputFormat = params['OutputFormat']
  unless params['RowParam'].nil?
    @RowParam = RowParam.new
    @RowParam.deserialize(params['RowParam'])
  end
  @KeepMetadata = params['KeepMetadata']
  unless params['BatchAnalyse'].nil?
    @BatchAnalyse = BatchAnalyseParam.new
    @BatchAnalyse.deserialize(params['BatchAnalyse'])
  end
end