class TencentCloud::Ckafka::V20190819::TopicFlowRankingResult

def deserialize(params)
  unless params['TopicFlow'].nil?
    @TopicFlow = []
    params['TopicFlow'].each do |i|
      topicflowranking_tmp = TopicFlowRanking.new
      topicflowranking_tmp.deserialize(i)
      @TopicFlow << topicflowranking_tmp
    end
  end
  unless params['ConsumeSpeed'].nil?
    @ConsumeSpeed = []
    params['ConsumeSpeed'].each do |i|
      consumergroupspeed_tmp = ConsumerGroupSpeed.new
      consumergroupspeed_tmp.deserialize(i)
      @ConsumeSpeed << consumergroupspeed_tmp
    end
  end
  unless params['TopicMessageHeap'].nil?
    @TopicMessageHeap = []
    params['TopicMessageHeap'].each do |i|
      topicmessageheapranking_tmp = TopicMessageHeapRanking.new
      topicmessageheapranking_tmp.deserialize(i)
      @TopicMessageHeap << topicmessageheapranking_tmp
    end
  end
  @BrokerIp = params['BrokerIp']
  unless params['BrokerTopicData'].nil?
    @BrokerTopicData = []
    params['BrokerTopicData'].each do |i|
      brokertopicdata_tmp = BrokerTopicData.new
      brokertopicdata_tmp.deserialize(i)
      @BrokerTopicData << brokertopicdata_tmp
    end
  end
  unless params['BrokerTopicFlowData'].nil?
    @BrokerTopicFlowData = []
    params['BrokerTopicFlowData'].each do |i|
      brokertopicflowdata_tmp = BrokerTopicFlowData.new
      brokertopicflowdata_tmp.deserialize(i)
      @BrokerTopicFlowData << brokertopicflowdata_tmp
    end
  end
end

def initialize(topicflow=nil, consumespeed=nil, topicmessageheap=nil, brokerip=nil, brokertopicdata=nil, brokertopicflowdata=nil)
  @TopicFlow = topicflow
  @ConsumeSpeed = consumespeed
  @TopicMessageHeap = topicmessageheap
  @BrokerIp = brokerip
  @BrokerTopicData = brokertopicdata
  @BrokerTopicFlowData = brokertopicflowdata
end