以前有简单介绍过dremio 的DACModule 模块,核心就是进行服务的启动以及依赖管理维护,接口实现了包含了bootstrap 以及build
区别在于bootstrap管理的是一些需要提前准备好的服务(比如协调服务,master 选举服务,还有就是一些引擎相关的,但是社区版没有实现)
bootstrap 依赖服务
bootstrap 依赖的服务很少,MasterElectionService 会依赖协调服务,RequestContext 会依赖租户以及一些项目信息
- ClusterCoordinator
都是自己创建的,对于不同的环境会需要不同的,包含了嵌入式zk,外部zk 以及无master 模式的
我们一般使用的是嵌入式(单机模式)以及外部zk(集群模式) - MasterElectionService
MasterElectionService 会依赖协调服务进行master 选举处理
public MasterElectionService(Provider<ClusterCoordinator> clusterCoordinator) {
this.clusterCoordinator = Preconditions.checkNotNull(clusterCoordinator);
}
- EngineId 以及SubEngineId
此实现社区版为空,对于企业版以及cloud 此功能是一个很强大的能力,可以让我们自己选择不同的执行引擎,具体使用的地方包含了执行器选择(ExecutorSelectionServiceImpl)我们可以自己扩展实现类似的能力 - RequestContext
实际上应该是一个请求级别的服务,但是目前官方对于社区版的实现是直接固定了几个值,当然也是可以扩展的,方便更好的支持租户以及项目的能力
官方的实现基于了threadlocal 进行数据存储
说明
以上是一个简单的关于DACModule bootstrap 方法的介绍,同时服务模块依赖关系的学习,我们可以更好的学习dremio 模块的关系以及进行扩展
参考资料
dac/backend/src/main/java/com/dremio/dac/daemon/DACModule.java
dac/backend/src/main/java/com/dremio/dac/daemon/DACDaemonModule.java
sabot/kernel/src/main/java/com/dremio/exec/server/ContextService.java
common/src/main/java/com/dremio/context/RequestContext.java
dac/backend/src/main/java/com/dremio/dac/service/exec/MasterElectionService.java
services/exec-selector/src/main/java/com/dremio/service/execselector/ExecutorSelectionServiceImpl.java
services/exec-selector/src/main/java/com/dremio/service/execselector/ExecutorSelectionServiceImpl.java