Coordinator

coordinator主要与ClusterPlanRouter和ClusterPlanExecutor进行交互,接收和处理thrift模块的rpc调用

物理计划类型

转发至ConfigNode

  • 建/删除存储组

  • 创建/删除TTL

  • 创建/删除时间序列

  • 配置加载(loadConfigurationPlan

  • 权限相关

  • 创建/删除模板(待定

  • 创建/删除udf

  • 设置系统模式

  • 创建快照

  • MergePlan/FlushPlan/ClearCachePlan(由ConfigNode发送给所有DataRegion)

该部分操作需要首先转发给Config集群,之后根据Config集群节点返回结果进行后续处理


本地执行操作

  • LoadDataPlan

  • OperateFilePlan

  • KillQueryPlan

  • local的LoadConfigurationPlan

该类操作无需转发,直接在本地执行


常规写入操作

  • 所有insertPlan(InsertRowPlan, InsertRowsPlan, InsertRowsOfOneDevice, InsertTablet, InsertMultiTablet)

  • AlterTimeseries


该部分操作首先需要根据分区表对写入操作进行拆分,之后发送给对应的DataRegion,流程参考上面的给出的写入流程。


查询操作(Query)

查询操作通常需要进行拆分和结果集的合并,这里不多做赘述,输入到coordinator中处理的查询应当是以物理计划的形式。

数据/元数据分片和负载均衡相关的物理计划(未整理)



  • No labels