fangzx
fangzx
当按频度排序时,对于频度相同的,会按最近考察时间降序; 但当以最近考察时间为排序选项时,对于最近考察时间相同的,并没有按频度降序排列
背景:对于分布式数据库如DMSLogicDB 分布式订阅使用说明:  如上图所示,用户需在`main`方法中设置自己的groupId(任务ID)、dtsInstanceId(任务实例ID)、region、accessKeyId、secret、sid(消费组ID)、username、password、brokerUrl、checkpoint、mapping(是否将物理库表转化为逻辑库表)、subscribeMode、isForceUseInitCheckpoint 等参数,然后启动`main`方法。 若用户需要修改所要订阅的数据类型,可在`buildRecordListener()`方法中进行修改。也可定义自己的消费类(需实现`RecordListener` 接口)。  程序的大致流程如下: 1. 调用OpenAPI接口DescribeDtsJobs获得所有子任务JobId,然后调用DescribeSubscriptionMeta接口获得所有子任务的sid、任务名、dbList。 2. 使用上一步获得的dbList初始化库表映射类DBMapper。 3. 新建DistributedConsumer类,使用之前获得的子任务参数对其进行初始化后调用其start方法。consumer会为每一个topic新建一个DTSConsumer并在线程池中启动它们。DTSConsumer监听到订阅的数据变更后调用`buildRecordListener`进行消费。 消息位点管理、统计信息和问题排查与普通订阅一致。用户可为所有topic指定同一个消息位点,也可为不同的topic指定不同消息位点。 架构如下:  