THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
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
...