This is an automated email from the ASF dual-hosted git repository.
tanxinyu pushed a change to branch ca
in repository https://gitbox.apache.org/repos/asf/iotdb.git
discard 5431cbfd63 reduce rpc count for dispatch and thread count for internal
service
discard 28bbfdcc64 fix prometheus timeout
discard b76b380b63 improve iot
add 73fbcd1b2e [grafana plugin] update grafanaDependency (>= 9.3.0) in
plugin.json (#9678)
add 3412975a4a Fix NPE when using template and executing select into
(#9679)
add e3e83fe8aa [IOTDB-5788] Built-in pipe plug-in management mechanism
(#9680)
add 8b52e79bb3 [IOTDB-5791] Construct Cluster-LoadPublisher-Thread and
IClusterStatusSubscriber (#9645)
add 22b04f1bc8 Remove check of closed state in ISink
add 6767a142ca Update Programming-Go-Native-API.md (#9688)
add 6a8d009a72 Remove unecessary synchronized on decrementCnt of
SinkListener
add d92ea6e77c [IOTDB-5567] improve show cluster slots information (#9665)
add e8bf6ef1a8 [IOTDB-5810] Result handle in memory pool is not be cleaned
properly (#9685)
new 6c1556a293 improve iot
new 18baab5d01 fix prometheus timeout
new 3e58e30f49 reduce rpc count for dispatch and thread count for internal
service
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 (5431cbfd63)
\
N -- N -- N refs/heads/ca (3e58e30f49)
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 3 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:
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 28 +++-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 8 +-
.../consensus/request/ConfigPhysicalPlan.java | 6 +-
.../consensus/request/ConfigPhysicalPlanType.java | 2 +
...lotListPlan.java => CountTimeSlotListPlan.java} | 52 ++++--
.../read/partition/GetSeriesSlotListPlan.java | 18 +--
.../read/partition/GetTimeSlotListPlan.java | 44 +++--
.../request/read/region/GetRegionIdPlan.java | 46 +++---
.../CountTimeSlotListResp.java} | 23 +--
.../response/partition/GetRegionIdResp.java | 2 +-
.../response/partition/GetSeriesSlotListResp.java | 2 +-
.../response/partition/GetTimeSlotListResp.java | 2 +-
.../confignode/manager/ClusterSchemaManager.java | 15 --
.../iotdb/confignode/manager/ConfigManager.java | 22 ++-
.../apache/iotdb/confignode/manager/IManager.java | 35 +++-
.../manager/consensus/ConsensusManager.java | 12 +-
.../iotdb/confignode/manager/load/LoadManager.java | 8 +-
.../manager/load/balancer/RouteBalancer.java | 21 ++-
.../load/balancer/router/RegionRouteMap.java | 5 +
.../confignode/manager/load/cache/LoadCache.java | 15 +-
.../load/cache/region/RegionGroupCache.java | 4 +
.../manager/load/service/StatisticsService.java | 115 +++++++------
.../load/subscriber/IClusterStatusSubscriber.java | 19 +--
.../manager/load/subscriber/RouteChangeEvent.java | 74 +++++++++
.../subscriber/StatisticsChangeEvent.java} | 26 ++-
.../iotdb/confignode/manager/observer/IEvent.java | 21 ---
.../manager/partition/PartitionManager.java | 60 +++++--
.../manager/pipe/PipePluginCoordinator.java | 2 +-
.../persistence/executor/ConfigPlanExecutor.java | 3 +
.../partition/DatabasePartitionTable.java | 23 +--
.../persistence/partition/PartitionInfo.java | 128 +++++++++++++--
.../persistence/pipe/PipePluginInfo.java | 37 +++--
.../impl/pipe/plugin/DropPipePluginProcedure.java | 6 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 48 +++---
.../request/ConfigPhysicalPlanSerDeTest.java | 19 ++-
.../iotdb/confignode/persistence/PipeInfoTest.java | 2 +-
.../pipe/plugin/CreatePipePluginProcedureTest.java | 2 +-
docs/UserGuide/Cluster/Cluster-Maintenance.md | 176 +++++++++++++++-----
docs/zh/UserGuide/API/Programming-Go-Native-API.md | 1 +
docs/zh/UserGuide/Cluster/Cluster-Maintenance.md | 177 ++++++++++++++++-----
grafana-plugin/README.md | 63 +-------
grafana-plugin/src/plugin.json | 2 +-
.../iotdb/it/env/cluster/AbstractNodeWrapper.java | 1 +
.../it/partition/IoTDBPartitionGetterIT.java | 96 +++++------
.../iotdb/db/it/schema/IoTDBExtendTemplateIT.java | 45 ++++++
.../commons/partition/DataPartitionTable.java | 45 ++++--
.../commons/partition/SchemaPartitionTable.java | 10 ++
.../commons/partition/SeriesPartitionTable.java | 32 ++--
.../pipe/plugin/builtin/BuiltinPipePlugin.java | 55 +++++++
.../builtin/connector/DoNothingConnector.java | 72 +++++++++
.../builtin/processor/DoNothingProcessor.java | 68 ++++++++
.../meta/ConfigNodePipePluginMetaKeeper.java | 25 +--
.../plugin/meta/DataNodePipePluginMetaKeeper.java | 28 +++-
.../commons/pipe/plugin/meta/PipePluginMeta.java | 65 +++++---
.../pipe/plugin/meta/PipePluginMetaKeeper.java | 62 ++++++--
.../apache/iotdb/db/client/ConfigNodeClient.java | 22 +++
.../cache/DataNodeTemplateSchemaCache.java | 17 +-
.../db/mpp/common/header/ColumnHeaderConstant.java | 13 +-
.../db/mpp/common/header/DatasetHeaderFactory.java | 4 +
.../execution/exchange/MPPDataExchangeManager.java | 8 +-
.../execution/exchange/sink/LocalSinkChannel.java | 7 +
.../execution/exchange/sink/ShuffleSinkHandle.java | 7 +-
.../db/mpp/plan/execution/QueryExecution.java | 21 +++
.../plan/execution/config/ConfigTaskVisitor.java | 7 +
.../config/executor/ClusterConfigTaskExecutor.java | 74 ++++++---
.../config/executor/IConfigTaskExecutor.java | 4 +
...egionIdTask.java => CountTimeSlotListTask.java} | 33 ++--
.../config/metadata/GetTimeSlotListTask.java | 9 +-
.../config/metadata/ShowPipePluginsTask.java | 18 ++-
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 86 ++++++----
.../db/mpp/plan/statement/StatementVisitor.java | 6 +
...tement.java => CountTimeSlotListStatement.java} | 59 ++++---
.../statement/metadata/GetRegionIdStatement.java | 54 +++----
.../metadata/GetSeriesSlotListStatement.java | 20 +--
.../metadata/GetTimeSlotListStatement.java | 46 ++++--
.../org/apache/iotdb/db/pipe/agent/PipeAgent.java | 5 +-
.../db/pipe/agent/plugin/PipePluginAgent.java | 41 +++--
.../java/org/apache/iotdb/db/service/DataNode.java | 6 +
.../src/main/thrift/confignode.thrift | 36 +++--
79 files changed, 1804 insertions(+), 777 deletions(-)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/partition/{GetTimeSlotListPlan.java
=> CountTimeSlotListPlan.java} (66%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{database/CountDatabaseResp.java
=> partition/CountTimeSlotListResp.java} (73%)
copy example/tsfile/src/main/java/org/apache/iotdb/tsfile/Constant.java =>
confignode/src/main/java/org/apache/iotdb/confignode/manager/load/subscriber/IClusterStatusSubscriber.java
(66%)
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/manager/load/subscriber/RouteChangeEvent.java
rename
confignode/src/main/java/org/apache/iotdb/confignode/manager/{observer/NodeStatisticsEvent.java
=> load/subscriber/StatisticsChangeEvent.java} (51%)
delete mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/manager/observer/IEvent.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/BuiltinPipePlugin.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/DoNothingConnector.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/processor/DoNothingProcessor.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/{GetRegionIdTask.java
=> CountTimeSlotListTask.java} (70%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/{GetTimeSlotListStatement.java
=> CountTimeSlotListStatement.java} (66%)
