THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
写入流程图
写入接口
InsertRow
该接口用于写入一个设备中的一行数据（多个物理量），可以写入对齐或非对齐的物理量。
...
- 客户端C连接集群内任意DataNode A发送写入请求
- 如果A的ClientRequestHandler接收到写入请求，使用planner转为物理计划InsertRowPlan，传递给Coordinator处理
- A在Coordinator中使用ClusterPlanRouter对写入请求进行路由
- ClusterPlanRouter根据device和时间戳计算出对应的数据分片
- 若本地没有该数据分片的数据分区表缓存，向ConfigNode共识组中的节点N发送
- 本地没有当前写入数据的分区表缓存，向ConfigNode共识组中的节点N发送数据分片（存储组，设备组，时间分片编号）
- 找到此数据对应的数据分区
- 找到此数据分区对应的 List<VSG 共识组>，选择最后一个作为写入的 VSG
- 如果此数据分区未分配 VSG 共识组，则分配一个 VSG 共识组
- 找到此 VSG 共识组对应的一组 DataNode 并返回
- 如果此 VSG 共识组没有分配 DataNode，则分配一组 DataNode，并在 DataNode 上初始化共识组
- A缓存数据分区的信息
- 根据路由结果，将写入的物理计划转发给B，并携带VSG共识组信息
- B的ClusterRequestHandler接收来自A的物理计划，转给Coordinator处理
- B在Coordinator传递给本地VSG执行
- VSG若发现本地没有写入序列的元数据，则检查此次写入的序列是否已经在集群注册
- 首先B通过MetaPuller去远程拉去元数据
- MetaPuller检查本地是否有当前存储组的元数据分区表缓存，若没有则向 ConfigNode 共识组发请求，查找写入点的元数据所在的 MManager 及所在的 DataNode D
- B 缓存分区信息，并根据该信息将写入的序列及推断类型发送至 MManager
- 如果 MManager 不存在此序列，将这些序列注册到 MManager（自动注册schema）
- 如果存在，进行数据类型校验（存在且一致、存在且不一致），接着返回数据类型，编码等序列级别的元信息
- B根据MManager 返回的信息决定抛错或者在本地注册不存在序列的元数据
- 若元数据拉取成功，B在vsg中缓存元数据
- 首先B通过MetaPuller去远程拉去元数据
- B将请求发送给共识模块，调用consensusLayer中的write方法，写入成功后返回
InsertRows
该接口用于批量写入，将多个Row请求通过一次rpc来进行执行，不支持写入的原子性，在返回结果中包含哪些行被成功写入。
InsertTablet
该接口用于写入一个设备中的多个数据点，每个数据点包含设备中的物理量以及对应的时间戳和值，推荐使用该方法进行写入。
InsertMultiTablets
该接口用于批量写入，将多个Tablet请求通过一次rpc来执行，不支持写入的原子性，在返回结果中包含哪些行被成功写入。
InsertRowsOfOneDevice
该接口用于同一个设备下的多行写入，相比于InsertRows，减少了devicePath的重复网络传输开销。