Page History

写入部分 Coordinator 需要的接口

与configNode交互

// 获取分区信息

List<Integer> getDataPartition(String deviceId)

// 获取DataRegionID

DataRegionID getDataRegion(String deviceId)

 public GetSchemaPartitionResp getSchemaPartition(GetSchemaPartitionReq req); 
 
 public GetDataPartitionResp getDataPartition(GetDataPartitionReq req);

//元数据查询 

 List<Pair<String, Long>> lookupStorageGroups(String pattern); //查询pattern对应存储组
 
List<Pair<Long, Node>> lookupSchemaRegions(String pattern); //查询pattern的所有schemaRegion及对应leader

List<Pair<Long, Node>> lookupDataRegions(String pattern, TimeInterval t); //查询pattern及时间范围t对应的DataRegion和对应leader

与DataNodeNode交互

// 向 SchemaRegion 获取元数据信息

void getSeriesSchemas(InsertPlan plan(String pattern)

//转发Physical plan

TSStatus executeNonQueryPlanInDataRegion(PhysicalPlan plan, int dataRegionId)

TSStatus executeNonQueryPlanInSchemaRegion(PhysicalPlan plan, int schemaRegionId)

TSStatus executeQueryStatement()

Standalone Coordinator 执行过程

Standalone Coordinater 收到 InsertPlan 之后

...