This is an automated email from the ASF dual-hosted git repository.
hxd pushed a change to branch testcontainer
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
discard f19b5b4 for docker-compose
discard 9aad4b1 done 1.
discard 588675f temporary submit
discard fc5571c temporary submit
discard 99a35a1 tempororay commit
discard 3525017 try test container
add 1e88f65 add parent pom to example/udf/example
add cea339d [IOTDB-1282] fix C++ class SessionDataSet mem-leak
add 63d08a2 [CLIENT-PY] Fixed Situation where non-timeseries queries
cannot be cast to df.
add 03f7f01 Alter upgrade tool instruction error (#2985)
add 5c9da96 [Distributed] add cluster setup example doc (#2984)
new 5ae6666 try test container
new 469bad4 update the website for release 0.11.3 and 0.12.0
new 009e621 Optimize sync leader for meta (#2987)
new fad93b9 [IOTDB-1283] add-node.sh supports printgc (#2978)
new 85b28fb fix release notes link (#3002)
new 7a26c92 Minor improve the concurrency problem caused by the checking
apply thread and the compact entries thread (#3001)
new 1def61b [IOTDB-1298] Insertion performance loss due to meaningless
autoboxing and unboxing (#3003)
new 50eb967 lowering the logging level from debug to trace when serialize
meta (#3005)
new 83e045d [Distributed] fix the plan index miss (#3007)
new 8909643 [IOTDB-1308] Users with READ_TIMESERIES permission cannot
execute group by fill queries (#3014)
new f76e2e0 [IOTDB-1294] Compaction mods for new mods structure (#3013)
new bd98a45 fix issue iotdb-1219 (#3020)
new e9e6318 [IOTDB-1217] Trigger module: API, executor and management
services (#2815)
new b5f5307 init
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (f19b5b4)
\
N -- N -- N refs/heads/testcontainer (b5f5307)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 14 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:
.../antlr4/org/apache/iotdb/db/qp/sql/SqlBase.g4 | 2 +-
client-cpp/src/main/Session.h | 9 +-
client-py/iotdb/utils/SessionDataSet.py | 10 +-
client-py/tests/test_dataframe.py | 21 +
.../resources/conf/iotdb-cluster.properties | 10 +-
cluster/src/assembly/resources/sbin/add-node.sh | 25 +-
.../apache/iotdb/cluster/config/ClusterConfig.java | 32 +-
.../iotdb/cluster/config/ClusterDescriptor.java | 5 -
.../iotdb/cluster/log/catchup/LogCatchUpTask.java | 4 +-
.../cluster/log/manage/CommittedEntryManager.java | 12 +-
.../serializable/SyncLogDequeSerializer.java | 4 +-
.../iotdb/cluster/server/DataClusterServer.java | 6 +-
.../iotdb/cluster/server/MetaClusterServer.java | 6 +-
.../iotdb/cluster/server/member/RaftMember.java | 77 +--
.../cluster/server/service/BaseAsyncService.java | 19 +-
.../cluster/server/service/BaseSyncService.java | 23 +-
.../cluster/partition/SlotPartitionTableTest.java | 2 +-
.../query/ClusterDataQueryExecutorTest.java | 3 -
.../cluster/server/member/DataGroupMemberTest.java | 8 +-
.../cluster/server/member/RaftMemberTest.java | 9 +-
docs/Download/README.md | 57 ++-
docs/UserGuide/Cluster/Cluster-Setup-Example.md | 47 ++
docs/UserGuide/Cluster/Cluster-Setup.md | 11 +-
docs/UserGuide/UDF/Triggers.md | 240 ++++++++-
docs/zh/Download/README.md | 55 +-
docs/zh/UserGuide/Cluster/Cluster-Setup-Example.md | 46 ++
docs/zh/UserGuide/Cluster/Cluster-Setup.md | 11 +-
docs/zh/UserGuide/UDF/Triggers.md | 249 +++++++++-
docs/zh/UserGuide/UDF/UDF-User-Defined-Function.md | 6 +-
example/udf/pom.xml | 8 +-
.../resources/conf/iotdb-engine.properties | 31 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 26 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 28 ++
.../org/apache/iotdb/db/conf/IoTDBConstant.java | 4 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 14 +
.../org/apache/iotdb/db/engine/StorageEngine.java | 2 +-
.../db/engine/compaction/TsFileManagement.java | 3 +
.../level/LevelCompactionTsFileManagement.java | 3 +
.../engine/compaction/utils/CompactionUtils.java | 25 +-
.../engine/storagegroup/StorageGroupProcessor.java | 30 +-
.../iotdb/db/engine/trigger/api/Trigger.java | 116 +++++
.../trigger/api/TriggerAttributes.java} | 61 +--
.../db/engine/trigger/executor/TriggerEngine.java | 114 +++++
.../trigger/{api => executor}/TriggerEvent.java | 26 +-
.../engine/trigger/executor/TriggerExecutor.java | 242 +++++++++
.../trigger/service/TriggerClassLoader.java} | 46 +-
.../trigger/service/TriggerClassLoaderManager.java | 94 ++++
.../trigger/service/TriggerLogReader.java} | 30 +-
.../engine/trigger/service/TriggerLogWriter.java | 68 +++
.../service/TriggerRegistrationInformation.java} | 49 +-
.../service/TriggerRegistrationService.java | 447 +++++++++++++++++
...ception.java => TriggerExecutionException.java} | 8 +-
...eption.java => TriggerManagementException.java} | 8 +-
.../org/apache/iotdb/db/metadata/MManager.java | 11 +-
.../iotdb/db/metadata/mnode/MeasurementMNode.java | 11 +
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 53 +-
.../org/apache/iotdb/db/qp/logical/Operator.java | 10 -
.../db/qp/logical/sys/CreateTriggerOperator.java | 2 +-
.../db/qp/logical/sys/ShowTriggersOperator.java | 12 -
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 59 +--
.../db/qp/physical/crud/InsertMultiTabletPlan.java | 9 +
.../physical/crud/InsertRowsOfOneDevicePlan.java | 9 +
.../iotdb/db/qp/physical/crud/InsertRowsPlan.java | 10 +
.../db/qp/physical/crud/InsertTabletPlan.java | 24 +-
.../db/qp/physical/sys/CreateTriggerPlan.java | 96 +++-
.../iotdb/db/qp/physical/sys/DropTriggerPlan.java | 31 +-
.../iotdb/db/qp/physical/sys/ShowTriggersPlan.java | 10 +-
.../iotdb/db/qp/physical/sys/StartTriggerPlan.java | 31 +-
.../iotdb/db/qp/physical/sys/StopTriggerPlan.java | 31 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 9 +-
.../iotdb/db/qp/strategy/PhysicalGenerator.java | 3 +-
.../row/ElasticSerializableRowRecordList.java | 13 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 2 +
.../org/apache/iotdb/db/service/ServiceType.java | 1 +
.../apache/iotdb/db/auth/AuthorityCheckerTest.java | 21 +-
.../db/engine/compaction/CompactionChunkTest.java | 8 +-
.../compaction/LevelCompactionMergeTest.java | 71 +++
.../engine/compaction/LevelCompactionModsTest.java | 45 +-
.../storagegroup/StorageGroupProcessorTest.java | 28 +-
.../iotdb/db/engine/storagegroup/TTLTest.java | 12 +-
.../db/engine/trigger/example/Accumulator.java | 95 ++++
.../iotdb/db/engine/trigger/example/Counter.java | 96 ++++
.../db/integration/IoTDBTriggerExecutionIT.java | 553 +++++++++++++++++++++
.../db/integration/IoTDBTriggerManagementIT.java | 500 +++++++++++++++++++
.../db/integration/auth/IoTDBAuthorizationIT.java | 37 ++
.../iotdb/db/qp/physical/PhysicalPlanTest.java | 7 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 12 +-
server/src/test/resources/iotdb-engine.properties | 36 +-
.../iotdb/session/IoTDBSessionComplexIT.java | 55 ++
test/e2e/base/docker-compose.yaml | 4 +-
.../iotdb/db/sql/{SqlE2E.java => ClusterE2E.java} | 33 +-
.../db/sql/{SqlE2E.java => SingleNodeE2E.java} | 2 +-
.../NoProjectNameDockerComposeContainer.java | 27 +-
.../docker-compose.yaml} | 4 +
.../test/resources/1node}/iotdb-cluster.properties | 7 +-
.../docker-compose.yaml} | 4 +
.../resources/3nodes}/iotdb-cluster.properties | 5 +-
.../docker-compose.yaml} | 3 +
.../resources/5nodes}/iotdb-cluster.properties | 5 +-
thrift-cluster/src/main/thrift/cluster.thrift | 8 +-
100 files changed, 3997 insertions(+), 610 deletions(-)
create mode 100644 docs/UserGuide/Cluster/Cluster-Setup-Example.md
create mode 100644 docs/zh/UserGuide/Cluster/Cluster-Setup-Example.md
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/trigger/api/Trigger.java
copy
server/src/main/java/org/apache/iotdb/db/{query/udf/api/customizer/parameter/UDFParameters.java
=> engine/trigger/api/TriggerAttributes.java} (59%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/trigger/executor/TriggerEngine.java
rename server/src/main/java/org/apache/iotdb/db/engine/trigger/{api =>
executor}/TriggerEvent.java (61%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/trigger/executor/TriggerExecutor.java
copy
server/src/main/java/org/apache/iotdb/db/{query/udf/service/UDFClassLoader.java
=> engine/trigger/service/TriggerClassLoader.java} (56%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/trigger/service/TriggerClassLoaderManager.java
copy
server/src/main/java/org/apache/iotdb/db/{qp/physical/sys/DropTriggerPlan.java
=> engine/trigger/service/TriggerLogReader.java} (60%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/trigger/service/TriggerLogWriter.java
copy
server/src/main/java/org/apache/iotdb/db/{qp/physical/sys/CreateTriggerPlan.java
=> engine/trigger/service/TriggerRegistrationInformation.java} (61%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/trigger/service/TriggerRegistrationService.java
copy
server/src/main/java/org/apache/iotdb/db/exception/{UDFRegistrationException.java
=> TriggerExecutionException.java} (78%)
copy
server/src/main/java/org/apache/iotdb/db/exception/{UDFRegistrationException.java
=> TriggerManagementException.java} (78%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/engine/trigger/example/Accumulator.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/engine/trigger/example/Counter.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/integration/IoTDBTriggerExecutionIT.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/integration/IoTDBTriggerManagementIT.java
copy testcontainer/src/test/java/org/apache/iotdb/db/sql/{SqlE2E.java =>
ClusterE2E.java} (65%)
rename testcontainer/src/test/java/org/apache/iotdb/db/sql/{SqlE2E.java =>
SingleNodeE2E.java} (99%)
copy
server/src/main/java/org/apache/iotdb/db/qp/logical/sys/RemoveFileOperator.java
=>
testcontainer/src/test/java/org/testcontainers/containers/NoProjectNameDockerComposeContainer.java
(60%)
copy testcontainer/src/test/resources/{composes/docker-compose-3.yaml =>
1node/docker-compose.yaml} (92%)
copy {cluster/src/test/resources/node1conf =>
testcontainer/src/test/resources/1node}/iotdb-cluster.properties (92%)
copy testcontainer/src/test/resources/{composes/docker-compose-3.yaml =>
3nodes/docker-compose.yaml} (92%)
copy {cluster/src/test/resources/node1conf =>
testcontainer/src/test/resources/3nodes}/iotdb-cluster.properties (93%)
rename testcontainer/src/test/resources/{composes/docker-compose-3.yaml =>
5nodes/docker-compose.yaml} (92%)
copy {cluster/src/test/resources/node1conf =>
testcontainer/src/test/resources/5nodes}/iotdb-cluster.properties (89%)
