class TencentCloud::Wedata::V20210820::TaskTableMetricInfo
任务表粒度指标信息
def deserialize(params)
def deserialize(params) @DatabaseName = params['DatabaseName'] @TableName = params['TableName'] @TotalRecordNum = params['TotalRecordNum'] @TotalRecordByteNum = params['TotalRecordByteNum'] @TotalDirtyRecordNum = params['TotalDirtyRecordNum'] @SchemaName = params['SchemaName'] @Topic = params['Topic'] @Collection = params['Collection'] @DataSourceName = params['DataSourceName'] @NodeId = params['NodeId'] @LogicDatabase = params['LogicDatabase'] @LogicTable = params['LogicTable'] @LogicSchema = params['LogicSchema'] unless params['TaskTableMetricInfos'].nil? @TaskTableMetricInfos = [] params['TaskTableMetricInfos'].each do |i| tasktablemetricinfo_tmp = TaskTableMetricInfo.new tasktablemetricinfo_tmp.deserialize(i) @TaskTableMetricInfos << tasktablemetricinfo_tmp end end @SyncStatus = params['SyncStatus'] @TargetDatabaseName = params['TargetDatabaseName'] @TargetTableName = params['TargetTableName'] @WriteTotalRecordNum = params['WriteTotalRecordNum'] @WriteTotalRecordByteNum = params['WriteTotalRecordByteNum'] @TargetSchemaName = params['TargetSchemaName'] @TargetTopic = params['TargetTopic'] @TargetCollection = params['TargetCollection'] @TargetDataSourceName = params['TargetDataSourceName'] @TargetNodeId = params['TargetNodeId'] @TotalRecordSpeed = params['TotalRecordSpeed'] @WriteTotalRecordSpeed = params['WriteTotalRecordSpeed'] @ExceptionReason = params['ExceptionReason'] end
def initialize(databasename=nil, tablename=nil, totalrecordnum=nil, totalrecordbytenum=nil, totaldirtyrecordnum=nil, schemaname=nil, topic=nil, collection=nil, datasourcename=nil, nodeid=nil, logicdatabase=nil, logictable=nil, logicschema=nil, tasktablemetricinfos=nil, syncstatus=nil, targetdatabasename=nil, targettablename=nil, writetotalrecordnum=nil, writetotalrecordbytenum=nil, targetschemaname=nil, targettopic=nil, targetcollection=nil, targetdatasourcename=nil, targetnodeid=nil, totalrecordspeed=nil, writetotalrecordspeed=nil, exceptionreason=nil)
def initialize(databasename=nil, tablename=nil, totalrecordnum=nil, totalrecordbytenum=nil, totaldirtyrecordnum=nil, schemaname=nil, topic=nil, collection=nil, datasourcename=nil, nodeid=nil, logicdatabase=nil, logictable=nil, logicschema=nil, tasktablemetricinfos=nil, syncstatus=nil, targetdatabasename=nil, targettablename=nil, writetotalrecordnum=nil, writetotalrecordbytenum=nil, targetschemaname=nil, targettopic=nil, targetcollection=nil, targetdatasourcename=nil, targetnodeid=nil, totalrecordspeed=nil, writetotalrecordspeed=nil, exceptionreason=nil) @DatabaseName = databasename @TableName = tablename @TotalRecordNum = totalrecordnum @TotalRecordByteNum = totalrecordbytenum @TotalDirtyRecordNum = totaldirtyrecordnum @SchemaName = schemaname @Topic = topic @Collection = collection @DataSourceName = datasourcename @NodeId = nodeid @LogicDatabase = logicdatabase @LogicTable = logictable @LogicSchema = logicschema @TaskTableMetricInfos = tasktablemetricinfos @SyncStatus = syncstatus @TargetDatabaseName = targetdatabasename @TargetTableName = targettablename @WriteTotalRecordNum = writetotalrecordnum @WriteTotalRecordByteNum = writetotalrecordbytenum @TargetSchemaName = targetschemaname @TargetTopic = targettopic @TargetCollection = targetcollection @TargetDataSourceName = targetdatasourcename @TargetNodeId = targetnodeid @TotalRecordSpeed = totalrecordspeed @WriteTotalRecordSpeed = writetotalrecordspeed @ExceptionReason = exceptionreason end