You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ji...@apache.org on 2020/04/15 09:02:06 UTC
[incubator-iotdb] branch cluster_new updated (2689f43 -> df69d21)
This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch cluster_new
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git.
from 2689f43 start fixing fill
add df69d21 re-implement fill
No new revisions were added by this update.
Summary of changes:
.../1586940435029_-1335866411789719126.task} | Bin
.../1586940435029_-2737085648255529731.task} | Bin
.../1586940435029_3296565635904276337.task} | Bin 457 -> 457 bytes
.../1586940435029_6664967357388808309.task} | Bin
.../1586940435030_43467939819933913.task} | Bin
.../1586940435031_-3424487114509171272.task} | Bin
.../1586940435031_-6885643537939946750.task} | Bin
.../1586940435031_682888198294754342.task} | Bin
...task => 1586940426691_4032688694543822688.task} | Bin
...task => 1586940426649_2126670600386653664.task} | Bin
...ask => 1586940426600_-2089738869783160680.task} | Bin
...ask => 1586940426563_-6578077170713510872.task} | Bin
...task => 1586940426522_3842087510909341589.task} | Bin
...task => 1586940426497_3581948045191171736.task} | Bin
...ask => 1586940431695_-7992161623633871495.task} | Bin
.../apache/iotdb/cluster/config/ClusterConfig.java | 10 +++
.../iotdb/cluster/config/ClusterDescriptor.java | 4 +
...ndException.java => QueryTimeOutException.java} | 6 +-
.../cluster/query/fill/ClusterFillExecutor.java | 11 +++
...terFillExecutor.java => ClusterLinearFill.java} | 33 ++++---
...rFillExecutor.java => ClusterPreviousFill.java} | 35 ++++----
.../iotdb/cluster/server/DataClusterServer.java | 8 ++
.../apache/iotdb/cluster/server/RaftServer.java | 2 +
.../handlers/caller/PreviousFillHandler.java | 85 ++++++++++++++++++
.../cluster/server/member/DataGroupMember.java | 52 +++++++++++
.../cluster/server/member/MetaGroupMember.java | 100 +++++++++++++++++++++
.../apache/iotdb/cluster/utils/SerializeUtils.java | 72 ++++++++++++++-
.../java/org/apache/iotdb/db/query/fill/IFill.java | 8 +-
.../org/apache/iotdb/db/query/fill/LinearFill.java | 4 +-
.../apache/iotdb/db/query/fill/PreviousFill.java | 17 ++--
service-rpc/src/main/thrift/cluster.thrift | 16 ++++
31 files changed, 414 insertions(+), 49 deletions(-)
copy cluster/raft/{-1495197964/snapshot_task/1586835986280_-3320494564920408745.task => -1390748669/snapshot_task/1586940435029_-1335866411789719126.task} (100%)
copy cluster/raft/{-1495197964/snapshot_task/1586835986281_8171546385281388961.task => -1390748669/snapshot_task/1586940435029_-2737085648255529731.task} (100%)
copy cluster/raft/{-1476006343/snapshot_task/1586855177260_-5966149551635805162.task => -1390748669/snapshot_task/1586940435029_3296565635904276337.task} (97%)
copy cluster/raft/{-1495197964/snapshot_task/1586835986281_-948823018901582853.task => -1390748669/snapshot_task/1586940435029_6664967357388808309.task} (100%)
copy cluster/raft/{-1495197964/snapshot_task/1586835986281_4470132570545107636.task => -1390748669/snapshot_task/1586940435030_43467939819933913.task} (100%)
copy cluster/raft/{-1495197964/snapshot_task/1586835986281_8967413450799695062.task => -1390748669/snapshot_task/1586940435031_-3424487114509171272.task} (100%)
copy cluster/raft/{-1495197964/snapshot_task/1586835986281_-656359249422795972.task => -1390748669/snapshot_task/1586940435031_-6885643537939946750.task} (100%)
copy cluster/raft/{-1495197964/snapshot_task/1586835986281_-4671456328859670553.task => -1390748669/snapshot_task/1586940435031_682888198294754342.task} (100%)
copy cluster/raft/20/snapshot_task/{1586855169548_4741845169826760313.task => 1586940426691_4032688694543822688.task} (100%)
copy cluster/raft/30/snapshot_task/{1586855169540_-6658772559513582825.task => 1586940426649_2126670600386653664.task} (100%)
copy cluster/raft/40/snapshot_task/{1586855169531_-3309812358258853569.task => 1586940426600_-2089738869783160680.task} (100%)
copy cluster/raft/50/snapshot_task/{1586855169521_1095023885222012287.task => 1586940426563_-6578077170713510872.task} (100%)
copy cluster/raft/60/snapshot_task/{1586855169513_-2615850524724134501.task => 1586940426522_3842087510909341589.task} (100%)
copy cluster/raft/70/snapshot_task/{1586855173927_-1803686077397573050.task => 1586940426497_3581948045191171736.task} (100%)
copy cluster/raft/70/snapshot_task/{1586855173927_-1803686077397573050.task => 1586940431695_-7992161623633871495.task} (100%)
copy cluster/src/main/java/org/apache/iotdb/cluster/exception/{ReaderNotFoundException.java => QueryTimeOutException.java} (82%)
copy cluster/src/main/java/org/apache/iotdb/cluster/query/fill/{ClusterFillExecutor.java => ClusterLinearFill.java} (59%)
copy cluster/src/main/java/org/apache/iotdb/cluster/query/fill/{ClusterFillExecutor.java => ClusterPreviousFill.java} (57%)
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/PreviousFillHandler.java