You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2022/10/20 01:42:20 UTC
[iotdb] branch re-ext-lib updated (76d5a898df -> 99248c68cc)
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch re-ext-lib
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 76d5a898df refactor seriesNumberMonitor and additional properties, cherry pick from rel/0.13
add 127263dd3b [IOTDB-4627]Trigger transfer (#7643)
add f2ffb494a2 Perfect add/remove confignode process (#7656)
add 80dca5c7bb [IOTDB-4688] use streaming md5 computing to replace blocking md5
add b20f49525e [IOTDB-4689] Use seperate channel for heartbeat / appendEntries
add 88903b3189 Make default timeout parameter in SessionIT from 1s to 60s (#7647)
add fd8ced4f07 [IOTDB-4690] Add new configs for RatisConsensus (2.4.0)
add 723ecb42cf [IOTDB-4534] Add IT for Trigger Execution (#7657)
add 99248c68cc Merge branch 'master' into re-ext-lib
No new revisions were added by this update.
Summary of changes:
.gitignore | 1 +
.../resources/conf/iotdb-confignode.properties | 9 +
.../confignode/client/DataNodeRequestType.java | 1 +
.../client/async/AsyncDataNodeClientPool.java | 7 +
.../client/async/handlers/AsyncClientHandler.java | 1 +
.../iotdb/confignode/conf/ConfigNodeConfig.java | 50 +++
.../confignode/conf/ConfigNodeDescriptor.java | 30 ++
.../confignode/conf/ConfigNodeRemoveCheck.java | 4 +-
.../confignode/conf/SystemPropertiesUtils.java | 2 +-
.../consensus/request/ConfigPhysicalPlan.java | 12 +
.../consensus/request/ConfigPhysicalPlanType.java | 5 +-
...ePlan.java => GetTransferringTriggersPlan.java} | 8 +-
.../request/read/GetTriggerTablePlan.java | 22 +-
...blePlan.java => UpdateTriggerLocationPlan.java} | 31 +-
.../UpdateTriggersOnTransferNodesPlan.java} | 75 ++---
...InfoResp.java => TransferringTriggersResp.java} | 22 +-
.../iotdb/confignode/manager/ConfigManager.java | 38 ++-
.../iotdb/confignode/manager/ConsensusManager.java | 12 +-
.../apache/iotdb/confignode/manager/IManager.java | 3 +
.../iotdb/confignode/manager/TriggerManager.java | 93 +++++-
.../iotdb/confignode/manager/node/NodeManager.java | 43 ++-
.../iotdb/confignode/persistence/TriggerInfo.java | 50 ++-
.../persistence/executor/ConfigPlanExecutor.java | 13 +-
.../confignode/procedure/ProcedureExecutor.java | 2 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 3 -
.../procedure/impl/CreateTriggerProcedure.java | 5 +-
.../iotdb/confignode/service/ConfigNode.java | 7 +-
.../confignode/service/ConfigNodeCommandLine.java | 5 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 5 +
.../request/ConfigPhysicalPlanSerDeTest.java | 72 ++++-
.../apache/iotdb/consensus/config/RatisConfig.java | 55 +++-
.../ratis/FileInfoWithDelayedMd5Computing.java | 75 -----
.../iotdb/consensus/ratis/RatisConsensus.java | 7 +-
.../iotdb/consensus/ratis/SnapshotStorage.java | 2 +-
.../org/apache/iotdb/consensus/ratis/Utils.java | 8 +
.../org/apache/iotdb/trigger/LoggerTrigger.java | 86 ++++++
integration-test/import-control.xml | 2 +-
.../trigger/example/TriggerFireTimesCounter.java | 87 ++++++
.../db/it/trigger/IoTDBTriggerExecutionIT.java | 265 ++++++++++++++++
.../iotdb/session/it/IoTDBSessionInsertNulIT.java | 2 +-
.../IoTDBSessionInsertWithTriggerExecutionIT.java | 337 +++++++++++++++++++++
.../src/test/resources/TriggerFireTimesCounter.jar | Bin 0 -> 1324 bytes
.../apache/iotdb/commons/trigger/TriggerTable.java | 40 +++
.../apache/iotdb/db/client/ConfigNodeClient.java | 16 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 40 +++
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 6 +
.../db/consensus/DataRegionConsensusImpl.java | 10 +
.../db/consensus/SchemaRegionConsensusImpl.java | 10 +
.../db/mpp/common/header/ColumnHeaderConstant.java | 4 +-
.../db/mpp/plan/execution/QueryExecution.java | 17 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 4 -
.../impl/DataNodeInternalRPCServiceImpl.java | 17 ++
.../db/trigger/executor/TriggerFireVisitor.java | 7 +-
.../trigger/service/TriggerManagementService.java | 38 ++-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../src/main/thrift/confignode.thrift | 15 +-
thrift/src/main/thrift/datanode.thrift | 12 +
57 files changed, 1557 insertions(+), 237 deletions(-)
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{GetTriggerTablePlan.java => GetTransferringTriggersPlan.java} (83%)
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/trigger/{UpdateTriggerStateInTablePlan.java => UpdateTriggerLocationPlan.java} (63%)
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{RemoveDataNodePlan.java => trigger/UpdateTriggersOnTransferNodesPlan.java} (54%)
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{PathInfoResp.java => TransferringTriggersResp.java} (66%)
delete mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/ratis/FileInfoWithDelayedMd5Computing.java
create mode 100644 example/trigger/src/main/java/org/apache/iotdb/trigger/LoggerTrigger.java
create mode 100644 integration-test/src/main/java/org/apache/iotdb/db/trigger/example/TriggerFireTimesCounter.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/trigger/IoTDBTriggerExecutionIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/session/it/IoTDBSessionInsertWithTriggerExecutionIT.java
create mode 100644 integration-test/src/test/resources/TriggerFireTimesCounter.jar