class TencentCloud::Ckafka::V20190819::ClickHouseParam

def deserialize(params)
  @Cluster = params['Cluster']
  @Database = params['Database']
  @Table = params['Table']
  unless params['Schema'].nil?
    @Schema = []
    params['Schema'].each do |i|
      clickhouseschema_tmp = ClickHouseSchema.new
      clickhouseschema_tmp.deserialize(i)
      @Schema << clickhouseschema_tmp
    end
  end
  @Resource = params['Resource']
  @Ip = params['Ip']
  @Port = params['Port']
  @UserName = params['UserName']
  @Password = params['Password']
  @ServiceVip = params['ServiceVip']
  @UniqVpcId = params['UniqVpcId']
  @SelfBuilt = params['SelfBuilt']
  @DropInvalidMessage = params['DropInvalidMessage']
  @Type = params['Type']
  unless params['DropCls'].nil?
    @DropCls = DropCls.new
    @DropCls.deserialize(params['DropCls'])
  end
  @BatchSize = params['BatchSize']
  @ConsumerFetchMinBytes = params['ConsumerFetchMinBytes']
  @ConsumerFetchMaxWaitMs = params['ConsumerFetchMaxWaitMs']
end

def initialize(cluster=nil, database=nil, table=nil, schema=nil, resource=nil, ip=nil, port=nil, username=nil, password=nil, servicevip=nil, uniqvpcid=nil, selfbuilt=nil, dropinvalidmessage=nil, type=nil, dropcls=nil, batchsize=nil, consumerfetchminbytes=nil, consumerfetchmaxwaitms=nil)
  @Cluster = cluster
  @Database = database
  @Table = table
  @Schema = schema
  @Resource = resource
  @Ip = ip
  @Port = port
  @UserName = username
  @Password = password
  @ServiceVip = servicevip
  @UniqVpcId = uniqvpcid
  @SelfBuilt = selfbuilt
  @DropInvalidMessage = dropinvalidmessage
  @Type = type
  @DropCls = dropcls
  @BatchSize = batchsize
  @ConsumerFetchMinBytes = consumerfetchminbytes
  @ConsumerFetchMaxWaitMs = consumerfetchmaxwaitms
end