Page History

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); 
}