Page History

...

• 1.coordinator checks whether PT cache can process the request (and may pull cache)
• 1.if not exist, then pull cache attached a update request to PT Group.
• 2.if the SG exists in the PT but the time range does not exist, then need to send update to PT Group.
• 2.sends to corresponding data partition (not group) leader, i.e., Node B in the figure.
• 3.Tips: A data partition may have  several raft groups (= SG * virtual SG, now)
• 4.for each operation in B, check whether B is its corresponding raft group leader, if not, forward to the leader (this is just a temporary solution, will redesign finally)
• 5.For each operation received by the raft group leader (may B, or C …), if it has no schema locally, then forward “Create TS” to corresponding data partition/group leader.
  (May receives “already exist”, which means this node begins to process a new time range of the TS. May receives “create success”, which means this TS is new.  Update local Mmanager. 
• 6.call raft for replica.
• 7.execute.

4.10 Query givenTSs

• 1.coordinator checks whether PT cache can process the request (and may pull cache)
  • 1.if not exist, then pull cache attached a update request to PT Group.
  • 2.if the SG exists in the PT but the time range does not exist, then need to send update to PT Group.
• 2.sends to corresponding data partition (not group) leader (if weak consistency, follower is also ok), i.e., Node B in the figure.
• 3.Tips: A data partition may have  several raft groups (= SG * virtual SG, now)
• 4.for each operation in B, check whether to call raft replica according to the consistency
• 5.Run locally. 

Image Added

4.11 Query fuzzy TSs

• 1.coordinator checks whether PT cache can process the request
  • 1.if not, then the PT group returns the result, and the coordinator pulls cache.
  • 2.if ok, then the coordinator calculate the result locally.
• 2.sends to corresponding data partition (not group) leader (if weak consistency, follower is also ok), i.e., Node B in the figure.
• 3.Tips: A data partition may have  several raft groups (= SG * virtual SG, now)
• 4.for each operation in B, check whether to call raft replica according to the consistency
• 5.Run locally.