class TencentCloud::Ckafka::V20190819::TransformParam
数据处理参数
def deserialize(params)
def deserialize(params) @AnalysisFormat = params['AnalysisFormat'] @OutputFormat = params['OutputFormat'] unless params['FailureParam'].nil? @FailureParam = FailureParam.new @FailureParam.deserialize(params['FailureParam']) end @Content = params['Content'] @SourceType = params['SourceType'] @Regex = params['Regex'] unless params['MapParam'].nil? @MapParam = [] params['MapParam'].each do |i| mapparam_tmp = MapParam.new mapparam_tmp.deserialize(i) @MapParam << mapparam_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 @Result = params['Result'] unless params['AnalyseResult'].nil? @AnalyseResult = [] params['AnalyseResult'].each do |i| mapparam_tmp = MapParam.new mapparam_tmp.deserialize(i) @AnalyseResult << mapparam_tmp end end @UseEventBus = params['UseEventBus'] end
def initialize(analysisformat=nil, outputformat=nil, failureparam=nil, content=nil, sourcetype=nil, regex=nil, mapparam=nil, filterparam=nil, result=nil, analyseresult=nil, useeventbus=nil)
def initialize(analysisformat=nil, outputformat=nil, failureparam=nil, content=nil, sourcetype=nil, regex=nil, mapparam=nil, filterparam=nil, result=nil, analyseresult=nil, useeventbus=nil) @AnalysisFormat = analysisformat @OutputFormat = outputformat @FailureParam = failureparam @Content = content @SourceType = sourcetype @Regex = regex @MapParam = mapparam @FilterParam = filterparam @Result = result @AnalyseResult = analyseresult @UseEventBus = useeventbus end