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