THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
- DataNode向SchemaRegion拉取元数据(设备全路径)
- SchemaRegion在共识组内同步(SchemaRegion共识组强一致)
- SchemaRegion检查设备/时间序列的schema是否存在,若不存在,在SchemaRegion共识组内创建时间序列(CreateTimeSeriesPlan)
- 向DataNode返回
Coordinator接口定义
Code Block | ||
---|---|---|
| ||
public class DataNodeServiceImpl {
private ServiceProvider ServiceProvider;
private Coordinator coordinator;
public TSStatus executeNonQueryPlan(PhysicalPlan plan, ConsensusGroup groupId);
TSStatus createSchemaRegion(List<Integer> DataNodeID, int schemaRegionID);
TSStatus createDataRegion(List<Integer> DataNodeID, int dataRegionID);
TSStatus createDataPartition(List<Integer> DataNodeID, int dataRegionID, long timeInterval);
TSStatus migrateSchemaRegion(int from, int to, int schemaRegionID);
TSStatus migrateDataRegion(int from, int to, int dataRegionID);
TSStatus migrateDataPartition(); // 碎片清扫时迁移数据分区
// TODO: 查询接口调用
TSStatus executeQueryPlan(Physical plan, ConsensusGroup groupId);
//TODO: 增删节点流程
TSStatus addDataNode(AddDataNodeRequest request);
TSStatus removeDataNode(RemoveDataNodeRequest request);
} |
缓存相关接口
ConfigNode
ClusterRequestHandler
...