This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch rel/0.14.0-preview2
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from efbd55110f Merge branch 'master' of https://github.com/apache/iotdb
into rel/0.14.0-preview2
add 436d36a6ce [IOTDB-4278] null value processing to the Session API
(#7176)
add eef201614c [IOTDB-4306] Make max number of clients for InternalService
configurable (#7210)
add 41f74a578f [IOTDB-4304]Add TriggerTable and TriggerInformation (#7208)
add 6365fcddce [IOTDB-4137] Reject write when Peer in ReadOnly state in
RatisConsensus (#7216)
add 2db66c686d update release note of preview2 (#7227)
add 79e4a73d1f [IOTDB-4321] Migrate Trigger-API into a seperate module
(#7218)
add 0cf20ae58c [IOTFB-4279] Migrate Trigger related class to node-commons
(#7215)
add 518dcfbfa4 [IOTDB-4301] [IOTDB-4303] fix bug in create regions group
procedure (#7228)
add f53029b133 Add doc for last query order by timeseries (#7232)
add 35dd0cc002 [IOTDB-4305] fix website building (#7233)
add 85fa188ed1 [IOTDB-4325] NaN and Infinity will be regard as positive
Infinity in where clause in 0.14.0 (#7226)
add 8a179d7868 [IOTDB-4243] Antlr and Statement for Drop Trigger (#7220)
add 94500581f6 [IOTDB-3224][IOTDB-3949] Sync pipe execution and data
collection process in standalone version (#7154)
add 0095eb3cee update website about release-0.13.2 (#7235)
add d81192ddca delete origin data before loading snapshot without log
(#7236)
add cc78392a77 Clean ThreadName of Thrift (#7244)
add 22c8ac1f7d Change some useless logs to debug level (#7246)
add 403f5a9f9b [IOTDB-4347]NPE error when session is expired (#7245)
add 326fc81d7a [IOTDB-3642] Add retry mechanism when resource unavailable
(#7240)
add ecaa0f2af3 [IOTDB-4343] Fix session manager in MQTT module. (#7247)
new 4ef8fde63b Merge branch 'master' of https://github.com/apache/iotdb
into rel/0.14.0-preview2
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
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 +-
...upException.java => NodeReadOnlyException.java} | 11 +-
.../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 +-
...CacheWithDeletionIT.java => IoTDBFilterIT.java} | 79 ++-
.../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 | 12 +-
.../exception/TriggerRegistrationException.java | 9 +-
.../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 +-
...{DropFunctionTask.java => DropTriggerTask.java} | 13 +-
.../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 +
...ionStatement.java => DropTriggerStatement.java} | 17 +-
.../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 +-
.../sender/manager/ISyncManager.java} | 26 +-
.../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 +-
...leTransport.java => NoValidValueException.java} | 13 +-
.../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 +-
{udf-api => trigger-api}/pom.xml | 15 +-
.../java/org/apache/iotdb/trigger/api/Trigger.java | 68 ++
.../iotdb}/trigger/api/TriggerAttributes.java | 2 +-
139 files changed, 3174 insertions(+), 1040 deletions(-)
create mode 100644
confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/CreateRegionGroupsProcedureTest.java
copy
consensus/src/main/java/org/apache/iotdb/consensus/exception/{PeerNotInConsensusGroupException.java
=> NodeReadOnlyException.java} (74%)
rename docs/zh/UserGuide/Ecosystem-Integration/{Flink TsFile.md =>
Flink-TsFile.md} (100%)
rename docs/zh/UserGuide/Ecosystem-Integration/{Grafana Plugin.md =>
Grafana-Plugin.md} (100%)
rename docs/zh/UserGuide/Ecosystem-Integration/{Spark TsFile.md =>
Spark-TsFile.md} (100%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/{aligned/IoTDBLastQueryWithoutLastCacheWithDeletionIT.java
=> IoTDBFilterIT.java} (57%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/sync/{IoTDBPipeSinkIT.java
=> IoTDBPipeIT.java} (56%)
create mode 100644
integration/src/test/java/org/apache/iotdb/session/IoTDBSessionInsertNullT.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/executable/ExecutableManager.java
rename
node-commons/src/main/java/org/apache/iotdb/commons/{udf/service/UDFExecutableResource.java
=> executable/ExecutableResource.java} (87%)
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/trigger/TriggerInformation.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/trigger/TriggerTable.java
copy {server/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons/trigger}/exception/TriggerExecutionException.java
(85%)
copy
server/src/main/java/org/apache/iotdb/db/engine/trigger/sink/exception/SinkException.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/trigger/exception/TriggerRegistrationException.java
(77%)
rename {server/src/main/java/org/apache/iotdb/db/engine =>
node-commons/src/main/java/org/apache/iotdb/commons}/trigger/service/TriggerClassLoader.java
(93%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/{udf/service/UDFClassLoaderManager.java
=> trigger/service/TriggerClassLoaderManager.java} (51%)
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/trigger/service/TriggerRegistrationService.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/{DropFunctionTask.java
=> DropTriggerTask.java} (78%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/{DropFunctionStatement.java
=> DropTriggerStatement.java} (81%)
copy
server/src/main/java/org/apache/iotdb/db/{mpp/plan/planner/plan/node/write/BatchInsertNode.java
=> sync/sender/manager/ISyncManager.java} (55%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/sync/sender/manager/LocalSyncManager.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/sync/sender/manager/SchemaSyncManager.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/sync/sender/manager/TsFileSyncManager.java
copy
service-rpc/src/main/java/org/apache/iotdb/rpc/{TimeoutChangeableTransport.java
=> NoValidValueException.java} (81%)
copy {udf-api => trigger-api}/pom.xml (84%)
create mode 100644
trigger-api/src/main/java/org/apache/iotdb/trigger/api/Trigger.java
rename {server/src/main/java/org/apache/iotdb/db/engine =>
trigger-api/src/main/java/org/apache/iotdb}/trigger/api/TriggerAttributes.java
(98%)
