lxhjava的博客

待整理和完善。。。 org.apache.druid.cli.Main --> CliBroker getModules()–> BrokerQueryResource.getQueryTargets() –> 1.List ServerViewUtil.getTargetLocations(BrokerServerView,datasource,interval,…) 获取segmentLocation, 2.ResourceIOReaderWriter.ok()读取segment

1.梳理druid预聚合逻辑 摄取预聚合主逻辑： KafkaRecordSupplier.poll() --> IncrementalPublishingKafkaIndexTaskRunner.getRecords() --> SeekableStreamIndexTaskRunner.getRecords() --> StreamAppenderatorDriver.add(record) --> BaseAppenderatorDriver.append() --> ..

#若没有添加远程地址，则添加，取名如upgrade git remote add upgrade https://github.com/apache/druid.git 拉取远程最新代码upgrade代码 git fetch upgrade #查看修改文件状态信息 git status 添加修改且准备提交的文件 git add filename1 filename2 提交并注释 git commit -m “upgrade” 和并远程代码到本地master git merge upgrade/master