fangzx

Results 2 issues of fangzx

当按频度排序时,对于频度相同的,会按最近考察时间降序; 但当以最近考察时间为排序选项时,对于最近考察时间相同的,并没有按频度降序排列

背景:对于分布式数据库如DMSLogicDB 分布式订阅使用说明: ![image](https://user-images.githubusercontent.com/65332695/135267994-f265950d-9a00-488a-9dad-d2c0f7984249.png) 如上图所示,用户需在`main`方法中设置自己的groupId(任务ID)、dtsInstanceId(任务实例ID)、region、accessKeyId、secret、sid(消费组ID)、username、password、brokerUrl、checkpoint、mapping(是否将物理库表转化为逻辑库表)、subscribeMode、isForceUseInitCheckpoint 等参数,然后启动`main`方法。 若用户需要修改所要订阅的数据类型,可在`buildRecordListener()`方法中进行修改。也可定义自己的消费类(需实现`RecordListener` 接口)。 ![image](https://user-images.githubusercontent.com/65332695/135272162-10a16dec-90b1-4e4b-893e-8a649ffbbb42.png) 程序的大致流程如下: 1. 调用OpenAPI接口DescribeDtsJobs获得所有子任务JobId,然后调用DescribeSubscriptionMeta接口获得所有子任务的sid、任务名、dbList。 2. 使用上一步获得的dbList初始化库表映射类DBMapper。 3. 新建DistributedConsumer类,使用之前获得的子任务参数对其进行初始化后调用其start方法。consumer会为每一个topic新建一个DTSConsumer并在线程池中启动它们。DTSConsumer监听到订阅的数据变更后调用`buildRecordListener`进行消费。 消息位点管理、统计信息和问题排查与普通订阅一致。用户可为所有topic指定同一个消息位点,也可为不同的topic指定不同消息位点。 架构如下: ![image](https://user-images.githubusercontent.com/65332695/128682910-5a545339-2bb2-4d26-ada3-5d1c2a39b5df.png) ![image](https://user-images.githubusercontent.com/65332695/128682883-25f9c4d7-dc6b-46b8-80e6-c2e55c455c36.png)