This is an automated email from the ASF dual-hosted git repository.
ericpai pushed a change to branch feature/iotdb-4639
in repository https://gitbox.apache.org/repos/asf/iotdb.git
discard 70e268f105 [IOTDB-4639] Support limit, slimit, offset and soffset in
tag aggregation
add aaa4147cd8 [IOTDB-4022] Adjust the storage_group_report_threshold
according to memory for writing (#6920)
add 3c92951245 change compression ratio log level from debug to info
(#7593)
add bbe369add1 [IOTDB-4205] Use logical path to take place of absolute
path in snapshot log (#7535)
add cecfe9b2be [IOTDB-4623] Enhance the stability of remove-confignode.sh
when executed in non-running node (#7591)
add 90733d8289 [IOTDB-4646] Illegal privilege APPLY_TEMPLATE on seriesPath
root.ln.** (#7597)
add d8012d29b8 [IOTDB-4589] Register/recover trigger when
registering/restart a datanode (#7575)
add 5fb78ab80e [IOTDB-4648] Fix bug ConsensusManager won't initialize when
restart
add 66467bc30d [IOTDB-3067] Eliminate PhysicalPlan usage in SchemaRegion
(#7573)
add 089161ecef [docfix] add a sentence in chapter “kill query” to conclude
(#7608)
add 11c3681445 Update 0.14.0-preview3 website (#7611)
add 928e01fae3 update org.apache.kafka:kafka_2.13 2.8.1 to 2.8.2 (#7606)
add cbf51cc26f Optimizing regex matching in Regexp (#7618)
add 26d6c9e265 [IOTDB-4658] Fix ConfigNode restart bug and add Cluster
restart IT (#7623)
add c1c8fbaa77 Fix time unit in the ttl log (#7628)
add 0ebc42fd83 [IOTDB-4654] Fix concurrent bug caused by sharing same
ChunkMetadata
add c912f937cd [IODB-4657] Fix PatternTreeMap#getOverlapped does not
return correct values (#7625)
add a4fe367436 [IOTDB-4643] Add Unknown_DataNode_Detector (#7585)
add 53a436f93a Refactor IT classes and packages (#7626)
add d1358dd09f [IOTDB-4647] Fix CSV import error when import header name
with type (#7600)
add 4eaa59103c [IOTDB-4650] Support starting reading from tail in
RewriteTsFileTool (#7604)
add 5836e07d6d Add detailed error messages while query is time out (#7632)
add cf6d85062d [IOTDB-4656] Expose client retry configurations in
RatisConsensus
add e18af3de47 update construct method of pendingBatch. (#7548)
add f33130b9fc [IOTDB-4653] add time precision units when setting TTL
(#7639)
add dbef84905a [IOTDB-4649] Fix the problem that constants which have same
valueString but different types can not be distinguished. (#7619)
add 08b6c1514b [IOTDB-4636] Add check to avoid flush empty chunk group
(#7635)
add 2cb85a9286 [IOTDB-4636] Fix IndexOutOfBoundsException when compacting
aligned series (#7638)
add aac98fec73 [IOTDB-3656] mpp load supports modification (#7354)
add 5b91cecdeb [IOTDB-4680] fix error msg "%s" in load statement (#7645)
add a078e88daa [IOTDB-4256] Implement analyzer for SELECT INTO statement
(#7588)
add 79bfe4d123 [IOTDB-3462] Update ratis version to 2.4.0 (#7651)
add 1b71c37754 [IOTDB-4647] Fix CSV import error when import header name
with type (#7636)
add 993782d2de [IOTDB-4679] Make MPPDataExchangeService use
internal_address instead of rpc_address (#7648)
add a639c09875 Added changes and user docs to rpc sqls (#7633)
add 40779e48ad [IOTDB-4381] Implement Trigger fire process (#7355)
add 84aa99226a [IOTDB-4683] Fix REJECT_THERSHOLD init error in SystemInfo
(#7649)
add 75d853837c [IOTDB-4250][IOTDB-4628] Support multiple pipes and update
drop semantics (#7581)
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 40571eb259 [IOTDB-4698]Implement interface of
getLocationOfStatefulTrigger (#7663)
add d0d2ec30a8 Disable StandaloneMppIT (#7667)
add 66e01dfcfc [IOTDB-4699] Override peer's equals and hashcode
add a12f45e42e [IOTDB-4669] Scheduled task for checking trigger-table of
DataNode (#7660)
add 8303f187b6 [IOTDB-4694] Make sure memTable snapshot is made before
flush operation (#7662)
add e489286abe [github-7180] refactor seriesNumberMonitor and additional
properties, cherry pick from rel/0.13 (#7661)
add 895ab3bc8c [IOTDB-4532] Add ITs for Trigger Management (#7671)
add d89fbfaa48 [IOTDB-4535] Chinese vesion of Trigger user doc (#7680)
add 63768fb039 Grafana plugin Modify pluginId and readme files (#7679)
add 22c07901f7 Disable the IT of the original standalone architecture
(#7681)
add 3cfa037755 update website about release-0.13.3 (#7686)
add 0396163fcf [IOTDB-4685] Refactor ConfigNode Consensus heartbeat
statistics (#7642)
add e6fb0a51d9 [IOTDB-4705] English version of Trigger user doc (#7688)
add aabb052dca [IOTDB-4711] Bind DataNodeInternalService to correct
address (#7683)
add 30bf896095 [IOTDB-4706] Call Trigger.restore() when recovering trigger
instances
add 81237589e8 New distribution package structure (#7672)
add d66d6445ed [IOTDB-4714] Rename TPipeInfo to TCreatePipeReq (#7692)
add 631fad8860 Fix schema region recover bug (#7696)
add 2fea01176c Bump flink.version from 1.14.5 to 1.14.6 (#7614)
add ca7b2b8311 [IOTDB-4641] New Standalone Sync Receiver TsFile Loader
Implement (#7610)
add f9f9721969 [IOTDB-3562] Support Deactivate Template in cluster (#7674)
add 6101e132d6 [IOTDB-4293] BufferedPipeDataQueue supports discontinuous
serialNumber (#7664)
new 122bb13005 [IOTDB-4639] Support limit, slimit, offset and soffset in
tag aggregation
new 2159cc7516 Add special limit clause for group by tags
new 04d71fc7f2 Add hard mapping from output expression to result column
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 (70e268f105)
\
N -- N -- N refs/heads/feature/iotdb-4639 (04d71fc7f2)
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:
.github/workflows/main-unix.yml | 2 +-
.github/workflows/main-win.yml | 2 +-
.github/workflows/standalone-it-for-mpp.yml | 160 ++-
.gitignore | 1 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 31 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 5 +
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 20 +-
confignode/src/assembly/confignode.xml | 10 +-
.../resources/conf/iotdb-confignode.properties | 41 +-
.../conf/{logback.xml => logback-confignode.xml} | 20 +-
.../assembly/resources/sbin/remove-confignode.bat | 2 +-
.../assembly/resources/sbin/remove-confignode.sh | 2 +-
.../assembly/resources/sbin/start-confignode.bat | 2 +-
.../assembly/resources/sbin/start-confignode.sh | 2 +-
.../confignode/client/ConfigNodeRequestType.java | 2 +-
.../confignode/client/DataNodeRequestType.java | 9 +-
.../client/async/AsyncDataNodeClientPool.java | 45 +-
.../client/async/handlers/AsyncClientHandler.java | 10 +-
.../heartbeat/DataNodeHeartbeatHandler.java | 34 +-
...RPCHandler.java => DeleteSchemaRPCHandler.java} | 6 +-
.../client/sync/SyncConfigNodeClientPool.java | 4 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 180 ++-
.../iotdb/confignode/conf/ConfigNodeConstant.java | 7 +-
.../confignode/conf/ConfigNodeDescriptor.java | 96 +-
.../confignode/conf/ConfigNodeRemoveCheck.java | 20 +-
.../confignode/conf/SystemPropertiesUtils.java | 24 +-
.../consensus/request/ConfigPhysicalPlan.java | 52 +-
.../consensus/request/ConfigPhysicalPlanType.java | 12 +-
.../{GetRoutingPlan.java => GetRegionIdPlan.java} | 10 +-
...ePlan.java => GetTransferringTriggersPlan.java} | 8 +-
.../GetTriggerJarPlan.java} | 37 +-
.../GetTriggerLocationPlan.java} | 31 +-
.../request/read/GetTriggerTablePlan.java | 22 +-
.../template/GetTemplateSetInfoPlan.java} | 37 +-
.../write/{ => datanode}/RegisterDataNodePlan.java | 20 +-
.../write/{ => datanode}/RemoveDataNodePlan.java | 27 +-
.../write/{ => function}/CreateFunctionPlan.java | 2 +-
.../write/{ => function}/DropFunctionPlan.java | 2 +-
.../{ => partition}/UpdateRegionLocationPlan.java | 2 +-
.../write/{ => procedure}/DeleteProcedurePlan.java | 2 +-
.../write/{ => procedure}/UpdateProcedurePlan.java | 2 +-
.../write/region/OfferRegionMaintainTasksPlan.java | 2 +-
.../write/statistics/UpdateLoadStatisticsPlan.java | 125 +++
.../sync/DropPipePlan.java} | 28 +-
.../UpdateTriggerLocationPlan.java} | 62 +-
.../UpdateTriggersOnTransferNodesPlan.java} | 75 +-
.../consensus/response/DataNodeRegisterResp.java | 11 +
.../{GetRoutingResp.java => GetRegionIdResp.java} | 10 +-
...etRoutingResp.java => TemplateSetInfoResp.java} | 29 +-
.../response/TransferringTriggersResp.java | 27 +-
.../{GetRoutingResp.java => TriggerJarResp.java} | 25 +-
...etRoutingResp.java => TriggerLocationResp.java} | 30 +-
.../statemachine/PartitionRegionStateMachine.java | 17 +-
.../confignode/manager/ClusterSchemaManager.java | 7 +
.../iotdb/confignode/manager/ConfigManager.java | 144 ++-
.../iotdb/confignode/manager/ConsensusManager.java | 27 +-
.../apache/iotdb/confignode/manager/IManager.java | 35 +-
.../iotdb/confignode/manager/ProcedureManager.java | 74 +-
.../iotdb/confignode/manager/SyncManager.java | 8 +-
.../iotdb/confignode/manager/TriggerManager.java | 128 ++-
.../iotdb/confignode/manager/UDFManager.java | 4 +-
.../iotdb/confignode/manager/load/LoadManager.java | 112 +-
.../manager/load/balancer/RouteBalancer.java | 6 +-
.../manager/load/balancer/router/IRouter.java | 2 +-
.../load/balancer/router/LazyGreedyRouter.java | 2 +-
.../manager/load/balancer/router/LeaderRouter.java | 13 +-
.../balancer/router/LoadScoreGreedyRouter.java | 13 +-
.../confignode/manager/node/BaseNodeCache.java | 48 +-
.../manager/node/ConfigNodeHeartbeatCache.java | 49 +-
.../manager/node/DataNodeHeartbeatCache.java | 44 +-
.../iotdb/confignode/manager/node/NodeManager.java | 195 +++-
.../manager/partition/PartitionManager.java | 59 +-
.../confignode/manager/partition/RegionCache.java | 35 +-
.../manager/partition/RegionGroupCache.java | 114 +-
.../manager/partition/RegionHeartbeatSample.java | 12 +-
.../confignode/persistence/ProcedureInfo.java | 4 +-
.../iotdb/confignode/persistence/TriggerInfo.java | 91 +-
.../iotdb/confignode/persistence/UDFInfo.java | 4 +-
.../persistence/executor/ConfigPlanExecutor.java | 56 +-
.../persistence/metric/NodeInfoMetrics.java | 2 +-
.../persistence/{ => node}/NodeInfo.java | 150 +--
.../persistence/node/NodeStatistics.java | 134 +++
.../persistence/partition/PartitionInfo.java | 77 +-
.../persistence/partition/RegionGroup.java | 3 +
.../partition/StorageGroupPartitionTable.java | 8 +-
.../{ => maintainer}/RegionCreateTask.java | 2 +-
.../{ => maintainer}/RegionDeleteTask.java | 2 +-
.../{ => maintainer}/RegionMaintainTask.java | 2 +-
.../{ => maintainer}/RegionMaintainType.java | 2 +-
.../statistics/RegionGroupStatistics.java | 145 +++
.../partition/statistics/RegionStatistics.java | 111 ++
.../persistence/schema/ClusterSchemaInfo.java | 48 +
.../persistence/schema/TemplateTable.java | 16 +
.../persistence/sync/ClusterSyncInfo.java | 43 +-
.../confignode/procedure/ProcedureExecutor.java | 2 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 35 +-
.../procedure/env/DataNodeRemoveHandler.java | 6 +-
.../procedure/impl/CreateTriggerProcedure.java | 5 +-
.../impl/node/AddConfigNodeProcedure.java | 17 +-
.../impl/node/RemoveConfigNodeProcedure.java | 32 +-
.../impl/schema/DataNodeRegionGroupUtil.java | 81 ++
.../procedure/impl/schema/DataNodeRegionTask.java | 195 ++++
.../impl/schema/DeactivateTemplateProcedure.java | 487 ++++++++
.../DeleteStorageGroupProcedure.java | 7 +-
.../DeleteTimeSeriesProcedure.java | 333 ++----
.../statemachine/CreateRegionGroupsProcedure.java | 4 +-
.../impl/sync/AbstractOperatePipeProcedure.java | 6 +-
.../procedure/impl/sync/CreatePipeProcedure.java | 9 +-
.../procedure/impl/sync/DropPipeProcedure.java | 12 +-
.../procedure/state/AddConfigNodeState.java | 2 +-
.../procedure/state/RemoveConfigNodeState.java | 2 +-
.../DeactivateTemplateState.java} | 6 +-
.../{ => schema}/DeleteStorageGroupState.java | 2 +-
.../state/{ => schema}/DeleteTimeSeriesState.java | 2 +-
.../procedure/store/ConfigProcedureStore.java | 4 +-
.../procedure/store/ProcedureFactory.java | 13 +-
.../iotdb/confignode/service/ConfigNode.java | 20 +-
.../confignode/service/ConfigNodeCommandLine.java | 23 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 53 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 185 +++-
.../request/write/RemoveDataNodePlanTest.java | 173 ---
.../load/balancer/router/LazyGreedyRouterTest.java | 8 +-
.../load/balancer/router/LeaderRouterTest.java | 152 +--
.../balancer/router/LoadScoreGreedyRouterTest.java | 4 +-
.../manager/partition/RegionGroupCacheTest.java | 81 +-
.../iotdb/confignode/persistence/NodeInfoTest.java | 69 +-
.../confignode/persistence/PartitionInfoTest.java | 45 +-
.../node/NodeStatisticsTest.java} | 36 +-
.../statistics/RegionGroupStatisticsTest.java | 56 +
.../statistics/RegionStatisticsTest.java} | 36 +-
.../impl/DeactivateTemplateProcedureTest.java | 89 ++
.../impl/DeleteStorageGroupProcedureTest.java | 2 +-
.../impl/DeleteTimeSeriesProcedureTest.java | 2 +-
.../procedure/impl/OperatePipeProcedureTest.java | 8 +-
.../thrift/ConfigNodeRPCServiceProcessorTest.java | 338 ------
.../confignode1conf/iotdb-confignode.properties | 3 +-
.../confignode2conf/iotdb-confignode.properties | 3 +-
.../confignode3conf/iotdb-confignode.properties | 1 +
consensus/pom.xml | 2 +-
.../org/apache/iotdb/consensus/common/Peer.java | 16 +-
.../apache/iotdb/consensus/config/RatisConfig.java | 122 +-
.../multileader/logdispatcher/LogDispatcher.java | 18 +-
.../multileader/logdispatcher/PendingBatch.java | 11 +-
.../ratis/FileInfoWithDelayedMd5Computing.java | 75 --
.../iotdb/consensus/ratis/RatisConsensus.java | 7 +-
.../iotdb/consensus/ratis/SnapshotStorage.java | 2 +-
.../org/apache/iotdb/consensus/ratis/Utils.java | 8 +
.../multileader/logdispatcher/SyncStatusTest.java | 25 +-
.../apache/iotdb/consensus/ratis/SnapshotTest.java | 3 +
distribution/src/assembly/all.xml | 44 +-
distribution/src/assembly/confignode.xml | 10 +-
distribution/src/assembly/datanode.xml | 8 +-
docs/Download/README.md | 42 +-
docs/UserGuide/Alert/Alerting.md | 123 ++-
docs/UserGuide/Alert/Triggers.md | 1162 ++++++--------------
docs/UserGuide/Cluster/Cluster-Concept.md | 18 +-
docs/UserGuide/Cluster/Cluster-Setup.md | 12 +-
docs/UserGuide/Delete-Data/TTL.md | 16 +-
.../Maintenance-Tools/Maintenance-Command.md | 102 +-
docs/UserGuide/Operate-Metadata/Template.md | 38 +-
docs/UserGuide/Reference/DataNode-Config-Manual.md | 9 +
docs/zh/Download/README.md | 42 +-
docs/zh/UserGuide/Alert/Alerting.md | 108 +-
docs/zh/UserGuide/Alert/Triggers.md | 1128 ++++++-------------
docs/zh/UserGuide/Cluster/Cluster-Setup.md | 12 +-
docs/zh/UserGuide/Delete-Data/TTL.md | 18 +-
.../Maintenance-Tools/Maintenance-Command.md | 101 +-
docs/zh/UserGuide/Operate-Metadata/Template.md | 40 +-
.../UserGuide/Reference/DataNode-Config-Manual.md | 10 +-
example/kafka/pom.xml | 2 +-
.../iotdb/trigger/ClusterAlertingExample.java | 8 +-
.../org/apache/iotdb/trigger/LoggerTrigger.java | 86 ++
.../iotdb/external/api/IPropertiesLoader.java | 12 +-
...sNumerLimiter.java => ISeriesNumerMonitor.java} | 8 +-
.../iotdb/flink/tsfile/util/TSFileConfigUtil.java | 1 +
.../util/TSFileConfigUtilCompletenessTest.java | 13 +-
grafana-plugin/README.md | 363 +++++-
grafana-plugin/src/plugin.json | 4 +-
integration-test/checkstyle.xml | 8 +-
integration-test/import-control.xml | 82 +-
.../trigger/example/TriggerFireTimesCounter.java | 87 ++
.../java/org/apache/iotdb/it/env/AbstractEnv.java | 115 +-
.../org/apache/iotdb/it/env/ConfigNodeWrapper.java | 2 +-
.../org/apache/iotdb/it/env/DataNodeWrapper.java | 2 +-
.../java/org/apache/iotdb/it/env/MppConfig.java | 11 +-
.../org/apache/iotdb/it/env/RemoteServerEnv.java | 19 +-
.../org/apache/iotdb/it/utils/TsFileGenerator.java | 232 ++++
.../org/apache/iotdb/itbase/env/BaseConfig.java | 12 +-
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 12 +-
.../{ => it}/IoTDBClusterPartitionIT.java | 138 ++-
.../iotdb/confignode/it/IoTDBClusterRestartIT.java | 87 ++
.../confignode/{ => it}/IoTDBConfigNodeIT.java | 19 +-
.../{ => it}/IoTDBConfigNodeSnapshotIT.java | 21 +-
.../it/IoTDBConfigNodeSwitchLeaderIT.java | 236 ++++
.../iotdb/confignode/it/IoTDBStorageGroupIT.java | 184 ++++
.../org/apache/iotdb/db/it/IOTDBLoadTsFileIT.java | 340 +++---
.../java/org/apache/iotdb/db/it/IoTDBFilterIT.java | 24 +-
.../org/apache/iotdb/db/it/IoTDBFilterNullIT.java | 3 +
.../it/aggregation/IoTDBAggregationByLevelIT.java | 3 +
.../it/aggregation/IoTDBAggregationDeleteIT.java | 3 +
.../aggregation/IoTDBAggregationScanOrderIT.java | 3 +
.../aggregation/IoTDBAggregationSmallDataIT.java | 3 +
.../db/it/aggregation/IoTDBTagAggregationIT.java | 105 +-
.../aligned/IoTDBAggregationWithDeletion2IT.java | 1 +
.../it/aligned/IoTDBAggregationWithDeletionIT.java | 1 +
.../db/it/aligned/IoTDBAlignedLastQuery2IT.java | 1 +
.../db/it/aligned/IoTDBAlignedLastQuery3IT.java | 1 +
.../db/it/aligned/IoTDBAlignedLastQueryIT.java | 1 +
.../db/it/aligned/IoTDBAlignedSeriesQuery2IT.java | 1 +
.../db/it/aligned/IoTDBAlignedSeriesQuery3IT.java | 1 +
.../db/it/aligned/IoTDBAlignedSeriesQueryIT.java | 1 +
.../IoTDBAlignedSeriesQueryWithDeletionIT.java | 1 +
.../db/it/aligned/IoTDBGroupByLevelQueryIT.java | 1 +
...GroupByQueryWithValueFilterWithDeletion2IT.java | 1 +
...BGroupByQueryWithValueFilterWithDeletionIT.java | 1 +
...upByQueryWithoutValueFilterWithDeletion2IT.java | 1 +
...oupByQueryWithoutValueFilterWithDeletionIT.java | 1 +
.../it/aligned/IoTDBLastQueryWithDeletion2IT.java | 1 +
.../it/aligned/IoTDBLastQueryWithDeletionIT.java | 1 +
.../aligned/IoTDBLastQueryWithoutLastCache2IT.java | 1 +
.../aligned/IoTDBLastQueryWithoutLastCacheIT.java | 1 +
...DBLastQueryWithoutLastCacheWithDeletion2IT.java | 1 +
...TDBLastQueryWithoutLastCacheWithDeletionIT.java | 1 +
...BRawQueryWithoutValueFilterWithDeletion2IT.java | 1 +
...DBRawQueryWithoutValueFilterWithDeletionIT.java | 1 +
.../org/apache/iotdb/db/it/env/StandaloneEnv.java | 20 +-
.../db/it/schema/IoTDBDeactivateTemplateIT.java | 231 ++++
.../org/apache/iotdb/db/it/sync/IoTDBPipeIT.java | 69 +-
.../apache/iotdb/db/it/sync/IoTDBPipeSinkIT.java | 7 +-
.../apache/iotdb/db/it/sync/SyncTransportTest.java | 323 ++++++
.../db/it/trigger/IoTDBTriggerExecutionIT.java | 265 +++++
.../db/it/trigger/IoTDBTriggerManagementIT.java | 486 ++++++++
.../db/it/{aligned => utils}/AlignedWriteUtil.java | 2 +-
.../db/it/withoutNull/IoTDBWithoutAllNullIT.java | 3 +
.../db/it/withoutNull/IoTDBWithoutAnyNullIT.java | 3 +
.../withoutNull/IoTDBWithoutNullAllFilterIT.java | 3 +
.../withoutNull/IoTDBWithoutNullAnyFilterIT.java | 3 +
.../{ => it}/IoTDBSessionAlignedInsertIT.java | 4 +-
.../session/{ => it}/IoTDBSessionComplexIT.java | 4 +-
.../{ => it}/IoTDBSessionDisableMemControlIT.java | 4 +-
.../session/{ => it}/IoTDBSessionInsertNulIT.java | 6 +-
.../IoTDBSessionInsertWithTriggerExecutionIT.java | 337 ++++++
.../session/{ => it}/IoTDBSessionSimpleIT.java | 4 +-
.../{ => it}/IoTDBSessionSyntaxConventionIT.java | 4 +-
.../{SessionTest.java => it/SessionIT.java} | 9 +-
.../src/test/resources/TriggerFireTimesCounter.jar | Bin 0 -> 1324 bytes
...IoTDBLoadExternalTsFileWithTimePartitionIT.java | 329 ------
.../db/integration/IoTDBRepeatPatternNameIT.java | 67 ++
.../iotdb/db/integration/IoTDBSnapshotIT.java | 60 +-
metrics/dropwizard-metrics/pom.xml | 6 -
...otdb-metric.yml => iotdb-confignode-metric.yml} | 0
...{iotdb-metric.yml => iotdb-datanode-metric.yml} | 0
.../metrics/config/MetricConfigDescriptor.java | 31 +-
.../iotdb/metrics/config/MetricConstant.java | 4 +-
.../apache/iotdb/commons/cluster/NodeStatus.java | 2 +-
.../iotdb/commons/concurrent/ThreadName.java | 1 +
.../apache/iotdb/commons/conf/IoTDBConstant.java | 13 +-
...ception.java => PipeAlreadyExistException.java} | 12 +-
.../exception/sync/PipeNotExistException.java | 4 -
.../sync/PipeSinkAlreadyExistException.java | 12 +-
...eption.java => PipeSinkBeingUsedException.java} | 12 +-
.../exception/sync/PipeSinkNotExistException.java | 12 +-
.../commons/executable/ExecutableManager.java | 11 +
.../commons/partition/DataPartitionTable.java | 4 +-
.../commons/partition/SchemaPartitionTable.java | 2 +-
.../commons/partition/SeriesPartitionTable.java | 2 +-
.../org/apache/iotdb/commons/path/PartialPath.java | 17 +
.../apache/iotdb/commons/path/PatternTreeMap.java | 44 +-
.../iotdb/commons/sync/metadata/SyncMetadata.java | 122 +-
.../commons/sync/persistence/SyncLogReader.java | 31 +-
.../apache/iotdb/commons/sync/pipe/PipeStatus.java | 1 -
.../iotdb/commons/trigger/TriggerInformation.java | 15 +
.../apache/iotdb/commons/trigger/TriggerTable.java | 45 +
.../org/apache/iotdb/commons/utils/AuthUtils.java | 1 +
.../commons/utils/ThriftConfigNodeSerDeUtils.java | 19 -
.../commons/sync/metedata/SyncMetadataTest.java | 189 ++++
pom.xml | 2 +-
.../java/org/apache/iotdb/RewriteTsFileTool.java | 249 ++++-
.../schemaregion/rocksdb/RSchemaRegion.java | 55 +-
.../schemaregion/rocksdb/mnode/REntityMNode.java | 20 +
.../resources/conf/iotdb-datanode.properties | 85 +-
.../conf/{logback.xml => logback-datanode.xml} | 52 +-
.../assembly/resources/sbin/remove-datanode.bat | 2 +-
.../src/assembly/resources/sbin/remove-datanode.sh | 2 +-
.../src/assembly/resources/sbin/start-datanode.bat | 2 +-
.../src/assembly/resources/sbin/start-datanode.sh | 2 +-
.../assembly/resources/sbin/start-new-server.bat | 2 +-
.../assembly/resources/sbin/start-new-server.sh | 2 +-
.../src/assembly/resources/sbin/start-server.bat | 2 +-
server/src/assembly/resources/sbin/start-server.sh | 2 +-
server/src/assembly/server.xml | 10 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 84 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 196 +++-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 116 +-
.../db/consensus/DataRegionConsensusImpl.java | 25 +
.../db/consensus/SchemaRegionConsensusImpl.java | 25 +
.../impl/ReadChunkCompactionPerformer.java | 21 +-
.../iotdb/db/engine/flush/MemTableFlushTask.java | 10 +-
.../iotdb/db/engine/load/AlignedChunkData.java | 9 +-
.../org/apache/iotdb/db/engine/load/ChunkData.java | 14 +-
.../apache/iotdb/db/engine/load/DeletionData.java | 72 ++
.../iotdb/db/engine/load/LoadTsFileManager.java | 29 +-
.../iotdb/db/engine/load/NonAlignedChunkData.java | 1 +
.../load/{ChunkData.java => TsFileData.java} | 42 +-
.../iotdb/db/engine/snapshot/SnapshotFileSet.java | 4 +-
.../iotdb/db/engine/snapshot/SnapshotLoader.java | 377 ++++---
.../db/engine/snapshot/SnapshotLogAnalyzer.java | 61 +-
.../iotdb/db/engine/snapshot/SnapshotLogger.java | 47 +-
.../iotdb/db/engine/snapshot/SnapshotTaker.java | 16 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 38 +-
.../{StorageGroupInfo.java => DataRegionInfo.java} | 19 +-
.../db/engine/storagegroup/TsFileManager.java | 5 +-
.../db/engine/storagegroup/TsFileProcessor.java | 79 +-
.../engine/storagegroup/TsFileProcessorInfo.java | 16 +-
.../storagegroup/timeindex/DeviceTimeIndex.java | 5 +-
.../query/QueryTimeoutRuntimeException.java | 9 +
.../iotdb/db/metadata/LocalSchemaProcessor.java | 2 +-
.../apache/iotdb/db/metadata/idtable/IDTable.java | 8 +-
.../db/metadata/idtable/IDTableHashmapImpl.java | 12 +-
.../db/metadata/logfile/BufferedSerializer.java | 38 +-
.../db/metadata/logfile/FakeCRC32Deserializer.java | 91 ++
.../db/metadata/logfile/FakeCRC32Serializer.java | 65 ++
.../logfile/IDeserializer.java} | 25 +-
.../iotdb/db/metadata/logfile/ISerializer.java | 28 +-
.../iotdb/db/metadata/logfile/MLogTxtWriter.java | 2 +-
.../iotdb/db/metadata/logfile/SchemaLogReader.java | 247 +++++
.../iotdb/db/metadata/logfile/SchemaLogWriter.java | 114 ++
.../iotdb/db/metadata/mnode/EntityMNode.java | 38 +
.../iotdb/db/metadata/mnode/IEntityMNode.java | 8 +
.../iotdb/db/metadata/mnode/InternalMNode.java | 8 +-
.../iotdb/db/metadata/mtree/ConfigMTree.java | 39 +
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 102 +-
.../db/metadata/mtree/traverser/Traverser.java | 19 +-
.../traverser/collector/MeasurementCollector.java | 3 +-
.../plan/schemaregion/ISchemaRegionPlan.java | 12 +-
.../plan/schemaregion/SchemaRegionPlanType.java | 79 ++
.../plan/schemaregion/SchemaRegionPlanVisitor.java | 107 ++
.../impl/ActivateTemplateInClusterPlanImpl.java | 79 ++
.../impl/ActivateTemplatePlanImpl.java} | 28 +-
.../impl/AutoCreateDeviceMNodePlanImpl.java} | 28 +-
.../schemaregion/impl/ChangeAliasPlanImpl.java | 37 +-
.../schemaregion/impl/ChangeTagOffsetPlanImpl.java | 37 +-
.../impl/CreateAlignedTimeSeriesPlanImpl.java | 171 +++
.../impl/CreateTimeSeriesPlanImpl.java | 163 +++
.../impl/DeactivateTemplatePlanImpl.java} | 25 +-
.../impl/DeleteTimeSeriesPlanImpl.java | 27 +-
.../impl/PreDeactivateTemplatePlanImpl.java} | 34 +-
.../impl/PreDeleteTimeSeriesPlanImpl.java} | 28 +-
.../RollbackPreDeactivateTemplatePlanImpl.java} | 34 +-
.../impl/RollbackPreDeleteTimeSeriesPlanImpl.java} | 28 +-
.../impl/SchemaRegionPlanDeserializer.java | 380 +++++++
.../schemaregion/impl/SchemaRegionPlanFactory.java | 146 +++
.../impl/SchemaRegionPlanSerializer.java | 450 ++++++++
.../impl/SchemaRegionPlanTxtSerializer.java | 273 +++++
.../schemaregion/impl/SetTemplatePlanImpl.java} | 62 +-
.../schemaregion/impl/UnsetTemplatePlanImpl.java} | 62 +-
.../write/IActivateTemplateInClusterPlan.java | 60 +
.../schemaregion/write/IActivateTemplatePlan.java | 28 +-
.../write/IAutoCreateDeviceMNodePlan.java | 28 +-
.../plan/schemaregion/write/IChangeAliasPlan.java | 32 +-
.../schemaregion/write/IChangeTagOffsetPlan.java | 32 +-
.../write/ICreateAlignedTimeSeriesPlan.java | 80 ++
.../schemaregion/write/ICreateTimeSeriesPlan.java | 79 ++
.../write/IDeactivateTemplatePlan.java} | 36 +-
.../schemaregion/write/IDeleteTimeSeriesPlan.java | 28 +-
.../write/IPreDeactivateTemplatePlan.java} | 36 +-
.../write/IPreDeleteTimeSeriesPlan.java | 28 +-
.../write/IRollbackPreDeactivateTemplatePlan.java | 45 +
.../write/IRollbackPreDeleteTimeSeriesPlan.java | 28 +-
.../plan/schemaregion/write/ISetTemplatePlan.java | 31 +-
.../schemaregion/write/IUnsetTemplatePlan.java | 31 +-
.../db/metadata/schemaregion/ISchemaRegion.java | 43 +-
.../db/metadata/schemaregion/SchemaEngine.java | 46 +-
.../schemaregion/SchemaRegionMemoryImpl.java | 539 ++++++---
.../schemaregion/SchemaRegionSchemaFileImpl.java | 387 ++++---
.../iotdb/db/metadata/template/Template.java | 5 +-
.../metadata/visitor/SchemaExecutionVisitor.java | 103 +-
.../db/mpp/common/header/ColumnHeaderConstant.java | 37 +-
.../db/mpp/common/header/DatasetHeaderFactory.java | 10 +-
.../execution/exchange/MPPDataExchangeService.java | 8 +-
.../execution/executor/RegionWriteExecutor.java | 36 +-
.../schema/PathsUsingTemplateScanOperator.java | 21 +-
.../apache/iotdb/db/mpp/plan/analyze/Analysis.java | 67 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 372 +++++--
.../db/mpp/plan/analyze/ConcatPathRewriter.java | 43 +-
.../iotdb/db/mpp/plan/analyze/SelectIntoUtils.java | 105 ++
.../iotdb/db/mpp/plan/constant/StatementType.java | 2 +
.../db/mpp/plan/execution/QueryExecution.java | 15 +-
.../plan/execution/config/ConfigTaskVisitor.java | 17 +-
.../config/executor/ClusterConfigTaskExecutor.java | 116 +-
.../config/executor/IConfigTaskExecutor.java | 8 +-
.../executor/StandaloneConfigTaskExecutor.java | 16 +-
.../{GetRegionTask.java => GetRegionIdTask.java} | 22 +-
.../execution/config/metadata/ShowClusterTask.java | 4 +-
.../template/DeactivateSchemaTemplateTask.java | 45 +
.../mpp/plan/expression/leaf/ConstantOperand.java | 4 +-
.../plan/expression/leaf/TimeSeriesOperand.java | 9 +
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 141 ++-
.../db/mpp/plan/parser/StatementGenerator.java | 4 +-
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 19 +-
.../db/mpp/plan/planner/LogicalPlanVisitor.java | 4 +-
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 2 +-
.../plan/planner/distribution/SourceRewriter.java | 88 +-
.../mpp/plan/planner/plan/node/PlanNodeType.java | 14 +-
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 15 +
.../plan/node/load/LoadSingleTsFileNode.java | 69 +-
.../planner/plan/node/load/LoadTsFileNode.java | 3 +
.../plan/node/load/LoadTsFilePieceNode.java | 35 +-
.../metedata/read/PathsUsingTemplateScanNode.java | 36 +-
.../node/metedata/read/SchemaQueryScanNode.java | 10 +
.../node/metedata/write/ActivateTemplateNode.java | 15 +-
.../write/CreateAlignedTimeSeriesNode.java | 25 +-
.../node/metedata/write/CreateTimeSeriesNode.java | 17 +-
.../metedata/write/DeactivateTemplateNode.java | 128 +++
.../metedata/write/PreDeactivateTemplateNode.java | 128 +++
.../write/RollbackPreDeactivateTemplateNode.java | 130 +++
.../parameter/DeviceViewIntoPathDescriptor.java | 208 ++++
.../planner/plan/parameter/IntoPathDescriptor.java | 167 +++
.../plan/scheduler/load/LoadTsFileScheduler.java | 7 +
.../db/mpp/plan/statement/StatementVisitor.java | 12 +-
.../plan/statement/component/IntoComponent.java | 237 ++++
.../db/mpp/plan/statement/component/IntoItem.java | 73 ++
.../plan/statement/crud/LoadTsFileStatement.java | 8 +-
.../db/mpp/plan/statement/crud/QueryStatement.java | 57 +-
...ionStatement.java => GetRegionIdStatement.java} | 6 +-
...ement.java => DeactivateTemplateStatement.java} | 44 +-
.../template/ShowPathsUsingTemplateStatement.java | 22 +-
.../dag/input/ConstantInputReader.java | 3 +-
.../transformation/dag/util/TransformUtils.java | 3 +-
.../db/protocol/mqtt/PayloadFormatManager.java | 5 +-
.../sys/ActivateTemplateInClusterPlan.java | 19 +-
.../db/qp/physical/sys/ActivateTemplatePlan.java | 8 +-
.../qp/physical/sys/AutoCreateDeviceMNodePlan.java | 8 +-
.../iotdb/db/qp/physical/sys/ChangeAliasPlan.java | 3 +-
.../db/qp/physical/sys/ChangeTagOffsetPlan.java | 3 +-
.../physical/sys/CreateAlignedTimeSeriesPlan.java | 38 +-
.../db/qp/physical/sys/CreateTimeSeriesPlan.java | 3 +-
.../db/qp/physical/sys/DeleteTimeSeriesPlan.java | 8 +-
.../qp/physical/sys/PreDeleteTimeSeriesPlan.java | 3 +-
.../sys/RollbackPreDeleteTimeSeriesPlan.java | 4 +-
.../iotdb/db/qp/physical/sys/SetTemplatePlan.java | 3 +-
.../db/qp/physical/sys/UnsetTemplatePlan.java | 3 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 34 +-
.../metadata/DiskAlignedChunkMetadataLoader.java | 2 +-
.../chunk/metadata/DiskChunkMetadataLoader.java | 2 +-
.../org/apache/iotdb/db/rescon/SystemInfo.java | 53 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 133 ++-
.../db/service/DataNodeInternalRPCService.java | 2 +-
.../db/service/DataNodeServerCommandLine.java | 36 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 4 -
.../java/org/apache/iotdb/db/service/NewIoTDB.java | 3 -
.../db/service/ResourcesInformationHolder.java | 29 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 209 +++-
.../java/org/apache/iotdb/db/sync/SyncService.java | 170 ++-
.../db/sync/common/ClusterSyncInfoFetcher.java | 7 +-
.../iotdb/db/sync/common/ISyncInfoFetcher.java | 4 +-
.../apache/iotdb/db/sync/common/LocalSyncInfo.java | 22 +-
.../iotdb/db/sync/common/LocalSyncInfoFetcher.java | 11 +-
.../sync/pipedata/queue/BufferedPipeDataQueue.java | 70 +-
.../db/sync/receiver/load/DeletionLoader.java | 52 +-
.../iotdb/db/sync/receiver/load/ILoader.java | 20 +
.../iotdb/db/sync/receiver/load/TsFileLoader.java | 58 +-
.../org/apache/iotdb/db/sync/sender/pipe/Pipe.java | 7 +
.../iotdb/db/sync/sender/pipe/TsFilePipe.java | 49 +-
.../db/sync/transport/client/SenderManager.java | 2 +
.../apache/iotdb/db/tools/schema/MLogParser.java | 122 +-
.../iotdb/db/trigger/executor/TriggerExecutor.java | 59 +-
.../db/trigger/executor/TriggerFireResult.java | 57 +
.../db/trigger/executor/TriggerFireVisitor.java | 423 +++++++
.../trigger/service/TriggerInformationUpdater.java | 104 ++
.../trigger/service/TriggerManagementService.java | 249 ++++-
.../java/org/apache/iotdb/db/utils/FilesUtils.java | 43 +
.../org/apache/iotdb/db/utils/JarLoaderUtil.java | 150 ---
.../java/org/apache/iotdb/db/utils/QueryUtils.java | 16 +-
.../apache/iotdb/db/utils/sync/SyncPipeUtil.java | 6 +-
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 70 +-
.../ReadChunkCompactionPerformerAlignedTest.java | 79 ++
.../db/engine/snapshot/IoTDBSnapshotTest.java | 13 +-
.../db/engine/storagegroup/DataRegionTest.java | 40 +
.../engine/storagegroup/TsFileProcessorTest.java | 4 +-
.../engine/storagegroup/TsFileProcessorV2Test.java | 4 +-
.../iotdb/db/metadata/path/PatternTreeMapTest.java | 88 +-
.../plan/SchemaRegionPlanCompatibilityTest.java | 334 ++++++
.../db/mpp/common/schematree/NodeRefTest.java | 47 +
.../mpp/execution/operator/OperatorMemoryTest.java | 6 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeTest.java | 169 +++
.../iotdb/db/mpp/plan/plan/LogicalPlannerTest.java | 36 +
.../manager => persistence}/LocalSyncInfoTest.java | 23 +-
.../recovery => persistence}/SyncLogTest.java | 36 +-
.../sync/pipedata/BufferedPipeDataQueueTest.java | 95 ++
.../iotdb/db/sync/transport/SyncTransportTest.java | 357 ------
.../org/apache/iotdb/db/tools/MLogParserTest.java | 17 -
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 4 +-
.../src/main/thrift/confignode.thrift | 114 +-
thrift/src/main/thrift/datanode.thrift | 71 +-
.../iotdb/tsfile/common/conf/TSFileConfig.java | 22 +
.../iotdb/tsfile/common/conf/TSFileDescriptor.java | 4 +-
.../tsfile/common/constant/TsFileConstant.java | 4 +
.../file/metadata/AlignedTimeSeriesMetadata.java | 15 +
.../iotdb/tsfile/file/metadata/ChunkMetadata.java | 18 +
.../tsfile/file/metadata/TimeseriesMetadata.java | 7 +
.../iotdb/tsfile/read/filter/operator/Regexp.java | 48 +-
.../tsfile/write/chunk/AlignedChunkWriterImpl.java | 12 +
.../apache/iotdb/tsfile/write/record/Tablet.java | 341 +++++-
.../iotdb/tsfile/write/writer/TsFileIOWriter.java | 4 +
.../iotdb/tsfile/write/record/TabletTest.java | 65 ++
506 files changed, 20528 insertions(+), 7876 deletions(-)
rename confignode/src/assembly/resources/conf/{logback.xml =>
logback-confignode.xml} (86%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/rpc/{DeleteTimeSeriesRPCHandler.java
=> DeleteSchemaRPCHandler.java} (95%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{GetRoutingPlan.java
=> GetRegionIdPlan.java} (94%)
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/DropFunctionPlan.java
=> read/GetTriggerJarPlan.java} (59%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/{write/DropFunctionPlan.java
=> read/GetTriggerLocationPlan.java} (66%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/{write/DropFunctionPlan.java
=> read/template/GetTemplateSetInfoPlan.java} (54%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{
=> datanode}/RegisterDataNodePlan.java (74%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{
=> datanode}/RemoveDataNodePlan.java (82%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{
=> function}/CreateFunctionPlan.java (97%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{
=> function}/DropFunctionPlan.java (96%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{
=> partition}/UpdateRegionLocationPlan.java (97%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{
=> procedure}/DeleteProcedurePlan.java (96%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{
=> procedure}/UpdateProcedurePlan.java (97%)
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/statistics/UpdateLoadStatisticsPlan.java
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/{read/GetTriggerTablePlan.java
=> write/sync/DropPipePlan.java} (66%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{CreateFunctionPlan.java
=> trigger/UpdateTriggerLocationPlan.java} (51%)
rename
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/{GetRoutingResp.java
=> GetRegionIdResp.java} (83%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{GetRoutingResp.java
=> TemplateSetInfoResp.java} (62%)
copy
server/src/main/java/org/apache/iotdb/db/exception/query/QueryTimeoutRuntimeException.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/TransferringTriggersResp.java
(57%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{GetRoutingResp.java
=> TriggerJarResp.java} (63%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{GetRoutingResp.java
=> TriggerLocationResp.java} (59%)
rename confignode/src/main/java/org/apache/iotdb/confignode/persistence/{ =>
node}/NodeInfo.java (81%)
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/persistence/node/NodeStatistics.java
rename
confignode/src/main/java/org/apache/iotdb/confignode/persistence/partition/{ =>
maintainer}/RegionCreateTask.java (98%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/persistence/partition/{ =>
maintainer}/RegionDeleteTask.java (97%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/persistence/partition/{ =>
maintainer}/RegionMaintainTask.java (98%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/persistence/partition/{ =>
maintainer}/RegionMaintainType.java (92%)
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/persistence/partition/statistics/RegionGroupStatistics.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/persistence/partition/statistics/RegionStatistics.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/DataNodeRegionGroupUtil.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/DataNodeRegionTask.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/DeactivateTemplateProcedure.java
rename
confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/{statemachine
=> schema}/DeleteStorageGroupProcedure.java (96%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/{statemachine
=> schema}/DeleteTimeSeriesProcedure.java (60%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/{DeleteTimeSeriesState.java
=> schema/DeactivateTemplateState.java} (88%)
rename confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/{
=> schema}/DeleteStorageGroupState.java (93%)
rename confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/{
=> schema}/DeleteTimeSeriesState.java (94%)
delete mode 100644
confignode/src/test/java/org/apache/iotdb/confignode/consensus/request/write/RemoveDataNodePlanTest.java
copy
confignode/src/test/java/org/apache/iotdb/confignode/{procedure/impl/DeleteStorageGroupProcedureTest.java
=> persistence/node/NodeStatisticsTest.java} (53%)
create mode 100644
confignode/src/test/java/org/apache/iotdb/confignode/persistence/partition/statistics/RegionGroupStatisticsTest.java
copy
confignode/src/test/java/org/apache/iotdb/confignode/{procedure/impl/DeleteStorageGroupProcedureTest.java
=> persistence/partition/statistics/RegionStatisticsTest.java} (53%)
create mode 100644
confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/DeactivateTemplateProcedureTest.java
delete mode 100644
confignode/src/test/java/org/apache/iotdb/confignode/service/thrift/ConfigNodeRPCServiceProcessorTest.java
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
rename
external-api/src/main/java/org/apache/iotdb/external/api/{ISeriesNumerLimiter.java
=> ISeriesNumerMonitor.java} (82%)
create mode 100644
integration-test/src/main/java/org/apache/iotdb/db/trigger/example/TriggerFireTimesCounter.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/it/utils/TsFileGenerator.java
rename integration-test/src/test/java/org/apache/iotdb/confignode/{ =>
it}/IoTDBClusterPartitionIT.java (85%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/IoTDBClusterRestartIT.java
rename integration-test/src/test/java/org/apache/iotdb/confignode/{ =>
it}/IoTDBConfigNodeIT.java (97%)
rename integration-test/src/test/java/org/apache/iotdb/confignode/{ =>
it}/IoTDBConfigNodeSnapshotIT.java (94%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/IoTDBConfigNodeSwitchLeaderIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/IoTDBStorageGroupIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/schema/IoTDBDeactivateTemplateIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/sync/SyncTransportTest.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/db/it/trigger/IoTDBTriggerManagementIT.java
rename integration-test/src/test/java/org/apache/iotdb/db/it/{aligned =>
utils}/AlignedWriteUtil.java (99%)
rename integration-test/src/test/java/org/apache/iotdb/session/{ =>
it}/IoTDBSessionAlignedInsertIT.java (99%)
rename integration-test/src/test/java/org/apache/iotdb/session/{ =>
it}/IoTDBSessionComplexIT.java (99%)
rename integration-test/src/test/java/org/apache/iotdb/session/{ =>
it}/IoTDBSessionDisableMemControlIT.java (98%)
rename integration-test/src/test/java/org/apache/iotdb/session/{ =>
it}/IoTDBSessionInsertNulIT.java (99%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/session/it/IoTDBSessionInsertWithTriggerExecutionIT.java
rename integration-test/src/test/java/org/apache/iotdb/session/{ =>
it}/IoTDBSessionSimpleIT.java (99%)
rename integration-test/src/test/java/org/apache/iotdb/session/{ =>
it}/IoTDBSessionSyntaxConventionIT.java (99%)
rename
integration-test/src/test/java/org/apache/iotdb/session/{SessionTest.java =>
it/SessionIT.java} (95%)
create mode 100644
integration-test/src/test/resources/TriggerFireTimesCounter.jar
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/IoTDBLoadExternalTsFileWithTimePartitionIT.java
create mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/IoTDBRepeatPatternNameIT.java
copy metrics/interface/src/main/assembly/resources/conf/{iotdb-metric.yml =>
iotdb-confignode-metric.yml} (100%)
rename metrics/interface/src/main/assembly/resources/conf/{iotdb-metric.yml =>
iotdb-datanode-metric.yml} (100%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/exception/sync/{PipeNotExistException.java
=> PipeAlreadyExistException.java} (67%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/AddConfigNodeState.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/exception/sync/PipeSinkAlreadyExistException.java
(75%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/exception/sync/{PipeNotExistException.java
=> PipeSinkBeingUsedException.java} (73%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/AddConfigNodeState.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/exception/sync/PipeSinkNotExistException.java
(76%)
create mode 100644
node-commons/src/test/java/org/apache/iotdb/commons/sync/metedata/SyncMetadataTest.java
rename server/src/assembly/resources/conf/{logback.xml =>
logback-datanode.xml} (84%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/load/DeletionData.java
copy server/src/main/java/org/apache/iotdb/db/engine/load/{ChunkData.java =>
TsFileData.java} (53%)
rename
server/src/main/java/org/apache/iotdb/db/engine/storagegroup/{StorageGroupInfo.java
=> DataRegionInfo.java} (80%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetTriggerTablePlan.java
=>
server/src/main/java/org/apache/iotdb/db/metadata/logfile/BufferedSerializer.java
(50%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/logfile/FakeCRC32Deserializer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/logfile/FakeCRC32Serializer.java
copy
server/src/main/java/org/apache/iotdb/db/{exception/query/QueryTimeoutRuntimeException.java
=> metadata/logfile/IDeserializer.java} (58%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetTriggerTablePlan.java
=> server/src/main/java/org/apache/iotdb/db/metadata/logfile/ISerializer.java
(58%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/logfile/SchemaLogReader.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/logfile/SchemaLogWriter.java
copy
confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/AddConfigNodeState.java
=>
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/ISchemaRegionPlan.java
(80%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/SchemaRegionPlanType.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/SchemaRegionPlanVisitor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/ActivateTemplateInClusterPlanImpl.java
copy
server/src/main/java/org/apache/iotdb/db/{exception/query/QueryTimeoutRuntimeException.java
=> metadata/plan/schemaregion/impl/ActivateTemplatePlanImpl.java} (57%)
copy
server/src/main/java/org/apache/iotdb/db/{exception/query/QueryTimeoutRuntimeException.java
=> metadata/plan/schemaregion/impl/AutoCreateDeviceMNodePlanImpl.java} (58%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetTriggerTablePlan.java
=>
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/ChangeAliasPlanImpl.java
(54%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetTriggerTablePlan.java
=>
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/ChangeTagOffsetPlanImpl.java
(53%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/CreateAlignedTimeSeriesPlanImpl.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/CreateTimeSeriesPlanImpl.java
copy
server/src/main/java/org/apache/iotdb/db/{exception/query/QueryTimeoutRuntimeException.java
=> metadata/plan/schemaregion/impl/DeactivateTemplatePlanImpl.java} (56%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetTriggerTablePlan.java
=>
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/DeleteTimeSeriesPlanImpl.java
(55%)
copy
server/src/main/java/org/apache/iotdb/db/metadata/{mnode/IEntityMNode.java =>
plan/schemaregion/impl/PreDeactivateTemplatePlanImpl.java} (56%)
copy
server/src/main/java/org/apache/iotdb/db/{exception/query/QueryTimeoutRuntimeException.java
=> metadata/plan/schemaregion/impl/PreDeleteTimeSeriesPlanImpl.java} (59%)
copy
server/src/main/java/org/apache/iotdb/db/metadata/{mnode/IEntityMNode.java =>
plan/schemaregion/impl/RollbackPreDeactivateTemplatePlanImpl.java} (56%)
copy
server/src/main/java/org/apache/iotdb/db/{exception/query/QueryTimeoutRuntimeException.java
=> metadata/plan/schemaregion/impl/RollbackPreDeleteTimeSeriesPlanImpl.java}
(57%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/SchemaRegionPlanDeserializer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/SchemaRegionPlanFactory.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/SchemaRegionPlanSerializer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/SchemaRegionPlanTxtSerializer.java
copy
server/src/main/java/org/apache/iotdb/db/{qp/physical/sys/SetTemplatePlan.java
=> metadata/plan/schemaregion/impl/SetTemplatePlanImpl.java} (55%)
copy
server/src/main/java/org/apache/iotdb/db/{qp/physical/sys/UnsetTemplatePlan.java
=> metadata/plan/schemaregion/impl/UnsetTemplatePlanImpl.java} (54%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/write/IActivateTemplateInClusterPlan.java
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetTriggerTablePlan.java
=>
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/write/IActivateTemplatePlan.java
(54%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetTriggerTablePlan.java
=>
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/write/IAutoCreateDeviceMNodePlan.java
(54%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetTriggerTablePlan.java
=>
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/write/IChangeAliasPlan.java
(53%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetTriggerTablePlan.java
=>
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/write/IChangeTagOffsetPlan.java
(53%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/write/ICreateAlignedTimeSeriesPlan.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/write/ICreateTimeSeriesPlan.java
copy
server/src/main/java/org/apache/iotdb/db/metadata/{mnode/IEntityMNode.java =>
plan/schemaregion/write/IDeactivateTemplatePlan.java} (50%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetTriggerTablePlan.java
=>
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/write/IDeleteTimeSeriesPlan.java
(52%)
copy
server/src/main/java/org/apache/iotdb/db/metadata/{mnode/IEntityMNode.java =>
plan/schemaregion/write/IPreDeactivateTemplatePlan.java} (50%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetTriggerTablePlan.java
=>
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/write/IPreDeleteTimeSeriesPlan.java
(54%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/write/IRollbackPreDeactivateTemplatePlan.java
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetTriggerTablePlan.java
=>
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/write/IRollbackPreDeleteTimeSeriesPlan.java
(53%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetTriggerTablePlan.java
=>
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/write/ISetTemplatePlan.java
(54%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetTriggerTablePlan.java
=>
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/write/IUnsetTemplatePlan.java
(54%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/SelectIntoUtils.java
rename
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/{GetRegionTask.java
=> GetRegionIdTask.java} (81%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/template/DeactivateSchemaTemplateTask.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/DeactivateTemplateNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/PreDeactivateTemplateNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/RollbackPreDeactivateTemplateNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/parameter/DeviceViewIntoPathDescriptor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/parameter/IntoPathDescriptor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/IntoComponent.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/IntoItem.java
rename
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/{GetRegionStatement.java
=> GetRegionIdStatement.java} (94%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/template/{ShowPathsUsingTemplateStatement.java
=> DeactivateTemplateStatement.java} (50%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetTriggerTablePlan.java
=>
server/src/main/java/org/apache/iotdb/db/service/ResourcesInformationHolder.java
(54%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/trigger/executor/TriggerFireResult.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/trigger/executor/TriggerFireVisitor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/trigger/service/TriggerInformationUpdater.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/utils/FilesUtils.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/utils/JarLoaderUtil.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/metadata/plan/SchemaRegionPlanCompatibilityTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/common/schematree/NodeRefTest.java
rename server/src/test/java/org/apache/iotdb/db/sync/{receiver/manager =>
persistence}/LocalSyncInfoTest.java (83%)
rename server/src/test/java/org/apache/iotdb/db/sync/{receiver/recovery =>
persistence}/SyncLogTest.java (83%)
delete mode 100644
server/src/test/java/org/apache/iotdb/db/sync/transport/SyncTransportTest.java
create mode 100644
tsfile/src/test/java/org/apache/iotdb/tsfile/write/record/TabletTest.java
