class TencentCloud::Ckafka::V20190819::TransformsParam
数据处理参数
def deserialize(params)
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
def initialize(content=nil, fieldchain=nil, filterparam=nil, failureparam=nil, result=nil, sourcetype=nil, outputformat=nil, rowparam=nil, keepmetadata=nil, batchanalyse=nil)
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