You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by gi...@apache.org on 2022/04/12 16:48:01 UTC
[iotdb] branch dependabot/maven/spark-iotdb-connector/com.fasterxml.jackson.core-jackson-databind-2.12.6.1 updated (5d4c4b93ce -> b18f47a652)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch dependabot/maven/spark-iotdb-connector/com.fasterxml.jackson.core-jackson-databind-2.12.6.1
in repository https://gitbox.apache.org/repos/asf/iotdb.git
discard 5d4c4b93ce Bump jackson-databind from 2.6.7 to 2.12.6.1 in /spark-iotdb-connector
add 26a762f40a [IOTDB-2846] Add Driver which implements ExecFragmentInstance interface (#5402)
add 8f553e98c3 When a storage group is deleted, every related template will unmark it now. (#5380)
add d638c145aa Add docs about how the community works (#5432)
add b1f2c38f26 Test delete the blank (#5433)
add 4e154bb57e [IOTDB-2851]ChunkReaderTest failed in CI (#5429)
add cf2ba5ad45 [IOTDB-2853] there is low version of integration and jdbc in library-udf\pom.xml (#5436)
add 6f22319260 [IOTDB-2855] Fix DeletionFileNodeTest error (#5435)
add 54623d8e30 Implement mpp scheduler interface (#5438)
add b1c391fefe [IoTDB-2837] Add check and sort for NumpyTablet to make sure timestamps are ordered (#5434)
add e2e8a16a90 Modify site/src/main/.vuepress/config.js to add REST API navigation for v0.13 (#5442)
add 34ca54a94d [IOTDB-2859] Fix python tablet with None value is incorrect (#5441)
add 3174c501cd [IOTDB-2727] data block manager impl (#5367)
add 347bd4a580 [IOTDB-2727] add DataBlockService#getInstance (#5446)
add 0c847d4297 Add english community about docs (#5445)
add 519293b078 [IOTDB-2838] Check and auto correct endian type for NumpyTablet (#5448)
add b5e16dfbb9 [IOTDB-2307]UDF Library Series Discovery Functions (#4848)
add c32fc88aad [IOTDB-2308]Library string (#4836)
add b5a028e785 [IOTDB-2302] Library-UDF Data Profiling Functions (#4731)
add e23879045d [IOTDB-2238] Library-UDF Data Quality Functions (#4691)
add becc9c0f65 [IOTDB-2306]Library-UDF Frequency Domain Functions (#4824)
add f5ec5baea9 [IoTDB-2799] Complete the basic implementation of QueryExecution and ClusterScheduler (#5430)
add edad9ddf0d [IOTDB-2862] Fix SQL injection risks of grafana-connector (#5450)
add e2f93a42ee rollback config.js (#5453)
add 40fd10e634 Remove redundant docs (#5454)
add 2e82976def [IOTDB-2303]Library dmatch (#4835)
add bd01ddea00 [IOTDB-2832] Initialize the consensus layer of the Datanode (#5417)
add 9d206f9568 [IOTDB-2857] Move methods in serviceProvider to sessionManager (#5440)
add 19d469775d Construct SinkHandle in LocalExecutionPlanner and remove the IOExecption in next and hasNext method of Operator (#5449)
add f3cc2821ba Update iotdb-doap.rdf (#5456)
add 87c8ab4ac8 [IOTDB-2304]Library-UDF Data Repairing Functions (#4833)
add 69b3920af7 Update iotdb-doap.rdf (#5457)
add dd67c0aacb Update iotdb-doap.rdf (#5458)
add a8f7439db9 [IOTDB-2841] add permission manager model (#5401)
add 931e309ad8 [IOTDB-2803]add AlterTimeSeriesNode and CreateAlignedTimeSeriesNode to PlanNodeType and its serialize and deserialize (#5444)
add 03f876ea19 [IOTDB-2864] Fix Read-only occurred when insert Text values to aligned timeseries (#5460)
add 1d946c71c7 Fix coverage check
add 99c824f4d0 [IOTDB-2807]Speed up the cross space compaction by multi-threads (#5415)
add 9ee5aedc1d [IOTDB-2801] New storage engine framework (#5357)
add 168cfe85ce [IOTDB-2827] Batch insert in new cluster (#5412)
add 43a8febae5 Modify the jdbc query time column to be empty (#5281)
add ce3661f2db user SerializeDeserializeUtil in confignode/AuthorPlan (#5467)
add 18c54ca050 Update ContributeGuide.md (#5463)
add 3c81f567f4 [IOTDB-1614] New WAL (#5320)
add cc78c84f99 [IOTDB-2658] Generate logical plan for query statement —— UT & Raw Data Query & Aggregation Query (#5469)
add 3e476e3756 [IOTDB-2806][InfluxDB] Compatibility of Apache IoTDB with InfluxDB - Complete UserGuide (#5351)
add 600ba97481 [IOTDB-2872] Rename vsg to dataRegion (#5470)
add fbe1bf2daf [IOTDB-2876] Definition of common thrift struct (#5471)
add 1c2886899d [IOTDB-2559][IOTDB-1840][IOTDB-2215][IOTDB-2216] Persistent Schema Management (#4732)
add 22fadbfc9c implement serialize and deserialize of SchemaTree (#5474)
add 9640b41e79 [IOTDB-2868] Construct ExchangeOperator in LocalExecutionPlanner (#5466)
add 703a64d2da [IOTDB-2687] Base partition policy of data (#5464)
add 5b24dcba37 [IOTDB-2878] Add getLeader interface to IConsensus (#5472)
add d160be9c22 [IOTDB-2800] Add plannode serialization/deserialization (#5455)
add e6e0d7407e Implement serialize and deserialize method for PathPatternTree (#5476)
add 8282f94043 [IOTDB-2727] tsblock serde (#5459)
add 45631f8e38 Add the ignored CMakeLists.txt (#5483)
add 1ab2e73108 [IOTDB-2881] add author serialize and deserialize and add serialize and deserialize test (#5475)
add c6634a0df3 Rocksdb-based metadata storage (#5295)
add 6fc6b11263 [IOTDB-2867] Response leader redirect when the current ConfigNode is not leader (#5481)
add 5d5f67f3dd [IoTDB-2666] Implement the RPC of Fragment dispatch and status track (#5478)
add c889624e3e [IOTDB-2817] Clear Compaction Framework (#5437)
add 506def32b0 [IOTDB-2804] DataRegion consensus state machine (#5479)
add 53089cee1f [IOTDB-2803] Implement create timeseries metadata operation through consensus layer in MPP framework (#5403)
add d3b30cf654 [IOTDB-2889] Add method converting TsBlock to TSQueryDataSet in QueryDataSetUtils (#5490)
add f33ee814b8 [IOTDB-2890] Dynamic port support for DataBlockManager (#5491)
add f0ff5510a6 [IOTDB-2879] Add influxdb-protocol module into the root pom (#5473)
add b18f47a652 Bump jackson-databind from 2.6.7 to 2.12.6.1 in /spark-iotdb-connector
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 (5d4c4b93ce)
\
N -- N -- N refs/heads/dependabot/maven/spark-iotdb-connector/com.fasterxml.jackson.core-jackson-databind-2.12.6.1 (b18f47a652)
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.
No new revisions were added by this update.
Summary of changes:
.github/workflows/influxdb-protocol.yml | 10 +-
.github/workflows/main-unix.yml | 3 +-
.github/workflows/main-win.yml | 3 +-
.github/workflows/sonar-coveralls.yml | 2 +-
README.md | 2 +-
README_ZH.md | 2 +-
.../apache/iotdb/db/qp/sql/InfluxDBSqlParser.g4 | 2 +-
client-cpp/pom.xml | 4 +
client-py/README.md | 35 +-
client-py/SessionAlignedTimeseriesExample.py | 16 +-
client-py/SessionExample.py | 50 +-
client-py/iotdb/Session.py | 104 +-
client-py/iotdb/utils/IoTDBConstants.py | 11 +
client-py/iotdb/utils/IoTDBRpcDataSet.py | 2 +-
client-py/iotdb/utils/NumpyTablet.py | 32 +-
client-py/iotdb/utils/Tablet.py | 31 +-
client-py/tests/tablet_performance_comparison.py | 8 +-
client-py/tests/test_aligned_timeseries.py | 79 +-
client-py/tests/test_numpy_tablet.py | 147 +
client-py/tests/test_session.py | 55 +-
client-py/tests/test_tablet.py | 109 +
client-py/tests/test_todf.py | 4 +-
.../java/org/apache/iotdb/cluster/ClientMain.java | 2 +-
.../iotdb/cluster/ClusterFileFlushPolicy.java | 11 +-
.../cluster/client/sync/SyncClientAdaptor.java | 2 +-
.../iotdb/cluster/coordinator/Coordinator.java | 30 +-
.../cluster/log/applier/AsyncDataLogApplier.java | 10 +-
.../iotdb/cluster/log/applier/BaseApplier.java | 4 +-
.../iotdb/cluster/log/applier/DataLogApplier.java | 14 +-
.../iotdb/cluster/metadata/CSchemaProcessor.java | 32 +-
.../partition/slot/SlotTimePartitionFilter.java | 2 +-
.../iotdb/cluster/query/ClusterPlanExecutor.java | 2 +-
.../iotdb/cluster/query/ClusterPlanRouter.java | 59 +-
.../iotdb/cluster/server/ClusterTSServiceImpl.java | 2 +-
.../server/basic/ClusterServiceProvider.java | 2 +-
.../handlers/forwarder/ForwardPlanHandler.java | 2 +-
.../cluster/server/member/DataGroupMember.java | 15 +-
.../cluster/server/member/MetaGroupMember.java | 4 +-
.../iotdb/cluster/server/member/RaftMember.java | 4 +-
.../cluster/server/service/BaseAsyncService.java | 4 +-
.../cluster/server/service/BaseSyncService.java | 2 +-
.../server/service/DataGroupServiceImpls.java | 2 +-
.../apache/iotdb/cluster/utils/PartitionUtils.java | 2 +-
.../apache/iotdb/cluster/utils/StatusUtils.java | 6 +-
.../cluster/client/sync/SyncClientAdaptorTest.java | 2 +-
.../iotdb/cluster/common/TestAsyncDataClient.java | 2 +-
.../cluster/log/applier/DataLogApplierTest.java | 10 +-
.../cluster/log/snapshot/FileSnapshotTest.java | 14 +-
.../log/snapshot/MetaSimpleSnapshotTest.java | 2 +-
.../log/snapshot/PartitionedSnapshotTest.java | 6 +-
.../cluster/log/snapshot/PullSnapshotTaskTest.java | 4 +-
.../handlers/forwarder/ForwardPlanHandlerTest.java | 2 +-
.../iotdb/cluster/server/member/BaseMember.java | 9 +-
.../cluster/server/member/DataGroupMemberTest.java | 4 +-
.../cluster/server/member/MetaGroupMemberTest.java | 6 +-
.../iotdb/cluster/utils/SerializeUtilTest.java | 2 -
confignode/pom.xml | 10 +
confignode/src/assembly/confignode.xml | 9 +-
.../resources/conf/iotdb-confignode.properties | 41 +-
.../iotdb/confignode/conf/ConfigNodeConf.java | 55 +-
.../iotdb/confignode/conf/ConfigNodeConfCheck.java | 29 +-
.../confignode/conf/ConfigNodeDescriptor.java | 47 +-
.../response/DataNodeConfigurationDataSet.java | 66 +
.../consensus/response/DataNodesInfoDataSet.java | 33 +-
.../consensus/response/DataPartitionDataSet.java | 108 +-
.../consensus/response/PermissionInfoDataSet.java | 26 +
.../consensus/response/SchemaPartitionDataSet.java | 94 +-
.../response/StorageGroupSchemaDataSet.java | 27 +-
.../statemachine/PartitionRegionStateMachine.java | 7 +-
.../iotdb/confignode/manager/ConfigManager.java | 142 +-
.../iotdb/confignode/manager/ConsensusManager.java | 94 +-
.../iotdb/confignode/manager/DataNodeManager.java | 91 +-
.../apache/iotdb/confignode/manager/Manager.java | 96 +-
.../iotdb/confignode/manager/PartitionManager.java | 193 +-
.../confignode/manager/PermissionManager.java | 40 +
.../iotdb/confignode/manager/RegionManager.java | 128 +-
.../iotdb/confignode/partition/DataRegionInfo.java | 66 -
.../confignode/partition/SchemaRegionInfo.java | 59 -
.../confignode/partition/StorageGroupSchema.java | 77 +-
.../persistence/AuthorInfoPersistence.java | 146 +
.../persistence/DataNodeInfoPersistence.java | 124 +-
.../persistence/PartitionInfoPersistence.java | 145 +-
.../persistence/RegionInfoPersistence.java | 215 +-
.../iotdb/confignode/physical/PhysicalPlan.java | 57 +-
.../confignode/physical/PhysicalPlanType.java | 30 +-
.../physical/crud/CreateDataPartitionPlan.java | 128 +
.../physical/crud/CreateRegionsPlan.java | 96 +
.../physical/crud/CreateSchemaPartitionPlan.java | 39 +
.../crud/GetOrCreateDataPartitionPlan.java | 139 +
.../crud/GetOrCreateSchemaPartitionPlan.java | 98 +
.../iotdb/confignode/physical/sys/AuthorPlan.java | 248 ++
.../confignode/physical/sys/DataPartitionPlan.java | 78 -
.../physical/sys/QueryDataNodeInfoPlan.java | 14 +
.../physical/sys/RegisterDataNodePlan.java | 22 +-
.../physical/sys/SchemaPartitionPlan.java | 97 -
.../physical/sys/SetStorageGroupPlan.java | 43 +-
.../confignode/service/executor/PlanExecutor.java | 65 +-
.../server/ConfigNodeRPCServerProcessor.java | 234 +-
.../apache/iotdb/confignode/auth/AuthorTest.java | 44 +
.../confignode/consensus/RatisConsensusDemo.java | 43 +-
.../manager/ConfigManagerManualTest.java | 31 +-
.../hash/DeviceGroupHashExecutorManualTest.java | 2 +-
.../physical/SerializeDeserializeUT.java | 346 ++
.../server/ConfigNodeRPCServerProcessorTest.java | 414 ++-
consensus/README.md | 126 +-
consensus/pom.xml | 2 +-
.../apache/iotdb/consensus/ConsensusFactory.java | 57 +
.../org/apache/iotdb/consensus/IConsensus.java | 2 +
.../iotdb/consensus/common/ConsensusType.java | 54 -
.../common/response/ConsensusWriteResponse.java | 6 +-
.../ConsensusGroupAlreadyExistException.java | 2 +-
.../ratis/ApplicationStateMachineProxy.java | 2 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 169 +-
.../iotdb/consensus/ratis/RequestMessage.java | 1 +
.../iotdb/consensus/ratis/ResponseMessage.java | 2 +-
.../org/apache/iotdb/consensus/ratis/Utils.java | 31 +-
.../consensus/standalone/StandAloneConsensus.java | 30 +-
.../consensus/standalone/StandAloneServerImpl.java | 2 +-
.../consensus/statemachine/EmptyStateMachine.java | 2 +-
.../consensus/statemachine/IStateMachine.java | 2 +-
.../iotdb/consensus/ratis/RatisConsensusTest.java | 26 +-
.../apache/iotdb/consensus/ratis/UtilsTest.java | 7 +-
.../standalone/StandAloneConsensusTest.java | 45 +-
distribution/pom.xml | 6 +
docs/Community/About.md | 20 +
docs/Community/Community-Powered By.md | 2 +-
docs/UserGuide/API/InfluxDB-Protocol.md | 341 ++
.../UserGuide/API/Programming-Python-Native-API.md | 35 +-
docs/UserGuide/Data-Concept/Time-Partition.md | 8 +-
docs/UserGuide/Data-Modeling/DataRegion.md | 55 +
.../UserGuide/Data-Modeling/VirtualStorageGroup.md | 55 -
docs/UserGuide/Library-UDF/Anomaly-Detection.md | 523 ---
docs/UserGuide/Reference/Config-Manual.md | 41 +-
docs/zh/Community/About.md | 63 +
docs/zh/Development/ContributeGuide.md | 11 +-
docs/zh/UserGuide/API/InfluxDB-Protocol.md | 122 +-
.../UserGuide/API/Programming-Python-Native-API.md | 34 +-
docs/zh/UserGuide/Data-Concept/Time-Partition.md | 2 -
docs/zh/UserGuide/Data-Modeling/DataRegion.md | 53 +
.../UserGuide/Data-Modeling/VirtualStorageGroup.md | 53 -
docs/zh/UserGuide/Library-UDF/Anomaly Detection.md | 530 ---
docs/zh/UserGuide/Reference/Config-Manual.md | 16 +-
docs/zh/UserGuide/UDF-Library/Data-Repairing.md | 1 -
example/rest-client-c-example/CMakeLists.txt | 25 +
.../controller/DatabaseConnectController.java | 3 +-
.../iotdb/web/grafana/dao/impl/BasicDaoImpl.java | 43 +-
influxdb-protocol/pom.xml | 38 +-
.../iotdb/influxdb/protocol/dto/SessionPoint.java | 6 +-
.../protocol/impl/IoTDBInfluxDBService.java | 12 +-
.../iotdb/influxdb/session/InfluxDBSession.java | 42 +-
.../iotdb/integration/env/ClusterEnvConfig.java | 5 +-
.../org/apache/iotdb/itbase/env/BaseConfig.java | 2 +-
.../iotdb/db/integration/IoTDBCompleteIT.java | 9 +-
.../db/integration/IoTDBLoadExternalTsfileIT.java | 6 +-
.../db/integration/IoTDBNewTsFileCompactionIT.java | 7 +-
.../apache/iotdb/db/integration/IoTDBTtlIT.java | 2 +-
.../aggregation/IoTDBAggregationIT.java | 28 +
.../aligned/IOTDBInsertAlignedValuesIT.java | 372 --
.../aligned/IoTDBInsertAlignedValuesIT.java | 391 ++
.../aligned/IoTDBLoadExternalAlignedTsFileIT.java | 6 +-
.../db/integration/env/StandaloneEnvConfig.java | 4 +-
.../IoTDBQueryVersionAdaptionIT.java | 1 -
.../iotdb/session/IoTDBSessionComplexIT.java | 7 +-
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 2 +-
.../org/apache/iotdb/jdbc/IoTDBSQLException.java | 2 +-
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 2 +-
.../test/java/org/apache/iotdb/jdbc/BatchTest.java | 2 +-
.../org/apache/iotdb/jdbc/IoTDBConnectionTest.java | 2 +-
.../iotdb/jdbc/IoTDBDatabaseMetadataTest.java | 2 +-
.../apache/iotdb/jdbc/IoTDBJDBCResultSetTest.java | 2 +-
.../iotdb/jdbc/IoTDBPreparedStatementTest.java | 1 +
.../test/java/org/apache/iotdb/jdbc/UtilsTest.java | 2 +-
library-udf/pom.xml | 8 +-
.../org/apache/iotdb/library/anomaly/UDTFIQR.java | 111 -
.../apache/iotdb/library/anomaly/UDTFKSigma.java | 127 -
.../org/apache/iotdb/library/anomaly/UDTFLOF.java | 215 --
.../iotdb/library/anomaly/UDTFMissDetect.java | 74 -
.../apache/iotdb/library/anomaly/UDTFRange.java | 97 -
.../iotdb/library/anomaly/UDTFTwoSidedFilter.java | 92 -
.../iotdb/library/anomaly/util/MissDetector.java | 240 --
.../library/anomaly/util/StreamMissDetector.java | 189 -
.../iotdb/library/anomaly/util/WindowDetect.java | 96 -
.../org/apache/iotdb/library/dmatch/UDAFCov.java | 86 +
.../org/apache/iotdb/library/dmatch/UDAFDtw.java | 91 +
.../apache/iotdb/library/dmatch/UDAFPearson.java | 95 +
.../apache/iotdb/library/dmatch/UDTFPtnSym.java | 98 +
.../org/apache/iotdb/library/dmatch/UDTFXCorr.java | 86 +
.../library/dmatch/util/CrossCorrelation.java | 54 +
.../iotdb/library/dprofile/UDAFIntegral.java | 113 +
.../iotdb/library/dprofile/UDAFIntegralAvg.java | 89 +
.../org/apache/iotdb/library/dprofile/UDAFMad.java | 85 +
.../apache/iotdb/library/dprofile/UDAFMedian.java | 85 +
.../apache/iotdb/library/dprofile/UDAFMode.java | 177 +
.../iotdb/library/dprofile/UDAFPercentile.java | 168 +
.../apache/iotdb/library/dprofile/UDAFPeriod.java | 142 +
.../apache/iotdb/library/dprofile/UDAFSkew.java | 73 +
.../apache/iotdb/library/dprofile/UDAFSpread.java | 124 +
.../apache/iotdb/library/dprofile/UDAFStddev.java | 69 +
.../org/apache/iotdb/library/dprofile/UDTFACF.java | 79 +
.../iotdb/library/dprofile/UDTFDistinct.java | 189 +
.../iotdb/library/dprofile/UDTFHistogram.java | 88 +
.../apache/iotdb/library/dprofile/UDTFMinMax.java | 110 +
.../apache/iotdb/library/dprofile/UDTFMvAvg.java | 81 +
.../apache/iotdb/library/dprofile/UDTFPACF.java | 95 +
.../org/apache/iotdb/library/dprofile/UDTFQLB.java | 104 +
.../iotdb/library/dprofile/UDTFResample.java | 116 +
.../apache/iotdb/library/dprofile/UDTFSample.java | 133 +
.../apache/iotdb/library/dprofile/UDTFSegment.java | 123 +
.../apache/iotdb/library/dprofile/UDTFSpline.java | 100 +
.../apache/iotdb/library/dprofile/UDTFZScore.java | 105 +
.../library/dprofile/util/CrossCorrelation.java | 53 +
.../dprofile/util/ExactOrderStatistics.java | 281 ++
.../iotdb/library/dprofile/util/GKArray.java | 179 +
.../iotdb/library/dprofile/util/MADSketch.java | 283 ++
.../apache/iotdb/library/dprofile/util/Mad.java | 34 +
.../iotdb/library/dprofile/util/MaxSelector.java | 76 +
.../iotdb/library/dprofile/util/Resampler.java | 243 ++
.../iotdb/library/dprofile/util/Segment.java | 161 +
.../iotdb/library/dprofile/util/YuleWalker.java | 71 +
.../iotdb/library/dquality/UDTFCompleteness.java | 76 +
.../iotdb/library/dquality/UDTFConsistency.java | 74 +
.../iotdb/library/dquality/UDTFTimeliness.java | 73 +
.../iotdb/library/dquality/UDTFValidity.java | 73 +
.../library/dquality/util/TimeSeriesQuality.java | 243 ++
.../iotdb/library/drepair/UDTFTimestampRepair.java | 102 +
.../iotdb/library/drepair/UDTFValueFill.java | 104 +
.../iotdb/library/drepair/UDTFValueRepair.java | 122 +
.../apache/iotdb/library/drepair/util/ARFill.java | 93 +
.../iotdb/library/drepair/util/LikelihoodFill.java | 128 +
.../iotdb/library/drepair/util/LinearFill.java | 57 +
.../iotdb/library/drepair/util/LsGreedy.java | 141 +
.../apache/iotdb/library/drepair/util/MAFill.java | 57 +
.../iotdb/library/drepair/util/MeanFill.java | 40 +
.../iotdb/library/drepair/util/PreviousFill.java | 49 +
.../apache/iotdb/library/drepair/util/Screen.java | 138 +
.../iotdb/library/drepair/util/ScreenFill.java | 154 +
.../library/drepair/util/TimestampInterval.java | 213 ++
.../library/drepair/util/TimestampRepair.java | 154 +
.../iotdb/library/drepair/util/ValueFill.java | 81 +
.../iotdb/library/drepair/util/ValueRepair.java | 130 +
.../apache/iotdb/library/frequency/UDTFConv.java | 82 +
.../apache/iotdb/library/frequency/UDTFDWT.java | 96 +
.../apache/iotdb/library/frequency/UDTFDeconv.java | 112 +
.../apache/iotdb/library/frequency/UDTFFFT.java | 106 +
.../iotdb/library/frequency/UDTFHighPass.java | 98 +
.../apache/iotdb/library/frequency/UDTFIDWT.java | 97 +
.../apache/iotdb/library/frequency/UDTFIFFT.java | 113 +
.../iotdb/library/frequency/UDTFLowPass.java | 95 +
.../iotdb/library/frequency/util/DWTUtil.java | 228 ++
.../iotdb/library/frequency/util/FFTUtil.java | 82 +
.../library/series/UDTFConsecutiveSequences.java | 78 +
.../library/series/UDTFConsecutiveWindows.java | 90 +
.../iotdb/library/series/util/ConsecutiveUtil.java | 129 +
.../iotdb/library/string/UDTFRegexMatch.java | 71 +
.../iotdb/library/string/UDTFRegexReplace.java | 130 +
.../iotdb/library/string/UDTFRegexSplit.java | 76 +
.../iotdb/library/string/UDTFStrReplace.java | 153 +
.../iotdb/library/util/LinearRegression.java | 8 +-
.../apache/iotdb/library/anomaly/AnomalyTests.java | 1533 --------
.../apache/iotdb/library/dmatch/DMatchTests.java | 826 +++++
.../iotdb/library/dprofile/DProfileTests.java | 629 ++++
.../iotdb/library/dquality/DQualityTests.java | 385 ++
.../apache/iotdb/library/drepair/DRepairTests.java | 317 ++
.../iotdb/library/frequency/FrequencyTests.java | 300 ++
.../apache/iotdb/library/series/SeriesTest.java | 467 +++
.../apache/iotdb/library/string/StringTests.java | 258 ++
.../iotdb/commons/cluster/DataNodeLocation.java | 77 +
.../org/apache/iotdb/commons/cluster/Endpoint.java | 16 +-
.../commons/concurrent/IoTDBThreadPoolFactory.java | 12 +
.../iotdb/commons/concurrent/ThreadName.java | 10 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 7 +
.../iotdb/commons/consensus/ConsensusGroupId.java | 88 +-
.../iotdb/commons/consensus/DataRegionId.java | 78 +
.../iotdb/commons/consensus/PartitionRegionId.java | 78 +
.../iotdb/commons/consensus/SchemaRegionId.java | 78 +
.../apache/iotdb/commons/hash/APHashExecutor.java | 42 -
.../iotdb/commons/hash/BKDRHashExecutor.java | 40 -
.../commons/hash/DeviceGroupHashExecutor.java | 31 -
.../apache/iotdb/commons/hash/JSHashExecutor.java | 40 -
.../iotdb/commons/hash/SDBMHashExecutor.java | 38 -
.../iotdb/commons/partition/DataNodeLocation.java | 102 -
.../iotdb/commons/partition/DataPartition.java | 132 +-
.../iotdb/commons/partition/RegionReplicaSet.java | 56 +-
.../iotdb/commons/partition/SchemaPartition.java | 49 +-
.../commons/partition/SeriesPartitionSlot.java | 35 +-
.../iotdb/commons/partition/TimePartitionSlot.java | 33 +
.../executor/SeriesPartitionExecutor.java | 33 +
.../partition/executor/hash/APHashExecutor.java | 45 +
.../partition/executor/hash/BKDRHashExecutor.java | 43 +
.../partition/executor/hash/JSHashExecutor.java | 43 +
.../partition/executor/hash/SDBMHashExecutor.java | 41 +
.../apache/iotdb/commons/utils/CommonUtils.java | 12 +-
.../apache/iotdb/commons/utils/StatusUtils.java | 226 ++
.../apache/iotdb/commons/ConsensusGroupIdTest.java | 53 +
pom.xml | 3 +-
server/pom.xml | 15 +-
.../resources/conf/iotdb-engine.properties | 237 +-
.../assembly/resources/tools/rocksdb-transfer.bat | 126 +
.../assembly/resources/tools/rocksdb-transfer.sh | 82 +
.../db/auth/authorizer/AuthorizerManager.java | 190 +
.../iotdb/db/auth/authorizer/BasicAuthorizer.java | 1 +
.../db/auth/authorizer/ClusterAuthorizer.java | 23 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 496 ++-
.../org/apache/iotdb/db/conf/IoTDBConfigCheck.java | 41 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 257 +-
.../db/conf/directories/DirectoryManager.java | 4 -
.../iotdb/db/conf/directories/FolderManager.java | 65 +
.../strategy/DirectoryStrategyType.java | 26 +
.../iotdb/db/consensus/ConsensusExample.java | 113 -
.../apache/iotdb/db/consensus/ConsensusImpl.java | 77 +
.../iotdb/db/consensus/ConsensusManager.java | 72 +
.../consensus/statemachine/BaseStateMachine.java | 14 +-
.../statemachine/DataRegionStateMachine.java | 53 +-
.../statemachine/SchemaRegionStateMachine.java | 20 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 175 +-
.../apache/iotdb/db/engine/StorageEngineV2.java | 595 +++
.../compaction/CompactionExceptionHandler.java | 247 ++
.../compaction/CompactionMetricsManager.java | 12 +-
.../compaction/CompactionRecoverManager.java | 119 +
.../db/engine/compaction/CompactionScheduler.java | 165 +-
.../compaction/CompactionTaskComparator.java | 112 -
.../engine/compaction/CompactionTaskManager.java | 23 +-
.../db/engine/compaction/CompactionUtils.java | 345 +-
.../db/engine/compaction/TsFileIdentifier.java | 229 --
.../DefaultCompactionTaskComparatorImpl.java | 110 +
.../comparator/ICompactionTaskComparator.java | 35 +
.../constant/CrossCompactionPerformer.java | 41 +
.../constant/CrossCompactionSelector.java | 71 +
.../constant/InnerSeqCompactionPerformer.java | 41 +
.../constant/InnerSequenceCompactionSelector.java | 48 +
.../constant/InnerUnseqCompactionPerformer.java | 41 +
.../InnerUnsequenceCompactionSelector.java | 48 +
.../AbstractCrossSpaceCompactionSelector.java | 56 -
.../cross/AbstractCrossSpaceCompactionTask.java | 113 -
.../compaction/cross/CrossCompactionStrategy.java | 79 -
.../compaction/cross/CrossSpaceCompactionTask.java | 281 ++
.../cross/CrossSpaceCompactionTaskFactory.java | 49 -
.../compaction/cross/ICrossSpaceSelector.java | 30 +
.../RewriteCrossSpaceCompactionResource.java | 206 ++
.../RewriteCrossSpaceCompactionSelector.java | 62 +-
.../manage/CrossSpaceCompactionResource.java | 206 --
.../selector/ICrossSpaceMergeFileSelector.java | 2 -
.../cross/rewrite/selector/IMergePathSelector.java | 31 -
.../cross/rewrite/selector/MergeFileStrategy.java | 27 -
.../cross/rewrite/selector/NaivePathSelector.java | 55 -
.../selector/RewriteCompactionFileSelector.java | 12 +-
.../rewrite/task/ReadPointPerformerSubTask.java | 107 +
.../task/RewriteCrossSpaceCompactionTask.java | 254 --
.../AbstractInnerSpaceCompactionSelector.java | 59 -
.../inner/AbstractInnerSpaceCompactionTask.java | 160 -
.../compaction/inner/IInnerSeqSpaceSelector.java | 28 +
.../compaction/inner/IInnerUnseqSpaceSelector.java | 28 +
.../compaction/inner/InnerCompactionStrategy.java | 80 -
.../compaction/inner/InnerSpaceCompactionTask.java | 367 ++
.../inner/InnerSpaceCompactionTaskFactory.java | 48 -
.../sizetiered/SizeTieredCompactionSelector.java | 70 +-
.../inner/sizetiered/SizeTieredCompactionTask.java | 280 --
.../inner/utils/InnerSpaceCompactionUtils.java | 302 --
.../compaction/log/CompactionLogAnalyzer.java | 162 +
.../db/engine/compaction/log/CompactionLogger.java | 83 +
.../db/engine/compaction/log/TsFileIdentifier.java | 229 ++
.../compaction/performer/ICompactionPerformer.java | 49 +
.../performer/ICrossCompactionPerformer.java | 27 +
.../performer/ISeqCompactionPerformer.java | 27 +
.../performer/IUnseqCompactionPerformer.java | 27 +
.../impl/ReadChunkCompactionPerformer.java | 166 +
.../impl/ReadPointCompactionPerformer.java | 360 ++
.../task/AbstractCompactionSelector.java | 29 -
.../compaction/task/AbstractCompactionTask.java | 4 +-
.../task/CompactionExceptionHandler.java | 248 --
.../compaction/task/CompactionRecoverManager.java | 131 -
.../compaction/task/CompactionRecoverTask.java | 6 +-
.../compaction/task/ICompactionSelector.java | 54 +
.../utils/log/CompactionLogAnalyzer.java | 163 -
.../compaction/utils/log/CompactionLogger.java | 84 -
.../writer/AbstractCompactionWriter.java | 64 +-
.../writer/CrossSpaceCompactionWriter.java | 80 +-
.../writer/InnerSpaceCompactionWriter.java | 27 +-
.../org/apache/iotdb/db/engine/cq/CQLogReader.java | 2 +-
.../org/apache/iotdb/db/engine/cq/CQLogWriter.java | 2 +-
.../iotdb/db/engine/cq/ContinuousQueryTask.java | 4 +-
.../iotdb/db/engine/flush/FlushListener.java | 17 +-
.../apache/iotdb/db/engine/flush/FlushStatus.java | 28 +
.../iotdb/db/engine/flush/TsFileFlushPolicy.java | 14 +-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 329 +-
.../engine/memtable/AlignedWritableMemChunk.java | 51 +
.../memtable/AlignedWritableMemChunkGroup.java | 22 +
.../apache/iotdb/db/engine/memtable/IMemTable.java | 22 +-
.../db/engine/memtable/IWritableMemChunk.java | 3 +-
.../db/engine/memtable/IWritableMemChunkGroup.java | 3 +-
.../iotdb/db/engine/memtable/WritableMemChunk.java | 28 +
.../db/engine/memtable/WritableMemChunkGroup.java | 37 +
.../iotdb/db/engine/storagegroup/DataRegion.java | 3493 ++++++++++++++++++
.../db/engine/storagegroup/StorageGroupInfo.java | 49 +-
.../db/engine/storagegroup/TsFileManager.java | 15 +-
.../db/engine/storagegroup/TsFileProcessor.java | 308 +-
.../engine/storagegroup/TsFileProcessorInfo.java | 9 +-
.../db/engine/storagegroup/TsFileResource.java | 4 +-
.../storagegroup/VirtualStorageGroupProcessor.java | 3238 -----------------
.../dataregion/HashVirtualPartitioner.java | 58 +
.../dataregion/StorageGroupManager.java | 489 +++
.../dataregion/VirtualPartitioner.java | 39 +
.../virtualSg/HashVirtualPartitioner.java | 58 -
.../virtualSg/StorageGroupManager.java | 525 ---
.../storagegroup/virtualSg/VirtualPartitioner.java | 39 -
.../engine/trigger/service/TriggerLogReader.java | 2 +-
.../engine/trigger/service/TriggerLogWriter.java | 4 +-
.../service/TriggerRegistrationService.java | 10 +-
.../iotdb/db/exception/BatchProcessException.java | 2 +-
.../iotdb/db/exception/DataRegionException.java | 35 +
.../exception/StorageGroupProcessorException.java | 35 -
.../metadata/AcquireLockTimeoutException.java | 26 +
.../metadata/DifferentTemplateException.java | 33 -
.../metadata/DuplicatedTemplateException.java | 31 -
.../metadata/NoTemplateOnMNodeException.java | 33 -
.../metadata/StorageGroupNotSetException.java | 6 +
.../metadata/TemplateImcompatibeException.java | 40 -
.../metadata/TemplateIsInUseException.java | 33 -
.../metadata/UndefinedTemplateException.java | 31 -
.../metadata/cache/MNodeNotCachedException.java | 28 +
.../metadata/cache/MNodeNotPinnedException.java | 29 +
.../schemafile/RecordDuplicatedException.java | 34 +
.../metadata/schemafile/SchemaFileNotExists.java | 34 +
.../schemafile/SchemaPageOverflowException.java | 34 +
.../schemafile/SegmentNotFoundException.java | 41 +
.../schemafile/SegmentOverflowException.java | 41 +
.../template/DifferentTemplateException.java | 34 +
.../template/DuplicatedTemplateException.java | 32 +
.../template/NoTemplateOnMNodeException.java | 34 +
.../template/TemplateImcompatibeException.java | 41 +
.../template/TemplateIsInUseException.java | 34 +
.../template/UndefinedTemplateException.java | 32 +
.../exception/sql/StatementAnalyzeException.java | 6 +
.../iotdb/db/metadata/Executor/SchemaVisitor.java | 55 +
.../iotdb/db/metadata/LocalConfigManager.java | 95 +-
.../db/metadata/LocalSchemaPartitionTable.java | 26 +-
.../iotdb/db/metadata/LocalSchemaProcessor.java | 71 +-
.../apache/iotdb/db/metadata/MetadataConstant.java | 4 +
.../iotdb/db/metadata/idtable/IDTableManager.java | 19 +-
.../iotdb/db/metadata/idtable/entry/IDeviceID.java | 4 +
.../idtable/entry/InsertMeasurementMNode.java | 23 +-
.../db/metadata/idtable/entry/PlainDeviceID.java | 12 +
.../db/metadata/idtable/entry/SHA256DeviceID.java | 21 +
.../db/metadata/lastCache/LastCacheManager.java | 2 +-
.../iotdb/db/metadata/logfile/MLogReader.java | 2 +-
.../iotdb/db/metadata/logfile/MLogWriter.java | 2 +-
.../iotdb/db/metadata/mnode/EntityMNode.java | 8 +
.../org/apache/iotdb/db/metadata/mnode/IMNode.java | 17 +-
.../iotdb/db/metadata/mnode/InternalMNode.java | 29 +-
.../org/apache/iotdb/db/metadata/mnode/MNode.java | 25 +-
.../apache/iotdb/db/metadata/mnode/MNodeUtils.java | 1 +
.../iotdb/db/metadata/mnode/MeasurementMNode.java | 16 +-
.../db/metadata/mnode/StorageGroupEntityMNode.java | 11 +-
.../iotdb/db/metadata/mnode/StorageGroupMNode.java | 8 +
.../metadata/mnode/container/IMNodeContainer.java | 25 +
.../mnode/container/MNodeContainerMapImpl.java | 26 +
.../metadata/mnode/container/MNodeContainers.java | 103 +
.../mnode/estimator/BasicMNodSizeEstimator.java | 117 +
.../mnode/estimator/IMNodeSizeEstimator.java | 38 +
.../db/metadata/mnode/iterator/IMNodeIterator.java | 28 +
.../db/metadata/mnode/iterator/MNodeIterator.java | 48 +
.../iotdb/db/metadata/mtree/MTreeAboveSG.java | 46 +-
.../iotdb/db/metadata/mtree/MTreeBelowSG.java | 854 +++--
.../db/metadata/mtree/store/CachedMTreeStore.java | 590 +++
.../iotdb/db/metadata/mtree/store/IMTreeStore.java | 61 +
.../db/metadata/mtree/store/MemMTreeStore.java | 170 +
.../mtree/store/disk/CachedMNodeContainer.java | 428 +++
.../mtree/store/disk/ICachedMNodeContainer.java | 80 +
.../mtree/store/disk/MTreeFlushTaskManager.java | 75 +
.../mtree/store/disk/MTreeReleaseTaskManager.java | 74 +
.../db/metadata/mtree/store/disk/SegmentLock.java | 91 +
.../mtree/store/disk/cache/CacheEntry.java | 48 +
.../mtree/store/disk/cache/CacheManager.java | 537 +++
.../mtree/store/disk/cache/ICacheManager.java | 52 +
.../mtree/store/disk/cache/LRUCacheManager.java | 256 ++
.../mtree/store/disk/cache/PlainCacheManager.java | 72 +
.../disk/memcontrol/CachedMNodeSizeEstimator.java | 71 +
.../mtree/store/disk/memcontrol/IMemManager.java | 52 +
.../store/disk/memcontrol/MemManagerHolder.java | 41 +
.../MemManagerNodeEstimatedSizeBasedImpl.java | 132 +
.../memcontrol/MemManagerNodeNumBasedImpl.java | 105 +
.../mtree/store/disk/schemafile/ISchemaFile.java | 63 +
.../mtree/store/disk/schemafile/ISchemaPage.java | 125 +
.../mtree/store/disk/schemafile/ISegment.java | 95 +
.../store/disk/schemafile/MockSchemaFile.java | 235 ++
.../mtree/store/disk/schemafile/RecordUtils.java | 339 ++
.../mtree/store/disk/schemafile/SchemaFile.java | 937 +++++
.../mtree/store/disk/schemafile/SchemaPage.java | 623 ++++
.../mtree/store/disk/schemafile/Segment.java | 708 ++++
.../db/metadata/mtree/traverser/Traverser.java | 169 +-
.../traverser/collector/CollectorTraverser.java | 11 +-
.../mtree/traverser/collector/EntityCollector.java | 11 +-
.../traverser/collector/MNodeAboveSGCollector.java | 6 +-
.../mtree/traverser/collector/MNodeCollector.java | 6 +-
.../traverser/collector/MeasurementCollector.java | 11 +-
.../traverser/collector/StorageGroupCollector.java | 6 +-
.../mtree/traverser/counter/CounterTraverser.java | 6 +-
.../mtree/traverser/counter/EntityCounter.java | 6 +-
.../counter/MNodeAboveSGLevelCounter.java | 6 +-
.../mtree/traverser/counter/MNodeLevelCounter.java | 5 +-
.../traverser/counter/MeasurementCounter.java | 6 +-
.../counter/MeasurementGroupByLevelCounter.java | 6 +-
.../traverser/counter/StorageGroupCounter.java | 6 +-
.../apache/iotdb/db/metadata/path/AlignedPath.java | 55 +
.../iotdb/db/metadata/path/MeasurementPath.java | 41 +
.../apache/iotdb/db/metadata/path/PartialPath.java | 30 +
.../db/metadata/path/PathDeserializeUtil.java | 59 +
.../iotdb/db/metadata/rescon/MemoryStatistics.java | 97 +
.../db/metadata/rescon/SchemaResourceManager.java | 67 +
.../db/metadata/rescon/TimeseriesStatistics.java | 38 +-
.../db/metadata/schemaregion/ISchemaRegion.java | 193 +
.../db/metadata/schemaregion/SchemaEngine.java | 48 +-
.../db/metadata/schemaregion/SchemaEngineMode.java | 26 +
.../db/metadata/schemaregion/SchemaRegion.java | 637 ++--
.../metadata/schemaregion/SchemaRegionUtils.java | 59 +
.../schemaregion/rocksdb/CheckKeyResult.java | 50 +
.../schemaregion/rocksdb/RSchemaConstants.java | 76 +
.../schemaregion/rocksdb/RSchemaLogger.java | 61 +
.../rocksdb/RSchemaReadWriteHandler.java | 514 +++
.../schemaregion/rocksdb/RSchemaRegion.java | 1962 ++++++++++
.../schemaregion/rocksdb/RSchemaUtils.java | 592 +++
.../schemaregion/rocksdb/mnode/REntityMNode.java | 124 +
.../schemaregion/rocksdb/mnode/RInternalMNode.java | 197 +
.../schemaregion/rocksdb/mnode/RMNode.java | 234 ++
.../schemaregion/rocksdb/mnode/RMNodeType.java | 49 +
.../rocksdb/mnode/RMNodeValueType.java | 47 +
.../rocksdb/mnode/RMeasurementMNode.java | 262 ++
.../rocksdb/mnode/RStorageGroupMNode.java | 102 +
.../storagegroup/IStorageGroupSchemaManager.java | 2 +-
.../storagegroup/StorageGroupSchemaManager.java | 2 +-
.../apache/iotdb/db/metadata/tag/TagManager.java | 20 +-
.../iotdb/db/metadata/template/Template.java | 73 +-
.../db/metadata/template/TemplateManager.java | 74 +-
.../db/metadata/upgrade/MetadataUpgrader.java | 5 +-
.../iotdb/db/mpp/buffer/DataBlockManager.java | 358 +-
.../db/mpp/buffer/DataBlockManagerService.java | 90 -
.../DataBlockManagerServiceThriftHandler.java | 44 -
.../iotdb/db/mpp/buffer/DataBlockService.java | 141 +
.../mpp/buffer/DataBlockServiceClientFactory.java | 24 +-
.../iotdb/db/mpp/buffer/DataBlockServiceImpl.java | 50 -
.../mpp/buffer/DataBlockServiceThriftHandler.java | 44 +
.../iotdb/db/mpp/buffer/IDataBlockManager.java | 25 +-
.../apache/iotdb/db/mpp/buffer/ISinkHandle.java | 35 +-
.../apache/iotdb/db/mpp/buffer/ISourceHandle.java | 21 +-
.../org/apache/iotdb/db/mpp/buffer/SinkHandle.java | 366 ++
.../apache/iotdb/db/mpp/buffer/SourceHandle.java | 372 +-
.../apache/iotdb/db/mpp/buffer/StubSinkHandle.java | 88 +
.../iotdb/db/mpp/buffer/TsBlockSerdeFactory.java | 31 +
.../org/apache/iotdb/db/mpp/common/DataRegion.java | 58 -
.../iotdb/db/mpp/common/FragmentInstanceId.java | 46 +
.../iotdb/db/mpp/common/MPPQueryContext.java | 25 +-
.../apache/iotdb/db/mpp/common/PlanFragmentId.java | 32 +
.../org/apache/iotdb/db/mpp/common/QueryId.java | 18 +
.../iotdb/db/mpp/common/ResultNodeContext.java | 67 +
.../db/mpp/common/filter/BasicFunctionFilter.java | 28 +-
.../mpp/common/filter/FilterDeserializeUtil.java | 63 +
.../iotdb/db/mpp/common/filter/FunctionFilter.java | 43 +
.../iotdb/db/mpp/common/filter/InFilter.java | 29 +-
.../iotdb/db/mpp/common/filter/LikeFilter.java | 26 +-
.../iotdb/db/mpp/common/filter/QueryFilter.java | 79 +-
.../iotdb/db/mpp/common/filter/RegexpFilter.java | 24 +-
.../db/mpp/common/schematree/DeviceSchemaInfo.java | 47 +
.../db/mpp/common/schematree/PathPatternNode.java | 35 +-
.../db/mpp/common/schematree/PathPatternTree.java | 87 +-
.../db/mpp/common/schematree/SchemaEntityNode.java | 27 +
.../mpp/common/schematree/SchemaInternalNode.java | 30 +-
.../common/schematree/SchemaMeasurementNode.java | 27 +
.../iotdb/db/mpp/common/schematree/SchemaNode.java | 9 +
.../iotdb/db/mpp/common/schematree/SchemaTree.java | 74 +-
.../iotdb/db/mpp/execution/ConfigExecution.java | 110 +
.../apache/iotdb/db/mpp/execution/Coordinator.java | 64 +-
.../apache/iotdb/db/mpp/execution/DataDriver.java | 321 ++
.../iotdb/db/mpp/execution/DataDriverContext.java | 62 +
.../org/apache/iotdb/db/mpp/execution/Driver.java | 63 +
.../iotdb/db/mpp/execution/DriverContext.java | 46 +
.../db/mpp/execution/ExecFragmentInstance.java | 63 -
.../iotdb/db/mpp/execution/ExecutionResult.java | 2 +-
.../db/mpp/execution/FragmentInstanceContext.java | 56 +-
.../mpp/execution/FragmentInstanceExecution.java | 88 +
.../db/mpp/execution/FragmentInstanceInfo.java | 40 +
.../db/mpp/execution/FragmentInstanceManager.java | 198 +
.../db/mpp/execution/FragmentInstanceState.java | 28 +-
.../iotdb/db/mpp/execution/FutureStateChange.java | 74 +
.../apache/iotdb/db/mpp/execution/IConfigTask.java | 26 +
.../iotdb/db/mpp/execution/IQueryExecution.java | 29 +
.../iotdb/db/mpp/execution/QueryExecution.java | 156 +-
.../apache/iotdb/db/mpp/execution/QueryState.java | 49 +
.../iotdb/db/mpp/execution/QueryStateMachine.java | 106 +-
.../iotdb/db/mpp/execution/SampleConfigTask.java | 47 +
.../iotdb/db/mpp/execution/SchemaDriver.java | 149 +
.../db/mpp/execution/SchemaDriverContext.java | 36 +
.../iotdb/db/mpp/execution/StateMachine.java | 322 ++
.../scheduler/AbstractFragInsStateTracker.java | 73 +
.../mpp/execution/scheduler/ClusterScheduler.java | 90 +-
.../scheduler/FixedRateFragInsStateTracker.java | 70 +
.../scheduler/FragInstanceDispatchResult.java | 32 +
.../scheduler/IFragInstanceDispatcher.java | 37 +
.../scheduler/IFragInstanceStateTracker.java | 26 +
.../mpp/execution/scheduler/IQueryTerminator.java | 24 +
.../db/mpp/execution/scheduler/IScheduler.java | 4 +-
.../scheduler/InternalServiceClientFactory.java | 40 +
.../scheduler/SimpleFragInstanceDispatcher.java | 75 +
.../execution/scheduler/SimpleQueryTerminator.java | 82 +
.../execution/scheduler/StandaloneScheduler.java | 4 +-
.../iotdb/db/mpp/memory/LocalMemoryManager.java | 17 +-
.../org/apache/iotdb/db/mpp/memory/MemoryPool.java | 108 +-
.../org/apache/iotdb/db/mpp/operator/Operator.java | 10 +-
.../db/mpp/operator/process/AggregateOperator.java | 5 +
.../mpp/operator/process/DeviceMergeOperator.java | 5 +
.../db/mpp/operator/process/FillOperator.java | 5 +
.../mpp/operator/process/FilterNullOperator.java | 5 +
.../mpp/operator/process/GroupByLevelOperator.java | 5 +
.../db/mpp/operator/process/LimitOperator.java | 9 +-
.../db/mpp/operator/process/OffsetOperator.java | 5 +
.../db/mpp/operator/process/SortOperator.java | 5 +
.../db/mpp/operator/process/TimeJoinOperator.java | 29 +-
.../db/mpp/operator/sink/FragmentSinkOperator.java | 5 +
.../mpp/operator/source/AlignedSeriesScanUtil.java | 5 +-
.../db/mpp/operator/source/DataSourceOperator.java | 26 +
.../db/mpp/operator/source/ExchangeOperator.java | 93 +
.../source/SeriesAggregateScanOperator.java | 15 +-
.../db/mpp/operator/source/SeriesScanOperator.java | 81 +-
.../db/mpp/operator/source/SeriesScanUtil.java | 25 +-
.../db/mpp/schedule/FragmentInstanceManager.java | 358 --
.../db/mpp/schedule/FragmentInstanceScheduler.java | 369 ++
.../mpp/schedule/FragmentInstanceTaskExecutor.java | 6 +-
.../db/mpp/schedule/IFragmentInstanceManager.java | 56 -
.../mpp/schedule/IFragmentInstanceScheduler.java | 61 +
.../db/mpp/schedule/task/FragmentInstanceTask.java | 11 +-
.../apache/iotdb/db/mpp/sql/analyze/Analysis.java | 21 +-
.../apache/iotdb/db/mpp/sql/analyze/Analyzer.java | 363 +-
.../db/mpp/sql/analyze/ClusterSchemaFetcher.java | 13 +-
.../mpp/sql/analyze/FakePartitionFetcherImpl.java | 14 +-
.../db/mpp/sql/analyze/FakeSchemaFetcherImpl.java | 62 +-
.../iotdb/db/mpp/sql/analyze/ISchemaFetcher.java | 10 +-
.../mpp/sql/analyze/StandaloneSchemaFetcher.java | 13 +-
.../iotdb/db/mpp/sql/constant/StatementType.java | 5 +-
.../apache/iotdb/db/mpp/sql/parser/ASTVisitor.java | 226 +-
.../db/mpp/sql/parser/StatementGenerator.java | 153 +-
.../db/mpp/sql/planner/DistributionPlanner.java | 95 +-
.../db/mpp/sql/planner/LocalExecutionPlanner.java | 215 +-
.../iotdb/db/mpp/sql/planner/LogicalPlanner.java | 449 ++-
.../iotdb/db/mpp/sql/planner/QueryPlanBuilder.java | 277 ++
.../db/mpp/sql/planner/plan/FragmentInstance.java | 116 +-
.../db/mpp/sql/planner/plan/IOutputPlanNode.java | 34 +
.../db/mpp/sql/planner/plan/PlanFragment.java | 35 +-
.../plan/SimpleFragmentParallelPlanner.java | 29 +-
.../iotdb/db/mpp/sql/planner/plan/SubPlan.java | 3 +-
.../db/mpp/sql/planner/plan/node/ColumnHeader.java | 106 +
.../db/mpp/sql/planner/plan/node/PlanNode.java | 52 +-
.../db/mpp/sql/planner/plan/node/PlanNodeId.java | 14 +
.../sql/planner/plan/node/PlanNodeIdAllocator.java | 36 -
.../db/mpp/sql/planner/plan/node/PlanNodeType.java | 21 +-
.../db/mpp/sql/planner/plan/node/PlanNodeUtil.java | 3 +
.../db/mpp/sql/planner/plan/node/PlanVisitor.java | 10 +
.../plan/node/metedata/read/ShowDevicesNode.java | 14 +-
.../planner/plan/node/metedata/read/ShowNode.java | 4 +-
.../node/metedata/write/AlterTimeSeriesNode.java | 174 +-
.../plan/node/metedata/write/AuthorNode.java | 351 ++
.../write/CreateAlignedTimeSeriesNode.java | 221 +-
.../node/metedata/write/CreateTimeSeriesNode.java | 158 +-
.../planner/plan/node/process/AggregateNode.java | 136 +-
.../planner/plan/node/process/DeviceMergeNode.java | 129 +-
.../planner/plan/node/process/ExchangeNode.java | 70 +-
.../sql/planner/plan/node/process/FillNode.java | 57 +-
.../sql/planner/plan/node/process/FilterNode.java | 97 +-
.../planner/plan/node/process/FilterNullNode.java | 95 +-
.../plan/node/process/GroupByLevelNode.java | 125 +-
.../sql/planner/plan/node/process/LimitNode.java | 63 +-
.../sql/planner/plan/node/process/OffsetNode.java | 60 +-
.../sql/planner/plan/node/process/SortNode.java | 68 +-
.../planner/plan/node/process/TimeJoinNode.java | 111 +-
.../planner/plan/node/sink/FragmentSinkNode.java | 92 +-
.../plan/node/source/SeriesAggregateScanNode.java | 187 +-
.../planner/plan/node/source/SeriesScanNode.java | 159 +-
.../sql/planner/plan/node/source/SourceNode.java | 22 -
.../plan/node/write/InsertMultiTabletNode.java | 69 -
.../plan/node/write/InsertMultiTabletsNode.java | 164 +
.../sql/planner/plan/node/write/InsertNode.java | 30 +-
.../sql/planner/plan/node/write/InsertRowNode.java | 19 +-
.../planner/plan/node/write/InsertRowsNode.java | 86 +-
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 82 +-
.../planner/plan/node/write/InsertTabletNode.java | 29 +-
.../sql/rewriter/ColumnPaginationController.java | 46 +-
.../db/mpp/sql/rewriter/WildcardsRemover.java | 24 +-
.../db/mpp/sql/statement/StatementVisitor.java | 149 +-
.../db/mpp/sql/statement/component/FillPolicy.java | 2 +-
.../statement/component/FilterNullComponent.java | 44 +
.../statement/component/GroupByLevelComponent.java | 5 +
.../component/GroupByLevelController.java | 16 +
.../sql/statement/component/SelectComponent.java | 16 +-
.../statement/crud/AggregationQueryStatement.java | 29 +-
.../mpp/sql/statement/crud/FillQueryStatement.java | 7 +-
.../statement/crud/GroupByFillQueryStatement.java | 5 +
.../sql/statement/crud/GroupByQueryStatement.java | 5 +
.../sql/statement/crud/InsertBaseStatement.java | 3 -
.../crud/InsertMultiTabletsStatement.java | 88 +
.../mpp/sql/statement/crud/InsertRowStatement.java | 9 +-
.../crud/InsertRowsOfOneDeviceStatement.java | 91 +
.../sql/statement/crud/InsertRowsStatement.java | 95 +
.../sql/statement/crud/InsertTabletStatement.java | 10 +-
.../mpp/sql/statement/crud/LastQueryStatement.java | 7 +-
.../db/mpp/sql/statement/crud/QueryStatement.java | 41 +-
.../mpp/sql/statement/crud/UDAFQueryStatement.java | 7 +-
.../mpp/sql/statement/crud/UDTFQueryStatement.java | 6 +
.../db/mpp/sql/statement/sys/AuthorStatement.java | 152 +
.../db/protocol/influxdb/handler/QueryHandler.java | 11 +-
.../iotdb/db/protocol/mqtt/PublishHandler.java | 14 +-
.../rest/handler/AuthorizationHandler.java | 12 +-
.../protocol/rest/impl/GrafanaApiServiceImpl.java | 2 +-
.../db/protocol/rest/impl/RestApiServiceImpl.java | 2 +-
.../apache/iotdb/db/qp/constant/SQLConstant.java | 4 +
.../apache/iotdb/db/qp/executor/IPlanExecutor.java | 6 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 118 +-
.../org/apache/iotdb/db/qp/physical/BatchPlan.java | 2 +-
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 72 +-
.../iotdb/db/qp/physical/crud/DeletePlan.java | 46 +-
.../db/qp/physical/crud/InsertMultiTabletPlan.java | 447 ---
.../qp/physical/crud/InsertMultiTabletsPlan.java | 447 +++
.../iotdb/db/qp/physical/crud/InsertRowPlan.java | 275 +-
.../physical/crud/InsertRowsOfOneDevicePlan.java | 2 +-
.../iotdb/db/qp/physical/crud/InsertRowsPlan.java | 4 +-
.../db/qp/physical/crud/InsertTabletPlan.java | 462 ++-
.../qp/physical/sys/CreateMultiTimeSeriesPlan.java | 4 +-
.../db/qp/physical/sys/DeleteTimeSeriesPlan.java | 6 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 3 +-
.../iotdb/db/qp/utils/GroupByLevelController.java | 90 +
.../db/query/aggregation/AggregateResult.java | 9 +
.../db/query/control/QueryResourceManager.java | 12 +-
.../iotdb/db/query/control/SessionManager.java | 130 +-
.../db/query/dataset/AlignByDeviceDataSet.java | 4 +-
.../groupby/GroupByWithValueFilterDataSet.java | 11 +-
.../groupby/GroupByWithoutValueFilterDataSet.java | 11 +-
.../db/query/executor/AggregationExecutor.java | 20 +-
.../iotdb/db/query/executor/FillQueryExecutor.java | 10 +-
.../iotdb/db/query/executor/LastQueryExecutor.java | 10 +-
.../db/query/executor/RawDataQueryExecutor.java | 20 +-
.../iotdb/db/query/expression/Expression.java | 9 +-
.../iotdb/db/query/expression/ExpressionType.java | 115 +
.../iotdb/db/query/expression/ResultColumn.java | 17 +
.../expression/binary/AdditionExpression.java | 19 +
.../query/expression/binary/BinaryExpression.java | 14 +-
.../expression/binary/DivisionExpression.java | 19 +
.../query/expression/binary/EqualToExpression.java | 19 +
.../expression/binary/GreaterEqualExpression.java | 19 +
.../expression/binary/GreaterThanExpression.java | 19 +
.../expression/binary/LessEqualExpression.java | 19 +
.../expression/binary/LessThanExpression.java | 19 +
.../expression/binary/LogicAndExpression.java | 19 +
.../query/expression/binary/LogicOrExpression.java | 19 +
.../query/expression/binary/ModuloExpression.java | 19 +
.../binary/MultiplicationExpression.java | 19 +
.../expression/binary/NonEqualExpression.java | 19 +
.../expression/binary/SubtractionExpression.java | 19 +
.../db/query/expression/unary/ConstantOperand.java | 28 +-
.../query/expression/unary/FunctionExpression.java | 42 +-
.../query/expression/unary/LogicNotExpression.java | 24 +-
.../query/expression/unary/NegationExpression.java | 24 +-
.../query/expression/unary/TimeSeriesOperand.java | 27 +-
.../query/timegenerator/ServerTimeGenerator.java | 10 +-
.../apache/iotdb/db/rescon/MemTableManager.java | 14 +-
.../org/apache/iotdb/db/rescon/SystemInfo.java | 10 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 24 +-
.../iotdb/db/service/InternalServiceImpl.java | 83 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 4 +-
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 6 +
.../db/service/basic/BasicOpenSessionResp.java | 2 +-
.../iotdb/db/service/basic/ServiceProvider.java | 172 -
.../iotdb/db/service/metrics/MetricsService.java | 33 +-
.../thrift/impl/DataNodeManagementServiceImpl.java | 1 +
.../service/thrift/impl/InfluxDBServiceImpl.java | 62 +-
.../db/service/thrift/impl/TSServiceImpl.java | 400 +-
.../db/sync/sender/manage/ISyncFileManager.java | 4 +-
.../db/sync/sender/manage/SyncFileManager.java | 12 +-
.../iotdb/db/sync/sender/transfer/SyncClient.java | 8 +-
.../java/org/apache/iotdb/db/tools/WalChecker.java | 81 +-
.../db/tools/dataregion/DeviceMappingViewer.java | 63 +
.../db/tools/virtualsg/DeviceMappingViewer.java | 64 -
.../org/apache/iotdb/db/utils/DataTypeUtils.java | 8 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 25 +-
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 2 +-
.../iotdb/db/utils/IExpressionDeserializeUtil.java | 51 +
.../java/org/apache/iotdb/db/utils/MemUtils.java | 54 +
.../org/apache/iotdb/db/utils/OpenFileNumUtil.java | 3 +-
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 282 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 2 +-
.../org/apache/iotdb/db/utils/SerializedSize.java | 29 +
.../org/apache/iotdb/db/utils/StatusUtils.java | 46 -
.../db/utils/datastructure/AlignedTVList.java | 202 +-
.../iotdb/db/utils/datastructure/BinaryTVList.java | 37 +
.../db/utils/datastructure/BooleanTVList.java | 33 +
.../iotdb/db/utils/datastructure/DoubleTVList.java | 32 +
.../iotdb/db/utils/datastructure/FloatTVList.java | 32 +
.../iotdb/db/utils/datastructure/IntTVList.java | 32 +
.../iotdb/db/utils/datastructure/LongTVList.java | 32 +
.../iotdb/db/utils/datastructure/TVList.java | 28 +-
.../iotdb/db/utils/writelog/BatchLogReader.java | 83 +
.../apache/iotdb/db/utils/writelog/ILogReader.java | 50 +
.../apache/iotdb/db/utils/writelog/ILogWriter.java | 50 +
.../apache/iotdb/db/utils/writelog/LogWriter.java | 133 +
.../db/utils/writelog/MultiFileLogReader.java | 76 +
.../db/utils/writelog/SingleFileLogReader.java | 166 +
.../java/org/apache/iotdb/db/wal/WALManager.java | 226 ++
.../iotdb/db/wal/buffer/AbstractWALBuffer.java | 76 +
.../org/apache/iotdb/db/wal/buffer/IWALBuffer.java | 40 +
.../iotdb/db/wal/buffer/IWALByteBufferView.java | 52 +
.../apache/iotdb/db/wal/buffer/SignalWALEntry.java | 51 +
.../org/apache/iotdb/db/wal/buffer/WALBuffer.java | 454 +++
.../org/apache/iotdb/db/wal/buffer/WALEntry.java | 219 ++
.../apache/iotdb/db/wal/buffer/WALEntryType.java | 55 +
.../apache/iotdb/db/wal/buffer/WALEntryValue.java | 30 +
.../apache/iotdb/db/wal/checkpoint/Checkpoint.java | 102 +
.../iotdb/db/wal/checkpoint/CheckpointManager.java | 257 ++
.../iotdb/db/wal/checkpoint/CheckpointType.java | 49 +
.../iotdb/db/wal/checkpoint/MemTableInfo.java | 113 +
.../iotdb/db/wal/exception/WALException.java | 38 +
.../db/wal/exception/WALNodeClosedException.java | 25 +
.../db/wal/exception/WALRecoverException.java | 29 +
.../apache/iotdb/db/wal/io/CheckpointReader.java | 63 +
.../apache/iotdb/db/wal/io/CheckpointWriter.java | 61 +
.../org/apache/iotdb/db/wal/io/ILogWriter.java | 61 +
.../java/org/apache/iotdb/db/wal/io/LogWriter.java | 96 +
.../java/org/apache/iotdb/db/wal/io/WALReader.java | 114 +
.../java/org/apache/iotdb/db/wal/io/WALWriter.java | 60 +
.../org/apache/iotdb/db/wal/node/IWALNode.java | 52 +
.../org/apache/iotdb/db/wal/node/WALFakeNode.java | 118 +
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 380 ++
.../db/wal/recover/CheckpointRecoverUtils.java | 78 +
.../iotdb/db/wal/recover/WALNodeRecoverTask.java | 151 +
.../iotdb/db/wal/recover/WALRecoverManager.java | 172 +
.../file/AbstractTsFileRecoverPerformer.java | 126 +
.../recover/file/SealedTsFileRecoverPerformer.java | 54 +
.../db/wal/recover/file/TsFilePlanRedoer.java | 159 +
.../file/UnsealedTsFileRecoverPerformer.java | 271 ++
.../org/apache/iotdb/db/wal/utils/WALMode.java | 35 +
.../apache/iotdb/db/wal/utils/WALWriteUtils.java | 134 +
.../wal/utils/listener/AbstractResultListener.java | 87 +
.../db/wal/utils/listener/WALFlushListener.java | 26 +
.../db/wal/utils/listener/WALRecoverListener.java | 35 +
.../apache/iotdb/db/writelog/WALFlushListener.java | 50 -
.../iotdb/db/writelog/io/BatchLogReader.java | 83 -
.../apache/iotdb/db/writelog/io/ILogReader.java | 50 -
.../apache/iotdb/db/writelog/io/ILogWriter.java | 50 -
.../org/apache/iotdb/db/writelog/io/LogWriter.java | 133 -
.../iotdb/db/writelog/io/MultiFileLogReader.java | 76 -
.../iotdb/db/writelog/io/SingleFileLogReader.java | 161 -
.../writelog/manager/MultiFileLogNodeManager.java | 206 --
.../db/writelog/manager/WriteLogNodeManager.java | 49 -
.../db/writelog/node/ExclusiveWriteLogNode.java | 389 --
.../iotdb/db/writelog/node/WriteLogNode.java | 92 -
.../iotdb/db/writelog/recover/LogReplayer.java | 242 --
.../writelog/recover/TsFileRecoverPerformer.java | 316 --
.../compaction/CompactionTaskComparatorTest.java | 31 +-
.../compaction/CompactionTaskManagerTest.java | 101 +-
.../db/engine/compaction/CompactionUtilsTest.java | 3518 ------------------
.../ReadPointCompactionPerformerTest.java | 3826 ++++++++++++++++++++
.../db/engine/compaction/TsFileIdentifierUT.java | 11 +-
.../cross/CrossSpaceCompactionExceptionTest.java | 23 +-
.../compaction/cross/CrossSpaceCompactionTest.java | 84 +-
.../engine/compaction/cross/MergeUpgradeTest.java | 6 +-
.../cross/RewriteCompactionFileSelectorTest.java | 58 +-
.../RewriteCrossSpaceCompactionRecoverTest.java | 25 +-
.../cross/RewriteCrossSpaceCompactionTest.java | 56 +-
.../compaction/inner/InnerCompactionLogTest.java | 2 +-
.../inner/InnerCompactionSchedulerTest.java | 18 +-
.../compaction/inner/InnerSeqCompactionTest.java | 40 +-
.../inner/InnerSpaceCompactionExceptionTest.java | 44 +-
.../InnerSpaceCompactionUtilsAlignedTest.java | 534 ---
.../InnerSpaceCompactionUtilsNoAlignedTest.java | 918 -----
.../inner/InnerSpaceCompactionUtilsOldTest.java | 128 -
.../compaction/inner/InnerUnseqCompactionTest.java | 14 +-
.../ReadChunkCompactionPerformerAlignedTest.java | 534 +++
.../ReadChunkCompactionPerformerNoAlignedTest.java | 918 +++++
.../inner/ReadChunkCompactionPerformerOldTest.java | 133 +
.../SizeTieredCompactionRecoverTest.java | 77 +-
...eCrossSpaceCompactionRecoverCompatibleTest.java | 2 +-
.../SizeTieredCompactionRecoverCompatibleTest.java | 20 +-
.../recover/SizeTieredCompactionRecoverTest.java | 57 +-
.../task/FakedCrossSpaceCompactionTask.java | 62 -
.../task/FakedCrossSpaceCompactionTaskFactory.java | 47 -
.../task/FakedInnerSpaceCompactionTask.java | 97 -
.../task/FakedInnerSpaceCompactionTaskFactory.java | 50 -
.../compaction/utils/CompactionClearUtils.java | 2 +-
.../compaction/utils/CompactionConfigRestorer.java | 13 +-
.../db/engine/memtable/MemTableTestUtils.java | 2 -
.../db/engine/memtable/PrimitiveMemTableTest.java | 32 +-
.../engine/modification/DeletionFileNodeTest.java | 30 +-
.../storagegroup/StorageGroupProcessorTest.java | 83 +-
.../iotdb/db/engine/storagegroup/TTLTest.java | 60 +-
.../engine/storagegroup/TsFileProcessorTest.java | 4 +-
.../dataregion/HashVirtualPartitionerTest.java | 63 +
.../virtualSg/HashVirtualPartitionerTest.java | 63 -
.../apache/iotdb/db/metadata/SchemaBasicTest.java | 79 +-
.../org/apache/iotdb/db/metadata/TemplateTest.java | 18 +
.../db/metadata/idtable/IDTableFlushTimeTest.java | 10 +-
.../db/metadata/idtable/InsertWithIDTableTest.java | 7 +-
.../iotdb/db/metadata/mtree/MTreeAboveSGTest.java | 4 +-
.../iotdb/db/metadata/mtree/MTreeBelowSGTest.java | 58 +-
.../mtree/disk/CachedMNodeContainerTest.java | 51 +
.../db/metadata/mtree/disk/MemManagerTest.java | 112 +
.../mtree/multimode/MTreeDiskModeTest.java | 42 +
.../mtree/multimode/MTreeFullMemoryTest.java | 28 +
.../mtree/multimode/MTreeMemoryModeTest.java | 35 +
.../mtree/multimode/MTreeNonMemoryTest.java | 28 +
.../mtree/multimode/MTreePartialMemoryTest.java | 28 +
.../metadata/mtree/schemafile/RecordUtilTests.java | 78 +
.../metadata/mtree/schemafile/SchemaFileTest.java | 787 ++++
.../metadata/mtree/schemafile/SchemaPageTest.java | 130 +
.../db/metadata/mtree/schemafile/SegmentTest.java | 148 +
.../db/metadata/multimode/SchemaDiskModeTest.java | 42 +
.../metadata/multimode/SchemaFullMemoryTest.java | 29 +
.../metadata/multimode/SchemaMemoryModeTest.java | 35 +
.../db/metadata/multimode/SchemaNonMemoryTest.java | 29 +
.../multimode/SchemaPartialMemoryTest.java | 28 +
.../schemaregion/rocksdb/MRocksDBBenchmark.java | 98 +
.../schemaregion/rocksdb/MRocksDBUnitTest.java | 238 ++
.../rocksdb/RSchemaReadWriteHandlerTest.java | 77 +
.../rocksdb/RSchemaRegionAdvancedTest.java | 167 +
.../rocksdb/RocksDBBenchmarkEngine.java | 153 +
.../schemaregion/rocksdb/RocksDBBenchmarkTask.java | 109 +
.../schemaregion/rocksdb/RocksDBTestUtils.java | 72 +
.../db/metadata/upgrade/MetadataUpgradeTest.java | 2 +-
.../apache/iotdb/db/mpp/buffer/SinkHandleTest.java | 460 +++
.../iotdb/db/mpp/buffer/SourceHandleTest.java | 588 +++
.../java/org/apache/iotdb/db/mpp/buffer/Utils.java | 106 +
.../iotdb/db/mpp/common/PathPatternTreeTest.java | 199 +-
.../apache/iotdb/db/mpp/common/SchemaTreeTest.java | 65 +-
.../iotdb/db/mpp/execution/DataDriverTest.java | 213 ++
.../db/mpp/execution/QueryStateMachineTest.java | 142 +
.../apache/iotdb/db/mpp/memory/MemoryPoolTest.java | 140 +-
.../iotdb/db/mpp/operator/LimitOperatorTest.java | 24 +-
.../db/mpp/operator/SeriesScanOperatorTest.java | 17 +-
.../db/mpp/operator/TimeJoinOperatorTest.java | 24 +-
.../db/mpp/schedule/DefaultTaskSchedulerTest.java | 73 +-
.../mpp/schedule/FragmentInstanceManagerTest.java | 134 -
.../schedule/FragmentInstanceSchedulerTest.java | 148 +
.../FragmentInstanceTimeoutSentinelTest.java | 76 +-
.../iotdb/db/mpp/sql/analyze/AnalyzerTest.java | 3 +-
.../db/mpp/sql/plan/DistributionPlannerTest.java | 144 +-
.../db/mpp/sql/plan/FragmentInstanceIdTest.java | 38 +
.../db/mpp/sql/plan/FragmentInstanceSerdeTest.java | 147 +
.../iotdb/db/mpp/sql/plan/LogicalPlannerTest.java | 556 ++-
.../db/mpp/sql/plan/QueryLogicalPlanUtil.java | 567 +++
.../iotdb/db/mpp/sql/plan/QueryPlannerTest.java | 6 +-
.../sql/plan/node/PlanNodeDeserializeHelper.java | 37 +
.../metadata/read/ShowDevicesNodeSerdeTest.java | 42 +
.../plan/node/process/AggregateNodeSerdeTest.java | 58 +
.../node/process/DeviceMergeNodeSerdeTest.java | 81 +
.../plan/node/process/ExchangeNodeSerdeTest.java | 101 +
.../sql/plan/node/process/FillNodeSerdeTest.java | 85 +
.../sql/plan/node/process/FilterNodeSerdeTest.java | 97 +
.../plan/node/process/FilterNullNodeSerdeTest.java | 102 +
.../node/process/GroupByLevelNodeSerdeTest.java | 117 +
.../sql/plan/node/process/LimitNodeSerdeTest.java | 119 +
.../sql/plan/node/process/OffsetNodeSerdeTest.java | 186 +
.../sql/plan/node/process/SortNodeSerdeTest.java | 130 +
.../plan/node/process/TimeJoinNodeSerdeTest.java | 135 +
.../plan/node/sink/FragmentSinkNodeSerdeTest.java | 53 +
.../source/SeriesAggregateScanNodeSerdeTest.java | 69 +
.../plan/node/source/SeriesScanNodeSerdeTest.java | 55 +
.../db/qp/physical/InsertTabletMultiPlanTest.java | 19 +-
.../iotdb/db/qp/physical/SerializedSizeTest.java | 130 +
.../iotdb/db/service/InternalServiceImplTest.java | 138 +
.../db/sync/receiver/load/FileLoaderTest.java | 23 +-
.../recover/SyncReceiverLogAnalyzerTest.java | 5 +-
.../org/apache/iotdb/db/tools/WalCheckerTest.java | 117 +-
.../db/utils/writelog/LogWriterReaderTest.java | 205 ++
.../db/utils/writelog/MultiFileLogReaderTest.java | 86 +
.../org/apache/iotdb/db/wal/DisableWALTest.java | 54 +
.../org/apache/iotdb/db/wal/WALManagerTest.java | 107 +
.../iotdb/db/wal/buffer/WALBufferCommonTest.java | 158 +
.../apache/iotdb/db/wal/buffer/WALBufferTest.java | 38 +
.../db/wal/checkpoint/CheckpointManagerTest.java | 154 +
.../apache/iotdb/db/wal/io/CheckpointFileTest.java | 133 +
.../org/apache/iotdb/db/wal/io/WALFileTest.java | 222 ++
.../apache/iotdb/db/wal/node/WALFakeNodeTest.java | 65 +
.../org/apache/iotdb/db/wal/node/WALNodeTest.java | 262 ++
.../db/wal/recover/WALRecoverManagerTest.java | 466 +++
.../file/SealedTsFileRecoverPerformerTest.java | 307 ++
.../db/wal/recover/file/TsFilePlanRedoerTest.java | 400 ++
.../file/UnsealedTsFileRecoverPerformerTest.java | 260 ++
.../db/wal/utils/TsFileUtilsForRecoverTest.java | 39 +
.../iotdb/db/wal/utils/WALByteBufferForTest.java | 75 +
.../iotdb/db/writelog/IoTDBLogFileSizeTest.java | 220 --
.../apache/iotdb/db/writelog/PerformanceTest.java | 219 --
.../iotdb/db/writelog/WriteLogNodeManagerTest.java | 185 -
.../apache/iotdb/db/writelog/WriteLogNodeTest.java | 451 ---
.../iotdb/db/writelog/io/LogWriterReaderTest.java | 212 --
.../db/writelog/io/MultiFileLogReaderTest.java | 89 -
.../db/writelog/recover/DeviceStringTest.java | 132 -
.../iotdb/db/writelog/recover/LogReplayerTest.java | 288 --
.../recover/RecoverResourceFromReaderTest.java | 231 --
.../db/writelog/recover/SeqTsFileRecoverTest.java | 565 ---
.../writelog/recover/UnseqTsFileRecoverTest.java | 277 --
server/src/test/resources/iotdb-engine.properties | 2 +
.../apache/iotdb/rpc/BatchExecutionException.java | 2 +-
.../org/apache/iotdb/rpc/IoTDBJDBCDataSet.java | 2 +-
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 3 +-
.../org/apache/iotdb/rpc/RedirectException.java | 2 +-
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 19 +-
.../iotdb/rpc/StatementExecutionException.java | 6 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 15 +-
.../java/org/apache/iotdb/session/Session.java | 2 +-
.../apache/iotdb/session/SessionConnection.java | 4 +-
.../apache/iotdb/session/util/SessionUtils.java | 2 +-
.../apache/iotdb/session/SessionCacheLeaderUT.java | 2 +-
site/iotdb-doap.rdf | 16 +-
site/src/main/.vuepress/config.js | 15 +-
.../apache/iotdb/spark/db/EnvironmentUtils.java | 14 +-
testcontainer/src/tool/parser.py | 4 +-
thrift-cluster/src/main/thrift/cluster.thrift | 4 +-
.../src/main/thrift/confignode.thrift | 147 +-
thrift-datanode/pom.xml | 67 -
thrift-datanode/src/main/thrift/datanode.thrift | 92 -
thrift-influxdb/src/main/thrift/influxdb.thrift | 36 +-
thrift/src/main/thrift/common.thrift | 48 +
thrift/src/main/thrift/management.thrift | 91 +
thrift/src/main/thrift/mpp.thrift | 36 +-
thrift/src/main/thrift/rpc.thrift | 92 +-
tsfile/pom.xml | 22 +
.../org/apache/iotdb/tsfile/read/common/Path.java | 21 +
.../read/common/block/column/BinaryColumn.java | 16 +
.../common/block/column/BinaryColumnBuilder.java | 6 +
.../read/common/block/column/BooleanColumn.java | 16 +
.../common/block/column/BooleanColumnBuilder.java | 6 +
.../tsfile/read/common/block/column/Column.java | 13 +
.../read/common/block/column/ColumnBuilder.java | 4 +
.../read/common/block/column/ColumnEncoder.java | 108 +
.../common/block/column/ColumnEncoderFactory.java | 40 +
.../read/common/block/column/ColumnEncoding.java | 64 +
.../read/common/block/column/DoubleColumn.java | 16 +
.../common/block/column/DoubleColumnBuilder.java | 6 +
.../read/common/block/column/FloatColumn.java | 16 +
.../common/block/column/FloatColumnBuilder.java | 6 +
.../block/column/Int32ArrayColumnEncoder.java | 90 +
.../block/column/Int64ArrayColumnEncoder.java | 90 +
.../tsfile/read/common/block/column/IntColumn.java | 16 +
.../read/common/block/column/IntColumnBuilder.java | 6 +
.../read/common/block/column/LongColumn.java | 16 +
.../common/block/column/LongColumnBuilder.java | 6 +
.../block/column/RunLengthEncodedColumn.java | 16 +
.../read/common/block/column/TimeColumn.java | 17 +
.../common/block/column/TimeColumnBuilder.java | 7 +
.../read/common/block/column/TsBlockSerde.java | 125 +
.../iotdb/tsfile/read/expression/IExpression.java | 3 +
.../read/expression/impl/BinaryExpression.java | 55 +
.../read/expression/impl/GlobalTimeExpression.java | 33 +
.../expression/impl/SingleSeriesExpression.java | 29 +
.../iotdb/tsfile/read/filter/basic/Filter.java | 8 +
.../org/apache/iotdb/tsfile/utils/BloomFilter.java | 7 +-
.../apache/iotdb/tsfile/utils/FilePathUtils.java | 2 +-
.../iotdb/tsfile/utils/ReadWriteIOUtils.java | 106 +-
.../org/apache/iotdb/tsfile/utils/TsFileUtils.java | 20 +
.../tsfile/write/schema/IMeasurementSchema.java | 2 +
.../tsfile/write/schema/MeasurementSchema.java | 18 +
.../write/schema/VectorMeasurementSchema.java | 13 +
.../write/writer/RestorableTsFileIOWriter.java | 5 +
.../iotdb/tsfile/write/writer/TsFileIOWriter.java | 8 +-
.../tsfile/common/block/ColumnEncoderTest.java | 144 +
.../common/block/Int32ArrayColumnEncoderTest.java | 113 +
.../common/block/Int64ArrayColumnEncoderTest.java | 114 +
.../tsfile/common/block/TsBlockSerdeTest.java | 97 +
.../apache/iotdb/tsfile/read/TsFileReaderTest.java | 4 +
.../iotdb/tsfile/utils/FilePathUtilsTest.java | 12 +-
.../iotdb/tsfile/utils/TsFileGeneratorForTest.java | 12 +
1065 files changed, 79705 insertions(+), 30700 deletions(-)
create mode 100644 client-py/tests/test_numpy_tablet.py
create mode 100644 client-py/tests/test_tablet.py
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/DataNodeConfigurationDataSet.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/PermissionInfoDataSet.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/PermissionManager.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/partition/DataRegionInfo.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/partition/SchemaRegionInfo.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/persistence/AuthorInfoPersistence.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/physical/crud/CreateDataPartitionPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/physical/crud/CreateRegionsPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/physical/crud/CreateSchemaPartitionPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/physical/crud/GetOrCreateDataPartitionPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/physical/crud/GetOrCreateSchemaPartitionPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/physical/sys/AuthorPlan.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/physical/sys/DataPartitionPlan.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/physical/sys/SchemaPartitionPlan.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/auth/AuthorTest.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/physical/SerializeDeserializeUT.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/ConsensusFactory.java
delete mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/common/ConsensusType.java
create mode 100644 docs/Community/About.md
create mode 100644 docs/UserGuide/API/InfluxDB-Protocol.md
create mode 100644 docs/UserGuide/Data-Modeling/DataRegion.md
delete mode 100644 docs/UserGuide/Data-Modeling/VirtualStorageGroup.md
delete mode 100644 docs/UserGuide/Library-UDF/Anomaly-Detection.md
create mode 100644 docs/zh/Community/About.md
create mode 100644 docs/zh/UserGuide/Data-Modeling/DataRegion.md
delete mode 100644 docs/zh/UserGuide/Data-Modeling/VirtualStorageGroup.md
delete mode 100644 docs/zh/UserGuide/Library-UDF/Anomaly Detection.md
create mode 100644 example/rest-client-c-example/CMakeLists.txt
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IOTDBInsertAlignedValuesIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBInsertAlignedValuesIT.java
delete mode 100644 library-udf/src/main/java/org/apache/iotdb/library/anomaly/UDTFIQR.java
delete mode 100644 library-udf/src/main/java/org/apache/iotdb/library/anomaly/UDTFKSigma.java
delete mode 100644 library-udf/src/main/java/org/apache/iotdb/library/anomaly/UDTFLOF.java
delete mode 100644 library-udf/src/main/java/org/apache/iotdb/library/anomaly/UDTFMissDetect.java
delete mode 100644 library-udf/src/main/java/org/apache/iotdb/library/anomaly/UDTFRange.java
delete mode 100644 library-udf/src/main/java/org/apache/iotdb/library/anomaly/UDTFTwoSidedFilter.java
delete mode 100644 library-udf/src/main/java/org/apache/iotdb/library/anomaly/util/MissDetector.java
delete mode 100644 library-udf/src/main/java/org/apache/iotdb/library/anomaly/util/StreamMissDetector.java
delete mode 100644 library-udf/src/main/java/org/apache/iotdb/library/anomaly/util/WindowDetect.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dmatch/UDAFCov.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dmatch/UDAFDtw.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dmatch/UDAFPearson.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dmatch/UDTFPtnSym.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dmatch/UDTFXCorr.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dmatch/util/CrossCorrelation.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/UDAFIntegral.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/UDAFIntegralAvg.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/UDAFMad.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/UDAFMedian.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/UDAFMode.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/UDAFPercentile.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/UDAFPeriod.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/UDAFSkew.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/UDAFSpread.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/UDAFStddev.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/UDTFACF.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/UDTFDistinct.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/UDTFHistogram.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/UDTFMinMax.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/UDTFMvAvg.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/UDTFPACF.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/UDTFQLB.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/UDTFResample.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/UDTFSample.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/UDTFSegment.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/UDTFSpline.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/UDTFZScore.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/util/CrossCorrelation.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/util/ExactOrderStatistics.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/util/GKArray.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/util/MADSketch.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/util/Mad.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/util/MaxSelector.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/util/Resampler.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/util/Segment.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/util/YuleWalker.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dquality/UDTFCompleteness.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dquality/UDTFConsistency.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dquality/UDTFTimeliness.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dquality/UDTFValidity.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dquality/util/TimeSeriesQuality.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/drepair/UDTFTimestampRepair.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/drepair/UDTFValueFill.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/drepair/UDTFValueRepair.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/drepair/util/ARFill.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/drepair/util/LikelihoodFill.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/drepair/util/LinearFill.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/drepair/util/LsGreedy.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/drepair/util/MAFill.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/drepair/util/MeanFill.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/drepair/util/PreviousFill.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/drepair/util/Screen.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/drepair/util/ScreenFill.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/drepair/util/TimestampInterval.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/drepair/util/TimestampRepair.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/drepair/util/ValueFill.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/drepair/util/ValueRepair.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/frequency/UDTFConv.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/frequency/UDTFDWT.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/frequency/UDTFDeconv.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/frequency/UDTFFFT.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/frequency/UDTFHighPass.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/frequency/UDTFIDWT.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/frequency/UDTFIFFT.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/frequency/UDTFLowPass.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/frequency/util/DWTUtil.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/frequency/util/FFTUtil.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/series/UDTFConsecutiveSequences.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/series/UDTFConsecutiveWindows.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/series/util/ConsecutiveUtil.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/string/UDTFRegexMatch.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/string/UDTFRegexReplace.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/string/UDTFRegexSplit.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/string/UDTFStrReplace.java
delete mode 100644 library-udf/src/test/java/org/apache/iotdb/library/anomaly/AnomalyTests.java
create mode 100644 library-udf/src/test/java/org/apache/iotdb/library/dmatch/DMatchTests.java
create mode 100644 library-udf/src/test/java/org/apache/iotdb/library/dprofile/DProfileTests.java
create mode 100644 library-udf/src/test/java/org/apache/iotdb/library/dquality/DQualityTests.java
create mode 100644 library-udf/src/test/java/org/apache/iotdb/library/drepair/DRepairTests.java
create mode 100644 library-udf/src/test/java/org/apache/iotdb/library/frequency/FrequencyTests.java
create mode 100644 library-udf/src/test/java/org/apache/iotdb/library/series/SeriesTest.java
create mode 100644 library-udf/src/test/java/org/apache/iotdb/library/string/StringTests.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/cluster/DataNodeLocation.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/consensus/DataRegionId.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/consensus/PartitionRegionId.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/consensus/SchemaRegionId.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/hash/APHashExecutor.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/hash/BKDRHashExecutor.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/hash/DeviceGroupHashExecutor.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/hash/JSHashExecutor.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/hash/SDBMHashExecutor.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/partition/DataNodeLocation.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/partition/executor/SeriesPartitionExecutor.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/partition/executor/hash/APHashExecutor.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/partition/executor/hash/BKDRHashExecutor.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/partition/executor/hash/JSHashExecutor.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/partition/executor/hash/SDBMHashExecutor.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/utils/StatusUtils.java
create mode 100644 node-commons/src/test/java/org/apache/iotdb/commons/ConsensusGroupIdTest.java
create mode 100644 server/src/assembly/resources/tools/rocksdb-transfer.bat
create mode 100644 server/src/assembly/resources/tools/rocksdb-transfer.sh
create mode 100644 server/src/main/java/org/apache/iotdb/db/auth/authorizer/AuthorizerManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/auth/authorizer/ClusterAuthorizer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/conf/directories/FolderManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/conf/directories/strategy/DirectoryStrategyType.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/consensus/ConsensusExample.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/consensus/ConsensusImpl.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/consensus/ConsensusManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/StorageEngineV2.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/CompactionExceptionHandler.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/CompactionRecoverManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/CompactionTaskComparator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/TsFileIdentifier.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/comparator/DefaultCompactionTaskComparatorImpl.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/comparator/ICompactionTaskComparator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/constant/CrossCompactionPerformer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/constant/CrossCompactionSelector.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/constant/InnerSeqCompactionPerformer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/constant/InnerSequenceCompactionSelector.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/constant/InnerUnseqCompactionPerformer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/constant/InnerUnsequenceCompactionSelector.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/AbstractCrossSpaceCompactionSelector.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/AbstractCrossSpaceCompactionTask.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/CrossCompactionStrategy.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/CrossSpaceCompactionTask.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/CrossSpaceCompactionTaskFactory.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/ICrossSpaceSelector.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/RewriteCrossSpaceCompactionResource.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/manage/CrossSpaceCompactionResource.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/selector/IMergePathSelector.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/selector/MergeFileStrategy.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/selector/NaivePathSelector.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/task/ReadPointPerformerSubTask.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/task/RewriteCrossSpaceCompactionTask.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/AbstractInnerSpaceCompactionSelector.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/AbstractInnerSpaceCompactionTask.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/IInnerSeqSpaceSelector.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/IInnerUnseqSpaceSelector.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/InnerCompactionStrategy.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/InnerSpaceCompactionTask.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/InnerSpaceCompactionTaskFactory.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/sizetiered/SizeTieredCompactionTask.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/utils/InnerSpaceCompactionUtils.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/log/CompactionLogAnalyzer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/log/CompactionLogger.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/log/TsFileIdentifier.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/performer/ICompactionPerformer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/performer/ICrossCompactionPerformer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/performer/ISeqCompactionPerformer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/performer/IUnseqCompactionPerformer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/performer/impl/ReadChunkCompactionPerformer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/performer/impl/ReadPointCompactionPerformer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/task/AbstractCompactionSelector.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/task/CompactionExceptionHandler.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/task/CompactionRecoverManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/task/ICompactionSelector.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/utils/log/CompactionLogAnalyzer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/utils/log/CompactionLogger.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/flush/FlushStatus.java
create mode 100755 server/src/main/java/org/apache/iotdb/db/engine/storagegroup/DataRegion.java
delete mode 100755 server/src/main/java/org/apache/iotdb/db/engine/storagegroup/VirtualStorageGroupProcessor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/storagegroup/dataregion/HashVirtualPartitioner.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/storagegroup/dataregion/StorageGroupManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/storagegroup/dataregion/VirtualPartitioner.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/storagegroup/virtualSg/HashVirtualPartitioner.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/storagegroup/virtualSg/StorageGroupManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/storagegroup/virtualSg/VirtualPartitioner.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/DataRegionException.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/exception/StorageGroupProcessorException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/metadata/AcquireLockTimeoutException.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/exception/metadata/DifferentTemplateException.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/exception/metadata/DuplicatedTemplateException.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/exception/metadata/NoTemplateOnMNodeException.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/exception/metadata/TemplateImcompatibeException.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/exception/metadata/TemplateIsInUseException.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/exception/metadata/UndefinedTemplateException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/metadata/cache/MNodeNotCachedException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/metadata/cache/MNodeNotPinnedException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/metadata/schemafile/RecordDuplicatedException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/metadata/schemafile/SchemaFileNotExists.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/metadata/schemafile/SchemaPageOverflowException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/metadata/schemafile/SegmentNotFoundException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/metadata/schemafile/SegmentOverflowException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/metadata/template/DifferentTemplateException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/metadata/template/DuplicatedTemplateException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/metadata/template/NoTemplateOnMNodeException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/metadata/template/TemplateImcompatibeException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/metadata/template/TemplateIsInUseException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/metadata/template/UndefinedTemplateException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/Executor/SchemaVisitor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mnode/container/IMNodeContainer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mnode/container/MNodeContainerMapImpl.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mnode/container/MNodeContainers.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mnode/estimator/BasicMNodSizeEstimator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mnode/estimator/IMNodeSizeEstimator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mnode/iterator/IMNodeIterator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mnode/iterator/MNodeIterator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/CachedMTreeStore.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/IMTreeStore.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/MemMTreeStore.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/CachedMNodeContainer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/ICachedMNodeContainer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/MTreeFlushTaskManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/MTreeReleaseTaskManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/SegmentLock.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/cache/CacheEntry.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/cache/CacheManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/cache/ICacheManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/cache/LRUCacheManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/cache/PlainCacheManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/memcontrol/CachedMNodeSizeEstimator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/memcontrol/IMemManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/memcontrol/MemManagerHolder.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/memcontrol/MemManagerNodeEstimatedSizeBasedImpl.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/memcontrol/MemManagerNodeNumBasedImpl.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/schemafile/ISchemaFile.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/schemafile/ISchemaPage.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/schemafile/ISegment.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/schemafile/MockSchemaFile.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/schemafile/RecordUtils.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/schemafile/SchemaFile.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/schemafile/SchemaPage.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/schemafile/Segment.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/path/PathDeserializeUtil.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/rescon/MemoryStatistics.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/rescon/SchemaResourceManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/ISchemaRegion.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaEngineMode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaRegionUtils.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/CheckKeyResult.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/RSchemaConstants.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/RSchemaLogger.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/RSchemaReadWriteHandler.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/RSchemaRegion.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/RSchemaUtils.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/mnode/REntityMNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/mnode/RInternalMNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/mnode/RMNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/mnode/RMNodeType.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/mnode/RMNodeValueType.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/mnode/RMeasurementMNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/mnode/RStorageGroupMNode.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/buffer/DataBlockManagerService.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/buffer/DataBlockManagerServiceThriftHandler.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/buffer/DataBlockService.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/buffer/DataBlockServiceImpl.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/buffer/DataBlockServiceThriftHandler.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/buffer/SinkHandle.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/buffer/StubSinkHandle.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/buffer/TsBlockSerdeFactory.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/DataRegion.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/ResultNodeContext.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/filter/FilterDeserializeUtil.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/schematree/DeviceSchemaInfo.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/ConfigExecution.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/DataDriver.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/DataDriverContext.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/Driver.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/DriverContext.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/ExecFragmentInstance.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/FragmentInstanceExecution.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/FragmentInstanceInfo.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/FragmentInstanceManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/FutureStateChange.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/IConfigTask.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/IQueryExecution.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/QueryState.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/SampleConfigTask.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/SchemaDriver.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/SchemaDriverContext.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/StateMachine.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/scheduler/AbstractFragInsStateTracker.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/scheduler/FixedRateFragInsStateTracker.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/scheduler/FragInstanceDispatchResult.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/scheduler/IFragInstanceDispatcher.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/scheduler/IFragInstanceStateTracker.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/scheduler/IQueryTerminator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/scheduler/InternalServiceClientFactory.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/scheduler/SimpleFragInstanceDispatcher.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/scheduler/SimpleQueryTerminator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/source/DataSourceOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/source/ExchangeOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/schedule/FragmentInstanceManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/schedule/FragmentInstanceScheduler.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/schedule/IFragmentInstanceManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/schedule/IFragmentInstanceScheduler.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/QueryPlanBuilder.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/IOutputPlanNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/ColumnHeader.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/PlanNodeIdAllocator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/write/AuthorNode.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/write/InsertMultiTabletNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/write/InsertMultiTabletsNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/crud/InsertMultiTabletsStatement.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/crud/InsertRowsOfOneDeviceStatement.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/crud/InsertRowsStatement.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/sys/AuthorStatement.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/crud/InsertMultiTabletPlan.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/crud/InsertMultiTabletsPlan.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/expression/ExpressionType.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/tools/dataregion/DeviceMappingViewer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/tools/virtualsg/DeviceMappingViewer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/utils/IExpressionDeserializeUtil.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/utils/SerializedSize.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/utils/StatusUtils.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/utils/writelog/BatchLogReader.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/utils/writelog/ILogReader.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/utils/writelog/ILogWriter.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/utils/writelog/LogWriter.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/utils/writelog/MultiFileLogReader.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/utils/writelog/SingleFileLogReader.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/WALManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/buffer/AbstractWALBuffer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/buffer/IWALBuffer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/buffer/IWALByteBufferView.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/buffer/SignalWALEntry.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/buffer/WALBuffer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/buffer/WALEntry.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/buffer/WALEntryType.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/buffer/WALEntryValue.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/checkpoint/Checkpoint.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/checkpoint/CheckpointManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/checkpoint/CheckpointType.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/checkpoint/MemTableInfo.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/exception/WALException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/exception/WALNodeClosedException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/exception/WALRecoverException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/io/CheckpointReader.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/io/CheckpointWriter.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/io/ILogWriter.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/io/LogWriter.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/io/WALReader.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/io/WALWriter.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/node/IWALNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/node/WALFakeNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/node/WALNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/recover/CheckpointRecoverUtils.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/recover/WALNodeRecoverTask.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/recover/WALRecoverManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/recover/file/AbstractTsFileRecoverPerformer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/recover/file/SealedTsFileRecoverPerformer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/recover/file/TsFilePlanRedoer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/recover/file/UnsealedTsFileRecoverPerformer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/utils/WALMode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/utils/WALWriteUtils.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/utils/listener/AbstractResultListener.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/utils/listener/WALFlushListener.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/utils/listener/WALRecoverListener.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/writelog/WALFlushListener.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/writelog/io/BatchLogReader.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/writelog/io/ILogReader.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/writelog/io/ILogWriter.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/writelog/io/LogWriter.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/writelog/io/MultiFileLogReader.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/writelog/io/SingleFileLogReader.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/writelog/manager/MultiFileLogNodeManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/writelog/manager/WriteLogNodeManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/writelog/node/ExclusiveWriteLogNode.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/writelog/node/WriteLogNode.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/writelog/recover/LogReplayer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/writelog/recover/TsFileRecoverPerformer.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/CompactionUtilsTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/ReadPointCompactionPerformerTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/InnerSpaceCompactionUtilsAlignedTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/InnerSpaceCompactionUtilsNoAlignedTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/InnerSpaceCompactionUtilsOldTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/ReadChunkCompactionPerformerAlignedTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/ReadChunkCompactionPerformerNoAlignedTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/ReadChunkCompactionPerformerOldTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/task/FakedCrossSpaceCompactionTask.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/task/FakedCrossSpaceCompactionTaskFactory.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/task/FakedInnerSpaceCompactionTask.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/task/FakedInnerSpaceCompactionTaskFactory.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/storagegroup/dataregion/HashVirtualPartitionerTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/engine/storagegroup/virtualSg/HashVirtualPartitionerTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/mtree/disk/CachedMNodeContainerTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/mtree/disk/MemManagerTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/mtree/multimode/MTreeDiskModeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/mtree/multimode/MTreeFullMemoryTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/mtree/multimode/MTreeMemoryModeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/mtree/multimode/MTreeNonMemoryTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/mtree/multimode/MTreePartialMemoryTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/mtree/schemafile/RecordUtilTests.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/mtree/schemafile/SchemaFileTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/mtree/schemafile/SchemaPageTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/mtree/schemafile/SegmentTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/multimode/SchemaDiskModeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/multimode/SchemaFullMemoryTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/multimode/SchemaMemoryModeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/multimode/SchemaNonMemoryTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/multimode/SchemaPartialMemoryTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/MRocksDBBenchmark.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/MRocksDBUnitTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/RSchemaReadWriteHandlerTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/RSchemaRegionAdvancedTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/RocksDBBenchmarkEngine.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/RocksDBBenchmarkTask.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/RocksDBTestUtils.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/buffer/SinkHandleTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/buffer/SourceHandleTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/buffer/Utils.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/execution/DataDriverTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/execution/QueryStateMachineTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/schedule/FragmentInstanceManagerTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/schedule/FragmentInstanceSchedulerTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/FragmentInstanceIdTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/FragmentInstanceSerdeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/QueryLogicalPlanUtil.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/PlanNodeDeserializeHelper.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/metadata/read/ShowDevicesNodeSerdeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/AggregateNodeSerdeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/DeviceMergeNodeSerdeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/ExchangeNodeSerdeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/FillNodeSerdeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/FilterNodeSerdeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/FilterNullNodeSerdeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/GroupByLevelNodeSerdeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/LimitNodeSerdeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/OffsetNodeSerdeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/SortNodeSerdeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/TimeJoinNodeSerdeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/sink/FragmentSinkNodeSerdeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/source/SeriesAggregateScanNodeSerdeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/source/SeriesScanNodeSerdeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/qp/physical/SerializedSizeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/service/InternalServiceImplTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/utils/writelog/LogWriterReaderTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/utils/writelog/MultiFileLogReaderTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/wal/DisableWALTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/wal/WALManagerTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/wal/buffer/WALBufferCommonTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/wal/buffer/WALBufferTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/wal/checkpoint/CheckpointManagerTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/wal/io/CheckpointFileTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/wal/io/WALFileTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/wal/node/WALFakeNodeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/wal/node/WALNodeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/wal/recover/WALRecoverManagerTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/wal/recover/file/SealedTsFileRecoverPerformerTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/wal/recover/file/TsFilePlanRedoerTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/wal/recover/file/UnsealedTsFileRecoverPerformerTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/wal/utils/TsFileUtilsForRecoverTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/wal/utils/WALByteBufferForTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/writelog/IoTDBLogFileSizeTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/writelog/PerformanceTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/writelog/WriteLogNodeManagerTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/writelog/WriteLogNodeTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/writelog/io/LogWriterReaderTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/writelog/io/MultiFileLogReaderTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/writelog/recover/DeviceStringTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/writelog/recover/LogReplayerTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/writelog/recover/RecoverResourceFromReaderTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/writelog/recover/SeqTsFileRecoverTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/writelog/recover/UnseqTsFileRecoverTest.java
delete mode 100644 thrift-datanode/pom.xml
delete mode 100644 thrift-datanode/src/main/thrift/datanode.thrift
create mode 100644 thrift/src/main/thrift/common.thrift
create mode 100644 thrift/src/main/thrift/management.thrift
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/ColumnEncoder.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/ColumnEncoderFactory.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/ColumnEncoding.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/Int32ArrayColumnEncoder.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/Int64ArrayColumnEncoder.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/TsBlockSerde.java
create mode 100644 tsfile/src/test/java/org/apache/iotdb/tsfile/common/block/ColumnEncoderTest.java
create mode 100644 tsfile/src/test/java/org/apache/iotdb/tsfile/common/block/Int32ArrayColumnEncoderTest.java
create mode 100644 tsfile/src/test/java/org/apache/iotdb/tsfile/common/block/Int64ArrayColumnEncoderTest.java
create mode 100644 tsfile/src/test/java/org/apache/iotdb/tsfile/common/block/TsBlockSerdeTest.java