This is an automated email from the ASF dual-hosted git repository. haonan pushed a commit to branch rel/0.14.0-preview2 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 4ef8fde63b955b580970c467dfc4a0cd8f3c8a2b Merge: efbd55110f ecaa0f2af3 Author: HTHou <[email protected]> AuthorDate: Wed Sep 7 10:21:44 2022 +0800 Merge branch 'master' of https://github.com/apache/iotdb into rel/0.14.0-preview2 RELEASE_NOTES.md | 2 - .../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 2 + .../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 6 +- .../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 8 + .../request/write/CreateRegionGroupsPlan.java | 10 + .../iotdb/confignode/persistence/UDFInfo.java | 4 +- .../impl/CreateRegionGroupsProcedure.java | 85 ++- .../procedure/state/RemoveConfigNodeState.java | 3 +- .../procedure/store/ProcedureFactory.java | 10 + .../service/thrift/ConfigNodeRPCService.java | 6 +- .../thrift/ConfigNodeRPCServiceProcessor.java | 7 + .../impl/CreateRegionGroupsProcedureTest.java | 110 ++++ .../apache/iotdb/consensus/config/RatisConfig.java | 59 +- .../consensus/exception/NodeReadOnlyException.java | 15 +- .../multileader/service/MultiLeaderRPCService.java | 4 +- .../iotdb/consensus/ratis/RatisConsensus.java | 87 ++- docs/Download/README.md | 28 +- docs/UserGuide/API/Status-Codes.md | 3 +- docs/UserGuide/Process-Data/Triggers.md | 2 +- docs/UserGuide/Query-Data/Last-Query.md | 18 +- docs/zh/Download/README.md | 28 +- docs/zh/UserGuide/API/Status-Codes.md | 3 +- .../{Flink TsFile.md => Flink-TsFile.md} | 0 .../{Grafana Plugin.md => Grafana-Plugin.md} | 0 .../{Spark TsFile.md => Spark-TsFile.md} | 0 docs/zh/UserGuide/Process-Data/Triggers.md | 2 +- docs/zh/UserGuide/Query-Data/Last-Query.md | 18 +- .../org/apache/iotdb/trigger/AlertingExample.java | 2 +- .../org/apache/iotdb/trigger/TriggerExample.java | 2 +- .../java/org/apache/iotdb/db/it/IoTDBFilterIT.java | 119 ++++ .../org/apache/iotdb/db/it/IoTDBNestedQueryIT.java | 2 +- .../{IoTDBPipeSinkIT.java => IoTDBPipeIT.java} | 82 ++- .../apache/iotdb/db/it/sync/IoTDBPipeSinkIT.java | 4 +- .../db/engine/trigger/example/Accumulator.java | 2 +- .../iotdb/db/engine/trigger/example/Counter.java | 2 +- .../db/integration/sync/IoTDBSyncSenderIT.java | 1 + .../iotdb/session/IoTDBSessionInsertNullT.java | 298 +++++++++ node-commons/pom.xml | 5 + .../iotdb/commons/client/ClientPoolFactory.java | 6 +- .../sync/SyncThriftClientWithErrorHandler.java | 6 +- .../iotdb/commons/concurrent/ThreadName.java | 62 +- .../commons/executable/ExecutableManager.java | 115 ++++ .../ExecutableResource.java} | 6 +- .../iotdb/commons/file/SystemFileFactory.java | 11 + .../apache/iotdb/commons/service/ServiceType.java | 4 +- .../apache/iotdb/commons/sync/SyncConstant.java | 4 +- .../iotdb/commons/trigger/TriggerInformation.java | 157 +++++ .../apache/iotdb/commons/trigger/TriggerTable.java | 64 ++ .../exception/TriggerExecutionException.java | 13 +- .../exception/TriggerRegistrationException.java | 13 +- .../trigger/service/TriggerClassLoader.java | 4 +- .../service/TriggerClassLoaderManager.java} | 74 +-- .../service/TriggerRegistrationService.java | 89 +++ .../commons/udf/service/UDFClassLoaderManager.java | 12 +- .../commons/udf/service/UDFExecutableManager.java | 108 +--- .../udf/service/UDFRegistrationService.java | 3 +- .../client/mock/MockInternalRPCService.java | 4 +- pom.xml | 1 + .../resources/conf/iotdb-datanode.properties | 9 + .../org/apache/iotdb/db/auth/AuthorityChecker.java | 6 +- .../apache/iotdb/db/client/ConfigNodeClient.java | 17 + .../iotdb/db/client/DataNodeClientPoolFactory.java | 16 +- .../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 25 + .../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 12 + .../apache/iotdb/db/engine/StorageEngineV2.java | 6 + .../iotdb/db/engine/snapshot/SnapshotLoader.java | 8 + .../iotdb/db/engine/storagegroup/DataRegion.java | 21 +- .../db/engine/storagegroup/TsFileManager.java | 14 +- .../db/engine/storagegroup/TsFileProcessor.java | 24 +- .../dataregion/StorageGroupManager.java | 10 - .../iotdb/db/engine/trigger/api/Trigger.java | 1 + .../db/engine/trigger/builtin/ForwardTrigger.java | 2 +- .../engine/trigger/executor/TriggerExecutor.java | 4 +- .../trigger/service/TriggerClassLoaderManager.java | 1 + .../service/TriggerRegistrationService.java | 3 +- .../iotdb/db/localconfignode/LocalConfigNode.java | 65 +- .../schemaregion/SchemaRegionMemoryImpl.java | 11 - .../schemaregion/SchemaRegionSchemaFileImpl.java | 11 - .../db/mpp/common/header/ColumnHeaderConstant.java | 17 + .../db/mpp/common/header/DatasetHeaderFactory.java | 4 + .../execution/exchange/MPPDataExchangeManager.java | 1 + .../execution/exchange/MPPDataExchangeService.java | 6 +- .../db/mpp/execution/exchange/SinkHandle.java | 3 +- .../db/mpp/execution/exchange/SourceHandle.java | 7 +- .../iotdb/db/mpp/plan/constant/StatementType.java | 2 +- .../plan/execution/config/ConfigTaskVisitor.java | 15 +- .../config/executor/ClusterConfigTaskExecutor.java | 41 +- .../config/executor/IConfigTaskExecutor.java | 19 +- .../executor/StandaloneConfigTaskExecutor.java | 92 ++- .../config/metadata/CreateTriggerTask.java | 8 +- .../DropTriggerTask.java} | 15 +- .../execution/config/sys/sync/CreatePipeTask.java | 4 +- .../execution/config/sys/sync/DropPipeTask.java | 4 +- .../execution/config/sys/sync/ShowPipeTask.java | 41 +- .../execution/config/sys/sync/StartPipeTask.java | 4 +- .../execution/config/sys/sync/StopPipeTask.java | 4 +- .../iotdb/db/mpp/plan/parser/ASTVisitor.java | 23 + .../db/mpp/plan/statement/StatementVisitor.java | 5 + .../statement/metadata/CreateTriggerStatement.java | 26 + .../DropTriggerStatement.java} | 57 +- .../statement/sys/sync/CreatePipeStatement.java | 38 ++ .../binary/CompareBinaryColumnTransformer.java | 12 +- .../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 36 +- .../iotdb/db/protocol/mqtt/PublishHandler.java | 39 +- .../iotdb/db/query/control/SessionManager.java | 16 +- .../db/service/DataNodeInternalRPCService.java | 6 +- .../iotdb/db/service/InfluxDBRPCService.java | 4 +- .../org/apache/iotdb/db/service/RPCService.java | 8 +- .../impl/DataNodeInternalRPCServiceImpl.java | 7 + .../java/org/apache/iotdb/db/sync/SyncService.java | 95 +++ .../iotdb/db/sync/common/ISyncInfoFetcher.java | 5 +- .../iotdb/db/sync/common/LocalSyncInfoFetcher.java | 19 +- .../org/apache/iotdb/db/sync/common/SyncInfo.java | 35 +- .../db/sync/common/persistence/SyncLogReader.java | 8 +- .../db/sync/common/persistence/SyncLogWriter.java | 17 +- .../iotdb/db/sync/receiver/load/TsFileLoader.java | 54 +- .../iotdb/db/sync/sender/manager/ISyncManager.java | 33 +- .../db/sync/sender/manager/LocalSyncManager.java | 90 +++ .../db/sync/sender/manager/SchemaSyncManager.java | 149 ----- .../db/sync/sender/manager/TsFileSyncManager.java | 106 ---- .../org/apache/iotdb/db/sync/sender/pipe/Pipe.java | 12 + .../iotdb/db/sync/sender/pipe/TsFilePipe.java | 144 ++--- .../db/sync/transport/client/SenderManager.java | 1 - .../apache/iotdb/db/utils/ErrorHandlingUtils.java | 8 +- .../apache/iotdb/db/utils/sync/SyncPipeUtil.java | 47 ++ .../engine/storagegroup/TsFileProcessorTest.java | 6 +- .../metadata/idtable/trigger_example/Counter.java | 2 +- .../iotdb/db/protocol/mqtt/PublishHandlerTest.java | 7 +- .../db/sync/receiver/manager/SyncInfoTest.java | 8 +- .../db/sync/receiver/recovery/SyncLogTest.java | 8 +- .../apache/iotdb/rpc/NoValidValueException.java | 14 +- .../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 + .../java/org/apache/iotdb/session/Session.java | 685 +++++++++++++++++++-- site/src/main/.vuepress/config.js | 2 +- .../src/main/thrift/confignode.thrift | 38 ++ thrift/src/main/thrift/datanode.thrift | 9 +- trigger-api/pom.xml | 73 +++ .../java/org/apache/iotdb/trigger/api/Trigger.java | 68 ++ .../iotdb}/trigger/api/TriggerAttributes.java | 2 +- 139 files changed, 3314 insertions(+), 1057 deletions(-)
