You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ji...@apache.org on 2022/04/26 07:24:17 UTC
[iotdb] branch jianyun/de-singleton updated (6622cbbc23 -> b1e02d698a)
This is an automated email from the ASF dual-hosted git repository.
jianyun pushed a change to branch jianyun/de-singleton
in repository https://gitbox.apache.org/repos/asf/iotdb.git
discard 6622cbbc23 [De-Singleton-1] remove singleton pattern for some classes
add ca53f81159 Implement SchemaTree Search (#5383)
add cec372afef Add interface in ConfigIService (#5386)
add 63b46689f8 Add isLeaderOf to Consensus (#5377)
add fcc4bf2746 Update python client doc and code for NumpyTablet (#5395)
add c414b81813 Bump jjwt-jackson from 0.10.7 to 0.10.8 (#5394)
add fdfee46676 Bump httpcore from 4.4.13 to 4.4.15 (#5391)
add c96cfa711d [IOTDB-2684] refactoring confignode architecture and schema partition assign (#5374)
add d9fb0c1d02 [IOTDB-2819][metrics] modify session to session pool. (#5369)
add f144d19c57 [IOTDB-2836] Fix ErrorHandlingUtils exception stacktrace logging (#5399)
add be883fd8cc [IOTDB-2818] Fix exception occurs when submitting compaction task to global queue (#5384)
add 55566b6eb6 refactor count node by level (#5398)
add 1f7361c7f3 [IOTDB-2650] Tablet supports adding String value (#5382)
add d00a3df757 [IOTDB-2833] Add readme to consensus (#5396)
add 6b073731f2 Add c rest client example (#5397)
add 566fa07497 fix bug in ratis consensus test (#5404)
add d8a0ac45a4 Unify class definitions of common concepts and move them into node-commons package (#5400)
add ee6e7700cf [IOTDB-2748] Writing statement and writing process of coordinator (#5355)
add 90e381d7c8 [IOTDB-2811] Fix compaction exception handle failure cause by deletion of storage group (#5363)
add 2c85f9cda2 [IOTDB-2839] Add Python client CI (#5407)
add fbfb3ebe2c [IOTDB-2843] remove unused jna dependency in cli (#5410)
add 0296d2cf9d Fix -DskipTests cannot skip commons tests (#5422)
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 0ec17d79eb fix StorageEngineV2 cannot start (#5484)
add ce4f2b25e4 [IOTDB-2886] refact LocalConfigManager and finish createSchemaRegion (#5486)
add 4fc9c7da54 [IOTDB-2803][new cluster] Adapt show timeseries to mpp (#5418)
add c368467c20 [IOTDB-2866] Support get or create SchemaPartition with PatternTree in config node (#5493)
add fc0313ed8b Fix compile error (#5500)
add 9e1a508be4 [IOTDB-2897] Fix wal recover deadlock (#5499)
add f60c584f4d New sync framework with TsFileSync (#5353)
add 47e2af285a [IOTDB-2871] Data node client to connect with config node (#5488)
add 4cf195c2b5 Update the deviceId in c rest example (#5504)
add 62365feb64 [IOTDB-2882] Fixed display of unary expression (#5485)
add 6139151e78 Consensus dep (#5507)
add 51b10a2679 [IOTDB-2910] Fix Count aggregate is not right after delete sg bug (#5511)
add 40585a34d4 [IOTDB-2805] Create data region (#5509)
add 984f1986d1 [IOTDB-2903] fix last value fetch failure during show timesereis (#5508)
add 8ade542133 Make some modifications according to talking for recent PRs of SchemaRegion (#5498)
add f3dc12ff59 [IOTDB-2896] Fix warning of illegal cross compaction strategy (#5503)
add 7cc2a739b4 [IOTDB-2911][Part 1: Underlying Data Structures] TransformOperator: operator implementation for nested expression evaluation (#5513)
add cc30e64dc2 fix ci (#5519)
add 4de7d70fe1 [IOTDB-2901] Refine codes of DataTypeMismatchException and checkDataTypeMatch (#5501)
add a0b1f19a88 Generate dataset header for query result set —— simple raw data query (#5522)
add 60fc7fc0da Add DistributionPlanner for WRITE operation (#5515)
add becb89fe61 [IOTDB-2905] IoTDBRecoverUnclosedIT failed in ci (#5514)
add 2bd55ae2f4 [IOTDB-2899] Feature/set storage group (#5510)
add 07a407be6f fix NPE when stop IoTDB and MLogTxtWriter parsing CreateAlignedTimeseriesPlan error (#5525)
add 25dc043b17 get time partition interval from config node (#5523)
add 627e479c3b [IOTDB-2779] TemporaryClient for ConfigNode to connect DataNode (#5530)
add 74df66decc [IOTDB-2847] Implementation of PartitionFetcher (#5516)
add a8c8acbc94 Generate header of result set: show timeseries/devices/sg (#5531)
add 976d041b76 [IOTDB-2896] Fix warning of illegal seq compaction performer (#5534)
add 12e3eb74a0 add some news for community/about (#5535)
add 8c09a47c5d Implement basic SchemaFetcher (#5494)
add d1278f8507 [IOTDB-2863] Serialize and deserialize of insert node (#5517)
add 1efdab36b5 Add getSeriesPartitionExecutor() in node-commons (#5528)
add 91dad5be71 fix DataRegionId directory name bug (#5547)
add 2d8a821592 [IOTDB-2921] Fix WALNodeTest of concurrently accessing ArrayList (#5543)
add 3309707399 [IOTDB-2909] ColumnEncoder(s) for BOOLEAN and TEXT (#5512)
add 51b7199ab0 [IOTDB-2888] Unable to select an unary expression followed by a constant expression (#5521)
add d808d844d6 [IOTDB-2913] Add InfluxDB Protocol Test Framework (#5546)
add 60e688841f Fix repeated flip() && Fix configNode's failure for addConsensusGroup && Improve DataNode's joining ConfigNode (#5544)
add 0c50e6c890 [IOTDB-2861] Improve Cross compaction selector file number restrict (#5532)
add 3f2846011c add comment for max_cross_compaction_candidate_file_nul (#5549)
add 0d83f7a894 Open Optimize ConfigNode redirect and create region process (#5550)
add 8d10d159ea [IOTDB-2906] Commit pipe data serial number error, Can not find tsfile (#5536)
add 93ee11b9f3 Add DataNodeTSIServiceImpl as RPCServiceImpl in mpp mode (#5540)
add ad9401282f [IOTDB-2923] fix CI IoTDBSyncReceiverIT.testReceiveDataAndLoad (#5548)
add 8c38d6baac [IOTDB-2842] SHOW PIPE PipeName throws NPE if receiverService isn't initialize (#5414)
add 6f8eadd8f0 fix the spotless issue in last PR (#5559)
add a356eeabc9 [IOTDB-2922] Fix NPE when compacting with files that contains zero device (#5553)
add b2dfcf847b Fix mpp CI (#5562)
add 588fece871 [IOTDB-2852] the import-csv tool can not import the data to nonaligned device (#5420)
add 1e3044dbd9 [IOTDB-2934] Fix StorageEngineV2 cannot recover (#5558)
add 8ed3f3ad5d [IOTDB-2902] Handling user privileges for aligned timeseries related features (#5556)
add 90cd903f9b [IOTDB-2924] UDF Framework: index overflow while iterating sliding windows (#5555)
add 2691ade495 Make standalone mode mpp basically runnable (#5566)
add 83ffc19622 [IOTDB-2892] add PermissionInfoDataSet and test (#5492)
add a263e4c1a3 [IoTDB-2661] Add PlanNode visualizer tool (#5489)
add 016ed3d76c Combine InternalService with ManagementIService (#5578)
add e34854e20f add doc about about/Community(#5575)
add 37346fa551 [IOTDB-2619] Grafana Plugin: Alerting (#5366)
add 38364cf79d [IOTDB-2911] TransformOperator: operator implementation for nested expression evaluation (#5569)
add 77a33e9795 Remove mpp_mode property in iotdb-engine.properties (#5583)
add 3cc7eb2519 [IOTDB-2588] Triggers support any tree level, such as storage groups, devices, measurements, and so on (#5495)
add 8a00e48876 [IOTDB-2803][new cluster][mpp] refine show plan node ser/deserialize (#5581)
add a448999829 [IOTDB-2898] Improve deletion of wal files (#5524)
add 0b61882ab4 Add failed method for Driver (#5589)
add 3d93a7764f Optimize dependencies management to reduce the lib size (#5582)
add f52beecbde Add input location for TimeJoinNode (#5585)
add ac51b0802a [IOTDB-2873] Apache IoTDB Dashboard: Grafana Metrics Template (#5587)
add 4d34f363af [IOTDB-2925]Add Schema File sketch tool (#5570)
add 2be90fe96d Rename thrift EndPoint to TEndPoint (#5590)
add e891a68c13 [IOTDB-2917] Fix flush operation has one residual wal file (#5560)
add eba44b18df [IOTDB-2954] fix influxdb protocol bug found in benchmark test of verificationQueryMode (#5594)
add 79b22a2799 Add UTs for new insert framework and fix insertRowNode memControl (#5576)
add 3bc4955429 [IOTDB-2887][IOTDB-2930][IOTDB-2932] Fix recover test error in CI & Fix NPE while concurrent createTimeseries & Add config check for schema engine mode (#5601)
add 1d0b0ec288 Fix some issues in MPP framework (#5596)
add e0ecf5354e [IOTDB-2844] Implementation of SeriesAggregateScanOperator and AggregateOperator - Part I (#5502)
add 8b2817bc05 [IOTDB-2943] Fix cannot use stop-server.sh to stop IoTDB (#5591)
add 6bd0f2cb0f [IOTDB-2848] Consensus snapshot interface (#5497)
add 564b286edd Format SerializeTask in WALBuffer (#5603)
add a019934b42 Add Thread re-interrupt when catching exception (#5604)
add 1b6a0bc26b [IOTDB-2619][User Docs] Grafana Plugin: Alerting (#5605)
add 380cda196c [IOTDB-2803]Supplement the remaining metadata write plannode and change SchemaRegion to accept plannode parameter (#5529)
add 2927a82915 Bump junit from 4.11 to 4.13.1 in /zeppelin-interpreter (#5428)
add fa7372aa56 Bump jackson-databind from 2.6.7 to 2.12.6.1 in /spark-iotdb-connector (#5425)
add 731965beb0 Separate SchemaRegion Memory Implementation (#5584)
add 67dafed0e6 Add Driver.failed() call in FragmentInstanceScheduler (#5593)
add 55812435d9 Change the result of ConfigExecution from Void to TsBlock (#5609)
add ec3f49549a [IOTDB-2965] Skip failed mlog and snapshot items when upgrading happens (#5608)
add aadd8cae72 [IOTDB-2619][User Docs EN] Grafana Plugin: Alerting (#5612)
add 7ce6033609 [IOTDB-2942] [IOTDB-2944] Delete duplicate data structure in node-commons and extend TDataNodeLocation (#5592)
add fa43cd6998 [rocksdb] add rocksdb docs (#5598)
add 9ff33b3f15 [IOTDB-2932]Fix localPartitionTable concurrent bug (#5607)
add 8db887692a Fix class path in SchemaFileSketcher.sh and mLogParser.sh (#5618)
add 254ca0532b fix the UT of ConfigExecution (#5621)
add 7af14c96ea [rocksdb] add rocksdb properties (#5588)
add d74157cd40 [IOTDB-2880]Add procedure framework (#5477)
add df250d3a1e [IOTDB-2970] Code style: Avoid wildcard imports (#5622)
add 2df96fee1e [rocksdb] updated the interface support (#5625)
add 75620dd4d6 [IOTDB-2971] Fix sink handle memory leak (#5626)
add b2520b31b0 [IOTDB-2880] Fix import check style (#5629)
add f9226c380d Add FragmentInstanceStateMachine for FragmentInstance State change (#5615)
add 9522cfb39e [IOTDB-2835]Fix empty page in selfcheck method of TsFileSequenceReader (#5552)
add 650a7a8e94 fix the bug when matching multi-wildcard in pattern tree (#5631)
add 6952eed0e6 Add block cancel when GetBlockTask throws exception (#5628)
add 1a2ea0c03a Add ColumnMerger to merge multipul input columns of same sensor into one column (#5630)
add 25983540e7 Fix CI (#5639)
add 7a500adb6e [IOTDB-2880] Fix NPE occured in ci test (#5634)
add f037de3705 fix concurrent bug of CachedMNodeContainer.putIfAbsent (#5632)
add 8df96c5ce2 Fix the issue that EndTime in FragmentInstanceContext is not set (#5636)
add dc344e5b70 [IOTDB-2740] Equal size bucket sampling UDFs: EQUAL_SIZE_BUCKET_RANDOM_SAMPLE, EQUAL_SIZE_BUCKET_AGG_SAMPLE, EQUAL_SIZE_BUCKET_M4_SAMPLE (#5518)
add 677f58763b change jenkins timeout from 2 hours to 3 hours
add 9504a2b703 [IOTDB-2976] Add English and Chinese docs for count devices and count storage groups (#5635)
add 61dde93485 filter non schemaRegionDir (#5640)
add a547fef5ca Serialize measurement schema of insert node to wal entry (#5638)
add d939abfc5e Refactor attributes in PlanNode (#5616)
add d3a8516172 Fix TimeJoinNode clone and serde bug (#5644)
add 39619ff619 [IOTDB-2982] Recover tsfile after datanode restart (#5643)
add ce064f429c Add config example for new cluster (#5624)
add 949abc4294 [IOTDB-2979] Optimize the serialization and deserialization of thrift data structures (#5637)
add a27cd2e58b [IOTDB-2984] RatisConsensus Recovery Logic (#5648)
add 9685c5b67b [IOTDB-2930]Fix concurrent UnPin bug & Improve template implementation (#5647)
add d47339793f [IOTDB-2989] Expression Serialize & Deserialize (#5649)
add f03f0205ab [IOTDB-2933] detect sender exit and set pipestatus=STOP (#5557)
add ecd19464f4 Fix import wildcard violation
add 467add666d [IOTDB-2945] Reconstruct ConfigNode manage layer and persistence layer (#5627)
add 74bcc7edc9 [IOTDB-2955] Design and implement ClientManager for thrift client's pooling management (#5595)
add dde44dcbe2 [IOTDB-2996] Fix wildcard import in test folders (#5652)
add ff4161643b will not delete empty .pst now (#5653)
add 907c06e52f Fix schema file with cache of size 1 (#5651)
add dd37fc1097 [IOTDB-2966]fix CompactionTaskManagerTest CI (#5610)
add 407c076424 [IOTDB-2999][Metric] remove useless config and fix default value error. (#5657)
add 138bd00ff9 Optimize source handle error handling (#5659)
add a7b0f198af Support set storage group in standalone mpp mode (#5655)
add 3d040c9855 fix the issue that FragmentInstance's status cannot be updated to FINISHED in some scenario (#5660)
add f7bd1ad8c3 [IOTDB-2912] MPP: FilterOperator (#5645)
add fc62a59a40 [IOTDB-2958]create a simple schemaCache for datanode metadata (#5602)
add 94bded4094 [IOTDB-2968] RatisConsensus snapshot implementation (#5623)
add 3c23ae3f39 [IOTDB-3007] Separate DataNode and IoTDB (#5668)
add 648212e1c4 [IOTDB-3005] Increase read and write permissions in ConfigExecution (#5664)
add 3dc1675e62 [IOTDB-2845] Implementation of DeviceViewOperator Part1 (#5613)
add 54faa59849 Implement MultiColumnMerger to support querying data of one timeseries distributed on different DataNodes (#5663)
add c22c1405ba extract interface from path (#5662)
add f24c7f5d18 [De-Singleton-1] remove singleton pattern for some classes
add b1e02d698a resolve conflict
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 (6622cbbc23)
\
N -- N -- N refs/heads/jianyun/de-singleton (b1e02d698a)
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/client-cpp.yml | 103 +
.github/workflows/client-python.yml | 63 +
.github/workflows/client.yml | 103 -
.github/workflows/grafana-plugin.yml | 7 +-
.github/workflows/influxdb-protocol.yml | 12 +-
.github/workflows/main-unix.yml | 3 +-
.github/workflows/main-win.yml | 3 +-
.github/workflows/sonar-coveralls.yml | 2 +-
Jenkinsfile | 2 +-
LICENSE | 1 +
README.md | 2 +-
README_ZH.md | 2 +-
.../apache/iotdb/db/qp/sql/InfluxDBSqlParser.g4 | 3 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 70 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 24 +
checkstyle.xml | 7 +-
cli/pom.xml | 2 +
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 6 +-
client-cpp/pom.xml | 9 +
client-py/README.md | 290 +-
client-py/SessionAlignedTimeseriesExample.py | 16 +-
client-py/SessionAlignedTimeseriesTest.py | 280 --
client-py/SessionExample.py | 50 +-
client-py/SessionTest.py | 336 --
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/pom.xml | 8 +
client-py/requirements_dev.txt | 2 +-
client-py/tests/tablet_performance_comparison.py | 8 +-
client-py/tests/test_aligned_timeseries.py | 294 ++
client-py/tests/test_dataframe.py | 6 +-
client-py/tests/test_numpy_tablet.py | 147 +
client-py/tests/test_session.py | 362 ++
client-py/tests/test_tablet.py | 109 +
client-py/tests/test_todf.py | 16 +-
.../java/org/apache/iotdb/cluster/ClientMain.java | 2 +-
.../iotdb/cluster/ClusterFileFlushPolicy.java | 11 +-
.../org/apache/iotdb/cluster/ClusterIoTDB.java | 1 -
.../cluster/client/sync/SyncClientAdaptor.java | 2 +-
.../iotdb/cluster/coordinator/Coordinator.java | 34 +-
.../cluster/log/applier/AsyncDataLogApplier.java | 10 +-
.../iotdb/cluster/log/applier/BaseApplier.java | 4 +-
.../iotdb/cluster/log/applier/DataLogApplier.java | 8 +-
.../log/manage/PartitionedSnapshotLogManager.java | 2 +-
.../iotdb/cluster/log/snapshot/FileSnapshot.java | 2 +-
.../iotdb/cluster/metadata/CSchemaProcessor.java | 59 +-
.../apache/iotdb/cluster/metadata/MetaPuller.java | 3 +-
.../partition/slot/SlotTimePartitionFilter.java | 2 +-
.../iotdb/cluster/query/ClusterPlanExecutor.java | 2 +-
.../iotdb/cluster/query/ClusterPlanRouter.java | 54 +-
.../apache/iotdb/cluster/query/ClusterPlanner.java | 1 +
.../iotdb/cluster/query/LocalQueryExecutor.java | 8 +-
.../cluster/query/reader/ClusterReaderFactory.java | 20 +-
.../iotdb/cluster/server/ClusterTSServiceImpl.java | 2 +-
.../server/basic/ClusterServiceProvider.java | 2 +-
.../server/handlers/caller/LogCatchUpHandler.java | 4 +-
.../handlers/forwarder/ForwardPlanHandler.java | 2 +-
.../cluster/server/member/DataGroupMember.java | 24 +-
.../cluster/server/member/MetaGroupMember.java | 8 +-
.../iotdb/cluster/server/member/RaftMember.java | 4 +-
.../cluster/server/service/BaseAsyncService.java | 6 +-
.../cluster/server/service/BaseSyncService.java | 2 +-
.../server/service/DataGroupServiceImpls.java | 2 +-
.../apache/iotdb/cluster/utils/PartitionUtils.java | 2 +-
.../apache/iotdb/cluster/utils/StatusUtils.java | 16 +-
.../cluster/client/sync/SyncClientAdaptorTest.java | 2 +-
.../iotdb/cluster/common/TestAsyncDataClient.java | 2 +-
.../iotdb/cluster/integration/SingleNodeTest.java | 5 +-
.../iotdb/cluster/log/CommitLogCallbackTest.java | 2 +-
.../iotdb/cluster/log/CommitLogTaskTest.java | 5 +-
.../cluster/log/applier/DataLogApplierTest.java | 10 +-
.../FilePartitionedSnapshotLogManagerTest.java | 2 +
.../cluster/log/snapshot/FileSnapshotTest.java | 26 +-
.../log/snapshot/MetaSimpleSnapshotTest.java | 2 +-
.../log/snapshot/PartitionedSnapshotTest.java | 10 +-
.../cluster/log/snapshot/PullSnapshotTaskTest.java | 6 +-
.../handlers/forwarder/ForwardPlanHandlerTest.java | 2 +-
.../iotdb/cluster/server/member/BaseMember.java | 9 +-
.../cluster/server/member/DataGroupMemberTest.java | 8 +-
.../cluster/server/member/MetaGroupMemberTest.java | 11 +-
.../iotdb/cluster/utils/SerializeUtilTest.java | 2 -
confignode/pom.xml | 14 +-
confignode/src/assembly/confignode.xml | 9 +-
.../resources/conf/iotdb-confignode.properties | 80 +-
.../iotdb/confignode/cli/TemporaryClient.java | 202 +
.../client/ConfigNodeClientPoolFactory.java | 74 +
.../iotdb/confignode/conf/ConfigNodeConf.java | 160 +-
.../iotdb/confignode/conf/ConfigNodeConfCheck.java | 57 +-
.../confignode/conf/ConfigNodeDescriptor.java | 89 +-
.../consensus/request/ConfigRequest.java | 154 +
.../consensus/request/ConfigRequestType.java | 52 +
.../consensus/request/auth/AuthorReq.java | 248 +
.../request/read/GetOrCreateDataPartitionReq.java | 141 +
.../read/GetOrCreateSchemaPartitionReq.java | 98 +
.../request/read/QueryDataNodeInfoReq.java | 68 +
.../request/read/QueryStorageGroupSchemaReq.java | 41 +
.../request/write/CreateDataPartitionReq.java | 129 +
.../consensus/request/write/CreateRegionsReq.java | 96 +
.../request/write/CreateSchemaPartitionReq.java | 100 +
.../request/write/DeleteStorageGroupReq.java | 39 +
.../request/write/RegisterDataNodeReq.java | 69 +
.../request/write/SetStorageGroupReq.java | 75 +
.../response/DataNodeConfigurationResp.java | 62 +
.../consensus/response/DataNodeLocationsResp.java | 56 +
.../consensus/response/DataNodesInfoDataSet.java | 41 -
.../consensus/response/DataPartitionResp.java | 62 +
.../consensus/response/PermissionInfoResp.java | 56 +
.../consensus/response/SchemaPartitionResp.java | 57 +
.../response/StorageGroupSchemaDataSet.java | 37 -
.../consensus/response/StorageGroupSchemaResp.java | 65 +
.../statemachine/PartitionRegionStateMachine.java | 48 +-
.../physical/UnknownPhysicalPlanTypeException.java | 4 +-
.../confignode/manager/ClusterSchemaManager.java | 185 +
.../iotdb/confignode/manager/ConfigManager.java | 369 +-
.../iotdb/confignode/manager/ConsensusManager.java | 109 +
.../iotdb/confignode/manager/DataNodeManager.java | 180 +
.../apache/iotdb/confignode/manager/Manager.java | 143 +
.../iotdb/confignode/manager/PartitionManager.java | 235 +
.../confignode/manager/PermissionManager.java | 58 +
.../iotdb/confignode/partition/DataNodeInfo.java | 88 -
.../confignode/partition/DataPartitionInfo.java | 80 -
.../iotdb/confignode/partition/PartitionTable.java | 189 -
.../confignode/partition/SchemaPartitionInfo.java | 62 -
.../confignode/partition/StorageGroupSchema.java | 77 -
.../iotdb/confignode/persistence/AuthorInfo.java | 255 ++
.../iotdb/confignode/persistence/DataNodeInfo.java | 191 +
.../confignode/persistence/PartitionInfo.java | 307 ++
.../confignode/persistence/StorageGroupInfo.java | 150 +
.../iotdb/confignode/physical/PhysicalPlan.java | 106 -
.../confignode/physical/PhysicalPlanType.java | 28 -
.../physical/sys/DeleteStorageGroupPlan.java | 39 -
.../physical/sys/QueryDataNodeInfoPlan.java | 54 -
.../physical/sys/QueryStorageGroupSchemaPlan.java | 41 -
.../physical/sys/RegisterDataNodePlan.java | 65 -
.../physical/sys/SetStorageGroupPlan.java | 55 -
.../iotdb/confignode/service/ConfigNode.java | 27 +-
.../confignode/service/balancer/LoadBalancer.java | 12 -
.../confignode/service/executor/PlanExecutor.java | 85 +-
.../service/thrift/ConfigNodeRPCService.java | 89 +
.../thrift/ConfigNodeRPCServiceHandler.java | 52 +
.../service/thrift/ConfigNodeRPCServiceMBean.java | 22 +
.../thrift/ConfigNodeRPCServiceProcessor.java | 252 ++
.../service/thrift/server/ConfigNodeRPCServer.java | 88 -
.../thrift/server/ConfigNodeRPCServerMBean.java | 22 -
.../server/ConfigNodeRPCServerProcessor.java | 162 -
.../thrift/server/ConfigNodeRPCServiceHandler.java | 52 -
.../iotdb/confignode/cli/TemporaryClientDemo.java | 76 +
.../confignode/consensus/RatisConsensusDemo.java | 136 -
.../manager/ConfigManagerManualTest.java | 132 -
.../hash/DeviceGroupHashExecutorManualTest.java | 5 +-
.../physical/ConfigRequestSerDeTest.java | 438 ++
.../thrift/ConfigNodeRPCServiceProcessorTest.java | 847 ++++
.../server/ConfigNodeRPCServerProcessorTest.java | 117 -
.../confignode1conf/iotdb-confignode.properties | 29 +
.../resources/confignode1conf}/logback.xml | 0
.../confignode2conf/iotdb-confignode.properties | 29 +
.../resources/confignode2conf}/logback.xml | 0
.../confignode3conf/iotdb-confignode.properties | 29 +
.../resources/confignode3conf}/logback.xml | 0
consensus/README.md | 163 +
consensus/pom.xml | 11 +-
.../apache/iotdb/consensus/ConsensusFactory.java | 58 +
.../org/apache/iotdb/consensus/IConsensus.java | 11 +-
.../iotdb/consensus/common/ConsensusGroup.java | 2 +
.../iotdb/consensus/common/ConsensusGroupId.java | 64 -
.../iotdb/consensus/common/ConsensusType.java | 54 -
.../apache/iotdb/consensus/common/Endpoint.java | 64 -
.../apache/iotdb/consensus/common/GroupType.java | 27 -
.../org/apache/iotdb/consensus/common/Peer.java | 9 +-
.../iotdb/consensus/common/SnapshotMeta.java | 54 +
.../common/response/ConsensusWriteResponse.java | 6 +-
.../ConsensusGroupAlreadyExistException.java | 4 +-
.../exception/ConsensusGroupNotExistException.java | 2 +-
.../PeerAlreadyInConsensusGroupException.java | 2 +-
.../PeerNotInConsensusGroupException.java | 2 +-
.../ratis/ApplicationStateMachineProxy.java | 83 +-
.../iotdb/consensus/ratis/RatisClientFactory.java | 67 +
.../iotdb/consensus/ratis/RatisConsensus.java | 355 +-
.../iotdb/consensus/ratis/RequestMessage.java | 4 +-
.../iotdb/consensus/ratis/ResponseMessage.java | 2 +-
.../iotdb/consensus/ratis/SnapshotStorage.java | 100 +
.../org/apache/iotdb/consensus/ratis/Utils.java | 69 +-
.../consensus/standalone/StandAloneConsensus.java | 37 +-
.../consensus/standalone/StandAloneServerImpl.java | 22 +-
.../consensus/statemachine/EmptyStateMachine.java | 22 +-
.../consensus/statemachine/IStateMachine.java | 55 +-
.../iotdb/consensus/ratis/RatisConsensusTest.java | 165 +-
.../apache/iotdb/consensus/ratis/SnapshotTest.java | 120 +
.../apache/iotdb/consensus/ratis/TestUtils.java | 203 +
.../apache/iotdb/consensus/ratis/UtilsTest.java | 9 +-
.../standalone/StandAloneConsensusTest.java | 93 +-
cross-tests/pom.xml | 2 +
.../tests/tools/importCsv/AbstractScript.java | 7 +-
.../tests/tools/importCsv/ImportCsvTestIT.java | 31 +
distribution/pom.xml | 6 +
distribution/src/assembly/all.xml | 4 +
distribution/src/assembly/server.xml | 4 +
docker/src/main/Dockerfile-single-influxdb | 46 +
docs/Community/About.md | 99 +
docs/Community/Community-Powered By.md | 2 +-
docs/Development/ContributeGuide.md | 16 +
docs/UserGuide/API/InfluxDB-Protocol.md | 344 ++
.../UserGuide/API/Programming-Python-Native-API.md | 52 +-
docs/UserGuide/Data-Concept/Time-Partition.md | 8 +-
docs/UserGuide/Data-Modeling/DataRegion.md | 55 +
.../Data-Modeling/SchemaRegion-rocksdb.md | 93 +
.../UserGuide/Data-Modeling/VirtualStorageGroup.md | 55 -
.../Ecosystem Integration/Grafana Plugin.md | 141 +-
docs/UserGuide/Library-UDF/Anomaly-Detection.md | 523 ---
docs/UserGuide/Maintenance-Tools/Metric-Tool.md | 13 +-
.../Maintenance-Tools/SchemaFileSketch-Tool.md | 38 +
docs/UserGuide/Maintenance-Tools/Sync-Tool.md | 396 +-
docs/UserGuide/Operate-Metadata/Node.md | 45 +
docs/UserGuide/Operate-Metadata/Storage-Group.md | 60 +
docs/UserGuide/Query-Data/Select-Expression.md | 143 +
docs/UserGuide/Reference/Config-Manual.md | 41 +-
docs/zh/Community/About.md | 127 +
docs/zh/Development/ContributeGuide.md | 28 +-
docs/zh/UserGuide/API/InfluxDB-Protocol.md | 124 +-
.../UserGuide/API/Programming-Python-Native-API.md | 49 +-
docs/zh/UserGuide/Data-Concept/Time-Partition.md | 2 -
docs/zh/UserGuide/Data-Modeling/DataRegion.md | 53 +
.../Data-Modeling/SchemaRegion-rocksdb.md | 93 +
.../UserGuide/Data-Modeling/VirtualStorageGroup.md | 53 -
.../Ecosystem Integration/Grafana Plugin.md | 143 +-
docs/zh/UserGuide/Library-UDF/Anomaly Detection.md | 530 ---
docs/zh/UserGuide/Maintenance-Tools/Metric-Tool.md | 13 +-
.../Maintenance-Tools/SchemaFileSketch-Tool.md | 35 +
docs/zh/UserGuide/Maintenance-Tools/Sync-Tool.md | 493 +-
docs/zh/UserGuide/Operate-Metadata/Node.md | 45 +
.../zh/UserGuide/Operate-Metadata/Storage-Group.md | 60 +
docs/zh/UserGuide/Query-Data/Select-Expression.md | 143 +
docs/zh/UserGuide/Reference/Config-Manual.md | 16 +-
docs/zh/UserGuide/UDF-Library/Data-Repairing.md | 1 -
.../iotdb/hadoop/tsfile/TSFMRReadExample.java | 5 +-
example/rest-client-c-example/CMakeLists.txt | 25 +
example/rest-client-c-example/README.md | 111 +
example/rest-client-c-example/base64.c | 100 +
example/rest-client-c-example/base64.h | 30 +
example/rest-client-c-example/main.c | 128 +
.../controller/DatabaseConnectController.java | 3 +-
.../iotdb/web/grafana/dao/impl/BasicDaoImpl.java | 43 +-
.../Apache IoTDB Dashboard v0.13.1.json | 1527 +++++++
.../Apache IoTDB Dashboard v0.14.0.json | 1527 +++++++
grafana-plugin/.gitignore | 1 +
grafana-plugin/Magefile.go | 32 +
grafana-plugin/README.md | 38 +-
grafana-plugin/backend-compile.sh | 36 +
grafana-plugin/go.mod | 23 +
grafana-plugin/go.sum | 659 +++
grafana-plugin/package.json | 7 +-
grafana-plugin/pkg/main.go | 40 +
grafana-plugin/pkg/plugin/plugin.go | 291 ++
grafana-plugin/pom.xml | 21 +
grafana-plugin/src/QueryEditor.tsx | 2 +-
grafana-plugin/src/datasource.ts | 130 +-
grafana-plugin/src/plugin.json | 3 +
grafana-plugin/yarn.lock | 4726 ++++++++++----------
.../apache/iotdb/hadoop/tsfile/TSFInputFormat.java | 11 +-
.../iotdb/hadoop/tsfile/record/HDFSTSRecord.java | 8 +-
.../iotdb/hadoop/tsfile/TSFInputSplitTest.java | 3 +-
.../org/apache/iotdb/hive/TSFHiveInputFormat.java | 6 +-
.../org/apache/iotdb/hive/TsFileDeserializer.java | 10 +-
.../apache/iotdb/hive/TsFileDeserializerTest.java | 11 +-
.../org/apache/iotdb/hive/TsFileSerDeTest.java | 11 +-
influxdb-protocol/pom.xml | 40 +-
.../org/apache/iotdb/influxdb/IoTDBInfluxDB.java | 3 +-
.../iotdb/influxdb/protocol/dto/SessionPoint.java | 20 +-
.../protocol/impl/IoTDBInfluxDBService.java | 12 +-
.../iotdb/influxdb/session/InfluxDBSession.java | 44 +-
.../influxdb/integration/IoTDBInfluxDBIT.java | 34 +-
.../iotdb/integration/env/ClusterEnvConfig.java | 5 +-
.../org/apache/iotdb/itbase/env/BaseConfig.java | 2 +-
.../apache/iotdb/db/integration/IoTDBAliasIT.java | 5 +-
.../iotdb/db/integration/IoTDBCompleteIT.java | 15 +-
.../apache/iotdb/db/integration/IoTDBDaemonIT.java | 16 +-
.../db/integration/IoTDBDeleteStorageGroupIT.java | 23 +
.../iotdb/db/integration/IoTDBFilePathUtilsIT.java | 2 +-
.../org/apache/iotdb/db/integration/IoTDBInIT.java | 7 +-
.../db/integration/IoTDBLoadExternalTsfileIT.java | 76 +-
.../integration/IoTDBManageTsFileResourceIT.java | 8 +-
.../iotdb/db/integration/IoTDBMaxTimeQueryIT.java | 9 +-
.../iotdb/db/integration/IoTDBMetadataFetchIT.java | 38 +
.../db/integration/IoTDBNewTsFileCompactionIT.java | 7 +-
.../db/integration/IoTDBRecoverUnclosedIT.java | 17 +-
.../db/integration/IoTDBResultMetadataIT.java | 13 +-
.../db/integration/IoTDBSchemaTemplateIT.java | 11 +-
.../iotdb/db/integration/IoTDBSelectSchemaIT.java | 127 +
.../db/integration/IoTDBTriggerExecutionIT.java | 188 +-
.../apache/iotdb/db/integration/IoTDBTtlIT.java | 2 +-
.../db/integration/IoTDBUDTFBuiltinFunctionIT.java | 190 +
.../aggregation/IoTDBAggregationIT.java | 28 +
.../aligned/IOTDBInsertAlignedValuesIT.java | 372 --
...ggregationWithoutValueFilterWithDeletionIT.java | 11 +-
...upBySlidingWindowQueryWithoutValueFilterIT.java | 9 +-
.../aligned/IoTDBInsertAlignedValuesIT.java | 391 ++
.../aligned/IoTDBLoadExternalAlignedTsFileIT.java | 70 +-
.../db/integration/env/StandaloneEnvConfig.java | 4 +-
.../groupby/IOTDBGroupByInnerIntervalIT.java | 13 +-
.../db/integration/groupby/IoTDBGroupByFillIT.java | 11 +-
.../sync/IoTDBSyncReceiverCollectorIT.java | 513 +++
.../db/integration/sync/IoTDBSyncReceiverIT.java | 360 ++
.../sync/IoTDBSyncReceiverLoaderIT.java | 212 +
.../db/integration/sync/IoTDBSyncSenderIT.java | 304 ++
.../iotdb/db/integration/sync/SyncTestUtil.java | 238 +
.../db/integration/sync/TransportClientMock.java | 69 +
.../versionadaption/IoTDBDDLVersionAdaptionIT.java | 4 +-
.../IoTDBQueryVersionAdaptionIT.java | 1 -
.../iotdb/session/IoTDBSessionComplexIT.java | 7 +-
.../session/IoTDBSessionDisableMemControlIT.java | 8 +-
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 46 +-
.../iotdb/session/IoTDBSessionVectorInsertIT.java | 4 +-
.../src/test/resources/iotdb-engine.properties | 3 +-
integration/src/test/resources/logback-test.xml | 2 +-
.../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 | 4 +-
.../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 ++
metrics/dropwizard-metrics/pom.xml | 2 +-
.../dropwizard/DropwizardMetricManager.java | 25 +-
.../iotdb/metrics/dropwizard/MetricName.java | 6 +-
.../reporter/DropwizardMetricsExporter.java | 10 +-
.../metrics/dropwizard/reporter/IoTDBReporter.java | 38 +-
.../dropwizard/DropwizardMetricManagerTest.java | 12 +-
.../main/assembly/resources/conf/iotdb-metric.yml | 1 +
.../org/apache/iotdb/metrics/MetricManager.java | 6 +-
.../apache/iotdb/metrics/config/MetricConfig.java | 30 +-
.../interface/src/test/resources/iotdb-metric.yml | 1 +
.../micrometer/MicrometerMetricManager.java | 21 +-
.../micrometer/reporter/IoTDBMeterRegistry.java | 32 +-
node-commons/pom.xml | 34 +-
.../commons/client/AsyncBaseClientFactory.java | 47 +
.../iotdb/commons/client/BaseClientFactory.java | 41 +
.../commons/client/ClientFactoryProperty.java | 93 +
.../apache/iotdb/commons/client/ClientManager.java | 95 +
.../iotdb/commons/client/ClientPoolProperty.java | 83 +
.../iotdb/commons/client/IClientManager.java | 43 +
.../iotdb/commons/client/IClientPoolFactory.java | 28 +
.../async/AsyncConfigNodeIServiceClient.java | 145 +
.../async/AsyncDataNodeDataBlockServiceClient.java | 146 +
.../async/AsyncDataNodeInternalServiceClient.java | 157 +
.../client/sync/SyncConfigNodeIServiceClient.java | 119 +
.../sync/SyncDataNodeDataBlockServiceClient.java | 120 +
.../sync/SyncDataNodeInternalServiceClient.java | 131 +
.../commons/concurrent/IoTDBThreadPoolFactory.java | 12 +
.../iotdb/commons/concurrent/ThreadName.java | 29 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 22 +
.../iotdb/commons/consensus/ConsensusGroupId.java | 74 +
.../iotdb/commons/consensus/DataRegionId.java | 71 +
.../iotdb/commons/consensus/PartitionRegionId.java | 71 +
.../iotdb/commons/consensus/SchemaRegionId.java | 71 +
.../exception/runtime/ThriftSerDeException.java | 26 +
.../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/DataPartition.java | 234 +
.../iotdb/commons/partition/DataPartitionInfo.java | 67 -
.../commons/partition/DataPartitionQueryParam.java | 23 +-
.../iotdb/commons/partition/DataRegionId.java | 39 -
.../commons/partition/DataRegionReplicaSet.java | 61 -
.../iotdb/commons/partition/DeviceGroupId.java | 44 -
.../apache/iotdb/commons/partition/Partition.java | 41 +
.../iotdb/commons/partition/PartitionInfo.java | 41 -
.../iotdb/commons/partition/SchemaPartition.java | 159 +
.../commons/partition/SchemaPartitionInfo.java | 36 -
.../iotdb/commons/partition/SchemaRegionId.java | 54 -
.../commons/partition/SchemaRegionReplicaSet.java | 44 -
.../iotdb/commons/partition/TimePartitionId.java | 31 -
.../executor/SeriesPartitionExecutor.java | 52 +
.../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/service/JMXService.java | 13 +-
.../apache/iotdb/commons/service/ServiceType.java | 6 +-
.../iotdb/commons/service/ThriftService.java | 8 +-
.../commons/utils/BasicStructureSerDeUtil.java | 242 +
.../apache/iotdb/commons/utils/CommonUtils.java | 12 +-
.../apache/iotdb/commons/utils/StatusUtils.java | 223 +
.../commons/utils/ThriftCommonsSerDeUtils.java | 165 +
.../commons/utils/ThriftConfigNodeSerDeUtils.java | 69 +
.../apache/iotdb/commons/ClientManagerTest.java | 456 ++
.../apache/iotdb/commons/ConsensusGroupIdTest.java | 50 +
.../commons/utils/BasicStructureSerDeUtilTest.java | 88 +
.../commons/utils/ThriftCommonsSerDeUtilsTest.java | 116 +
.../utils/ThriftConfigNodeSerDeUtilsTest.java | 67 +
pom.xml | 30 +-
procedure/pom.xml | 93 +
.../iotdb/procedure/CompletedProcedureCleaner.java | 88 +
.../procedure/CompletedProcedureRetainer.java | 36 +
.../apache/iotdb/procedure/InternalProcedure.java | 61 +
.../java/org/apache/iotdb/procedure/Procedure.java | 895 ++++
.../apache/iotdb/procedure/ProcedureExecutor.java | 995 +++++
.../apache/iotdb/procedure/ProcedureLockState.java | 26 +
.../apache/iotdb/procedure/RootProcedureStack.java | 177 +
.../iotdb/procedure/StateMachineProcedure.java | 329 ++
.../apache/iotdb/procedure/StoppableThread.java | 49 +
.../iotdb/procedure/TimeoutExecutorThread.java | 107 +
.../iotdb/procedure/conf/ProcedureNodeConfig.java | 153 +
.../conf/ProcedureNodeConfigDescriptor.java | 219 +
.../procedure/conf/ProcedureNodeConstant.java | 32 +
.../procedure/env/ClusterProcedureEnvironment.java | 25 +
.../exception/ProcedureAbortedException.java | 30 +
.../procedure/exception/ProcedureException.java | 44 +
.../exception/ProcedureSuspendedException.java | 39 +
.../exception/ProcedureTimeoutException.java | 26 +
.../exception/ProcedureYieldException.java | 36 +
.../scheduler/AbstractProcedureScheduler.java | 211 +
.../procedure/scheduler/ProcedureScheduler.java | 109 +
.../scheduler/SimpleProcedureScheduler.java | 78 +
.../iotdb/procedure/service/ProcedureNode.java | 98 +
.../procedure/service/ProcedureNodeMBean.java | 22 +
.../iotdb/procedure/service/ProcedureServer.java | 118 +
.../service/ProcedureServerCommandLine.java | 52 +
.../service/ProcedureServerProcessor.java | 77 +
.../procedure/service/ProcedureServiceHanlder.java | 45 +
.../iotdb/procedure/store/IProcedureStore.java | 48 +
.../iotdb/procedure/store/ProcedureStore.java | 195 +
.../apache/iotdb/procedure/store/ProcedureWAL.java | 106 +
.../apache/iotdb/procedure/NoopProcedureStore.java | 70 +
.../org/apache/iotdb/procedure/TestLockRegime.java | 46 +
.../org/apache/iotdb/procedure/TestProcEnv.java | 57 +
.../apache/iotdb/procedure/TestProcedureBase.java | 83 +
.../iotdb/procedure/TestProcedureExecutor.java | 111 +
.../apache/iotdb/procedure/TestSTMProcedure.java | 57 +
.../iotdb/procedure/entity/IncProcedure.java | 57 +
.../iotdb/procedure/entity/NoopProcedure.java | 44 +
.../procedure/entity/SimpleLockProcedure.java | 80 +
.../iotdb/procedure/entity/SimpleSTMProcedure.java | 97 +
.../iotdb/procedure/entity/SleepProcedure.java | 46 +
.../iotdb/procedure/entity/StuckProcedure.java | 59 +
.../iotdb/procedure/entity/StuckSTMProcedure.java | 112 +
.../procedure/service/TestProcedureService.java | 87 +
.../iotdb/procedure/store/TestProcedureStore.java | 111 +
.../iotdb/procedure/util/ProcedureTestUtil.java | 66 +
server/pom.xml | 48 +-
.../resources/conf/iotdb-engine.properties | 290 +-
.../resources/conf/iotdb-sync-client.properties | 35 -
.../resources/conf/schema-rocksdb.properties | 86 +
.../assembly/resources/tools/mlog/mLogParser.bat | 62 -
.../assembly/resources/tools/mlog/mLogParser.sh | 48 -
.../assembly/resources/tools/rocksdb-transfer.bat | 126 +
.../assembly/resources/tools/rocksdb-transfer.sh | 82 +
.../resources/tools/schema/SchemaFileSketcher.bat | 62 +
.../resources/tools/schema/SchemaFileSketcher.sh | 48 +
.../assembly/resources/tools/schema/mLogParser.bat | 62 +
.../assembly/resources/tools/schema/mLogParser.sh | 48 +
.../assembly/resources/tools/start-sync-client.bat | 71 -
.../assembly/resources/tools/start-sync-client.sh | 54 -
.../assembly/resources/tools/stop-sync-client.bat | 23 -
.../assembly/resources/tools/stop-sync-client.sh | 30 -
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 4 +
.../db/auth/authorizer/AuthorizerManager.java | 202 +
.../iotdb/db/auth/authorizer/BasicAuthorizer.java | 1 +
.../db/auth/authorizer/ClusterAuthorizer.java | 110 +
.../apache/iotdb/db/client/ConfigNodeClient.java | 338 ++
.../iotdb/db/client/DataNodeClientPoolFactory.java | 148 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 651 ++-
.../org/apache/iotdb/db/conf/IoTDBConfigCheck.java | 49 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 340 +-
.../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 +
.../consensus/statemachine/BaseStateMachine.java | 4 +-
.../statemachine/DataRegionStateMachine.java | 72 +-
.../statemachine/SchemaRegionStateMachine.java | 45 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 214 +-
.../apache/iotdb/db/engine/StorageEngineV2.java | 597 +++
.../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 | 150 +-
.../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 | 47 +
.../constant/InnerSeqCompactionPerformer.java | 41 +
.../constant/InnerSequenceCompactionSelector.java | 48 +
.../constant/InnerUnseqCompactionPerformer.java | 41 +
.../InnerUnsequenceCompactionSelector.java | 48 +
.../AbstractCrossSpaceCompactionSelector.java | 56 -
.../cross/AbstractCrossSpaceCompactionTask.java | 104 -
.../compaction/cross/CrossCompactionStrategy.java | 79 -
.../compaction/cross/CrossSpaceCompactionTask.java | 290 ++
.../cross/CrossSpaceCompactionTaskFactory.java | 49 -
.../compaction/cross/ICrossSpaceSelector.java | 30 +
.../RewriteCrossSpaceCompactionResource.java | 206 +
.../RewriteCrossSpaceCompactionSelector.java | 62 +-
.../manage/CrossSpaceCompactionResource.java | 205 -
.../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 | 19 +-
.../rewrite/task/ReadPointPerformerSubTask.java | 107 +
.../task/RewriteCrossSpaceCompactionTask.java | 250 --
.../AbstractInnerSpaceCompactionSelector.java | 59 -
.../inner/AbstractInnerSpaceCompactionTask.java | 151 -
.../compaction/inner/IInnerSeqSpaceSelector.java | 28 +
.../compaction/inner/IInnerUnseqSpaceSelector.java | 28 +
.../compaction/inner/InnerCompactionStrategy.java | 80 -
.../compaction/inner/InnerSpaceCompactionTask.java | 378 ++
.../inner/InnerSpaceCompactionTaskFactory.java | 48 -
.../sizetiered/SizeTieredCompactionSelector.java | 74 +-
.../inner/sizetiered/SizeTieredCompactionTask.java | 282 --
.../inner/utils/InnerSpaceCompactionUtils.java | 302 --
.../inner/utils/MultiTsFileDeviceIterator.java | 5 +-
.../compaction/log/CompactionLogAnalyzer.java | 162 +
.../db/engine/compaction/log/CompactionLogger.java | 83 +
.../db/engine/compaction/log/TsFileIdentifier.java | 234 +
.../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 | 27 +-
.../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 | 333 +-
.../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/modification/Deletion.java | 23 +
.../io/LocalTextModificationAccessor.java | 7 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 3493 +++++++++++++++
.../db/engine/storagegroup/StorageGroupInfo.java | 49 +-
.../db/engine/storagegroup/TsFileManager.java | 53 +-
.../db/engine/storagegroup/TsFileProcessor.java | 413 +-
.../engine/storagegroup/TsFileProcessorInfo.java | 9 +-
.../db/engine/storagegroup/TsFileResource.java | 14 +-
.../db/engine/storagegroup/TsFileResourceList.java | 5 +-
.../storagegroup/VirtualStorageGroupProcessor.java | 3210 -------------
.../dataregion/HashVirtualPartitioner.java | 58 +
.../dataregion/StorageGroupManager.java | 499 +++
.../dataregion/VirtualPartitioner.java | 39 +
.../virtualSg/HashVirtualPartitioner.java | 58 -
.../virtualSg/StorageGroupManager.java | 513 ---
.../storagegroup/virtualSg/VirtualPartitioner.java | 39 -
.../db/engine/trigger/executor/TriggerEngine.java | 20 +-
.../engine/trigger/executor/TriggerExecutor.java | 29 +-
.../engine/trigger/service/TriggerLogReader.java | 2 +-
.../engine/trigger/service/TriggerLogWriter.java | 4 +-
.../service/TriggerRegistrationService.java | 54 +-
.../iotdb/db/exception/BatchProcessException.java | 2 +-
.../iotdb/db/exception/DataRegionException.java | 35 +
.../exception/StorageGroupProcessorException.java | 35 -
.../SyncDeviceOwnerConflictException.java | 40 -
.../metadata/AcquireLockTimeoutException.java | 26 +
.../metadata/DataTypeMismatchException.java | 6 +-
.../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 | 13 +-
.../sync/PipeDataLoadBearableException.java | 25 +
.../db/exception/sync/PipeDataLoadException.java | 25 +
.../sync/PipeDataLoadUnbearableException.java | 25 +
.../iotdb/db/exception/sync/PipeException.java | 36 +
.../db/exception/sync/PipeServerException.java | 34 +
.../iotdb/db/exception/sync/PipeSinkException.java | 42 +
.../iotdb/db/localconfignode/LocalConfigNode.java | 784 ++++
.../localconfignode/LocalDataPartitionTable.java | 126 +
.../localconfignode/LocalSchemaPartitionTable.java | 121 +
.../iotdb/db/metadata/LocalConfigManager.java | 783 ----
.../db/metadata/LocalSchemaPartitionTable.java | 121 -
.../iotdb/db/metadata/LocalSchemaProcessor.java | 163 +-
.../apache/iotdb/db/metadata/MetadataConstant.java | 4 +
.../db/metadata/cache/DataNodeSchemaCache.java | 186 +
.../iotdb/db/metadata/cache/SchemaCacheEntity.java | 114 +
.../db/metadata/idtable/IDTableHashmapImpl.java | 50 +-
.../iotdb/db/metadata/idtable/IDTableManager.java | 19 +-
.../iotdb/db/metadata/idtable/entry/IDeviceID.java | 4 +
.../idtable/entry/InsertMeasurementMNode.java | 41 +-
.../db/metadata/idtable/entry/PlainDeviceID.java | 12 +
.../db/metadata/idtable/entry/SHA256DeviceID.java | 21 +
.../db/metadata/lastCache/LastCacheManager.java | 8 +-
.../iotdb/db/metadata/logfile/MLogReader.java | 2 +-
.../iotdb/db/metadata/logfile/MLogTxtWriter.java | 11 +-
.../iotdb/db/metadata/logfile/MLogWriter.java | 2 +-
.../iotdb/db/metadata/mnode/EntityMNode.java | 8 +
.../org/apache/iotdb/db/metadata/mnode/IMNode.java | 25 +-
.../iotdb/db/metadata/mnode/InternalMNode.java | 29 +-
.../org/apache/iotdb/db/metadata/mnode/MNode.java | 54 +-
.../apache/iotdb/db/metadata/mnode/MNodeUtils.java | 1 +
.../iotdb/db/metadata/mnode/MeasurementMNode.java | 18 +-
.../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/IMTreeBelowSG.java | 308 ++
.../iotdb/db/metadata/mtree/MTreeAboveSG.java | 67 +-
.../iotdb/db/metadata/mtree/MTreeBelowSG.java | 1235 -----
.../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 1516 +++++++
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 1348 ++++++
.../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 | 443 ++
.../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 | 542 +++
.../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 | 97 +
.../store/disk/schemafile/MockSchemaFile.java | 235 +
.../mtree/store/disk/schemafile/RecordUtils.java | 365 ++
.../mtree/store/disk/schemafile/SchemaFile.java | 1002 +++++
.../mtree/store/disk/schemafile/SchemaPage.java | 622 +++
.../mtree/store/disk/schemafile/Segment.java | 759 ++++
.../db/metadata/mtree/traverser/Traverser.java | 179 +-
.../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 | 15 +-
.../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 | 23 +-
.../traverser/counter/MeasurementCounter.java | 6 +-
.../counter/MeasurementGroupByLevelCounter.java | 6 +-
.../traverser/counter/StorageGroupCounter.java | 6 +-
.../apache/iotdb/db/metadata/path/AlignedPath.java | 322 +-
.../iotdb/db/metadata/path/MeasurementPath.java | 239 +-
.../apache/iotdb/db/metadata/path/PartialPath.java | 118 +-
.../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 | 363 ++
.../db/metadata/schemaregion/SchemaEngine.java | 128 +-
.../db/metadata/schemaregion/SchemaEngineMode.java | 26 +
.../db/metadata/schemaregion/SchemaRegion.java | 1762 --------
.../schemaregion/SchemaRegionMemoryImpl.java | 1717 +++++++
.../schemaregion/SchemaRegionSchemaFileImpl.java | 1801 ++++++++
.../metadata/schemaregion/SchemaRegionUtils.java | 101 +
.../schemaregion/rocksdb/CheckKeyResult.java | 50 +
.../schemaregion/rocksdb/RSchemaConfLoader.java | 182 +
.../schemaregion/rocksdb/RSchemaConstants.java | 76 +
.../schemaregion/rocksdb/RSchemaLogger.java | 61 +
.../rocksdb/RSchemaReadWriteHandler.java | 515 +++
.../schemaregion/rocksdb/RSchemaRegion.java | 1900 ++++++++
.../schemaregion/rocksdb/RSchemaUtils.java | 592 +++
.../schemaregion/rocksdb/mnode/REntityMNode.java | 124 +
.../schemaregion/rocksdb/mnode/RInternalMNode.java | 197 +
.../schemaregion/rocksdb/mnode/RMNode.java | 254 ++
.../schemaregion/rocksdb/mnode/RMNodeType.java | 49 +
.../rocksdb/mnode/RMNodeValueType.java | 47 +
.../rocksdb/mnode/RMeasurementMNode.java | 262 ++
.../rocksdb/mnode/RStorageGroupMNode.java | 102 +
.../storagegroup/IStorageGroupSchemaManager.java | 30 +-
.../storagegroup/StorageGroupSchemaManager.java | 43 +-
.../apache/iotdb/db/metadata/tag/TagManager.java | 20 +-
.../iotdb/db/metadata/template/Template.java | 57 +-
.../db/metadata/template/TemplateManager.java | 70 +-
.../db/metadata/upgrade/MetadataUpgrader.java | 46 +-
.../db/metadata/utils/ResourceByPathUtils.java | 607 +++
.../metadata/visitor/SchemaExecutionVisitor.java | 149 +
.../iotdb/db/mpp/buffer/DataBlockManager.java | 394 +-
.../db/mpp/buffer/DataBlockManagerService.java | 85 -
.../DataBlockManagerServiceThriftHandler.java | 44 -
.../iotdb/db/mpp/buffer/DataBlockService.java | 131 +
.../mpp/buffer/DataBlockServiceClientFactory.java | 93 +-
.../iotdb/db/mpp/buffer/DataBlockServiceImpl.java | 50 -
.../iotdb/db/mpp/buffer/DataBlockServiceMBean.java | 34 +
.../mpp/buffer/DataBlockServiceThriftHandler.java | 44 +
.../iotdb/db/mpp/buffer/IDataBlockManager.java | 33 +-
.../db/mpp/buffer/IDataBlockManagerCallback.java | 24 +
.../apache/iotdb/db/mpp/buffer/ISinkHandle.java | 41 +-
.../apache/iotdb/db/mpp/buffer/ISourceHandle.java | 25 +-
.../org/apache/iotdb/db/mpp/buffer/SinkHandle.java | 377 ++
.../apache/iotdb/db/mpp/buffer/SourceHandle.java | 372 +-
.../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/GroupByTimeParameter.java | 27 -
.../iotdb/db/mpp/common/MPPQueryContext.java | 31 +-
.../apache/iotdb/db/mpp/common/PlanFragmentId.java | 30 +
.../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 | 37 +-
.../iotdb/db/mpp/common/filter/LikeFilter.java | 26 +-
.../iotdb/db/mpp/common/filter/QueryFilter.java | 79 +-
.../iotdb/db/mpp/common/filter/RegexpFilter.java | 24 +-
.../iotdb/db/mpp/common/header/ColumnHeader.java | 125 +
.../iotdb/db/mpp/common/header/DatasetHeader.java | 88 +
.../iotdb/db/mpp/common/header/HeaderConstant.java | 90 +
.../db/mpp/common/schematree/DeviceSchemaInfo.java | 47 +
.../db/mpp/common/schematree/PathPatternNode.java | 48 +-
.../db/mpp/common/schematree/PathPatternTree.java | 141 +-
.../db/mpp/common/schematree/SchemaEntityNode.java | 94 +
.../mpp/common/schematree/SchemaInternalNode.java | 77 +-
.../common/schematree/SchemaMeasurementNode.java | 74 +
.../iotdb/db/mpp/common/schematree/SchemaNode.java | 57 +-
.../iotdb/db/mpp/common/schematree/SchemaTree.java | 232 +-
.../mpp/common/schematree/SchemaTreeVisitor.java | 237 +
.../apache/iotdb/db/mpp/execution/Coordinator.java | 96 +-
.../apache/iotdb/db/mpp/execution/DataDriver.java | 193 +
.../iotdb/db/mpp/execution/DataDriverContext.java | 63 +
.../org/apache/iotdb/db/mpp/execution/Driver.java | 482 ++
.../iotdb/db/mpp/execution/DriverContext.java | 55 +
.../db/mpp/execution/ExecFragmentInstance.java | 63 -
.../iotdb/db/mpp/execution/ExecutionResult.java | 2 +-
.../db/mpp/execution/FragmentInstanceContext.java | 95 +-
.../mpp/execution/FragmentInstanceExecution.java | 122 +
.../execution/FragmentInstanceFailureListener.java | 25 +
.../db/mpp/execution/FragmentInstanceInfo.java | 40 +
.../db/mpp/execution/FragmentInstanceManager.java | 229 +
.../db/mpp/execution/FragmentInstanceState.java | 28 +-
.../execution/FragmentInstanceStateMachine.java | 182 +
.../iotdb/db/mpp/execution/FutureStateChange.java | 74 +
.../org/apache/iotdb/db/mpp/execution/IDriver.java | 40 +
.../iotdb/db/mpp/execution/IQueryExecution.java | 44 +
.../iotdb/db/mpp/execution/QueryExecution.java | 237 +-
.../apache/iotdb/db/mpp/execution/QueryState.java | 49 +
.../iotdb/db/mpp/execution/QueryStateMachine.java | 116 +-
.../iotdb/db/mpp/execution/SchemaDriver.java | 45 +
.../db/mpp/execution/SchemaDriverContext.java | 37 +
.../iotdb/db/mpp/execution/StateMachine.java | 322 ++
.../mpp/execution/config/AuthorizerConfigTask.java | 76 +
.../db/mpp/execution/config/ConfigExecution.java | 161 +
.../db/mpp/execution/config/ConfigTaskResult.java | 53 +
.../db/mpp/execution/config/ConfigTaskVisitor.java | 45 +
.../iotdb/db/mpp/execution/config/IConfigTask.java | 26 +
.../mpp/execution/config/SetStorageGroupTask.java | 93 +
.../scheduler/AbstractFragInsStateTracker.java | 78 +
.../mpp/execution/scheduler/ClusterScheduler.java | 86 +-
.../scheduler/FixedRateFragInsStateTracker.java | 81 +
.../scheduler/FragInstanceDispatchResult.java | 32 +
.../scheduler/IFragInstanceDispatcher.java | 37 +
.../scheduler/IFragInstanceStateTracker.java | 26 +
.../mpp/execution/scheduler/IQueryTerminator.java | 26 +
.../db/mpp/execution/scheduler/IScheduler.java | 4 +-
.../scheduler/InternalServiceClientFactory.java | 112 +
.../scheduler/SimpleFragInstanceDispatcher.java | 78 +
.../execution/scheduler/SimpleQueryTerminator.java | 80 +
.../execution/scheduler/StandaloneScheduler.java | 61 +-
.../iotdb/db/mpp/memory/LocalMemoryManager.java | 17 +-
.../org/apache/iotdb/db/mpp/memory/MemoryPool.java | 108 +-
.../org/apache/iotdb/db/mpp/operator/Operator.java | 12 +-
.../db/mpp/operator/process/AggregateOperator.java | 5 +
.../mpp/operator/process/DeviceMergeOperator.java | 51 -
.../mpp/operator/process/DeviceViewOperator.java | 152 +
.../db/mpp/operator/process/FillOperator.java | 5 +
.../mpp/operator/process/FilterNullOperator.java | 5 +
.../db/mpp/operator/process/FilterOperator.java | 155 +
.../mpp/operator/process/GroupByLevelOperator.java | 5 +
.../db/mpp/operator/process/LimitOperator.java | 11 +-
.../db/mpp/operator/process/OffsetOperator.java | 5 +
.../db/mpp/operator/process/SortOperator.java | 5 +
.../db/mpp/operator/process/TimeJoinOperator.java | 90 +-
.../db/mpp/operator/process/TransformOperator.java | 241 +
.../mpp/operator/process/merge/ColumnMerger.java | 60 +
.../operator/process/merge/MultiColumnMerger.java | 96 +
.../operator/process/merge/SingleColumnMerger.java | 124 +
.../operator/schema/DevicesSchemaScanOperator.java | 91 +
.../mpp/operator/schema/SchemaFetchOperator.java | 128 +
.../mpp/operator/schema/SchemaMergeOperator.java | 79 +
.../db/mpp/operator/schema/SchemaScanOperator.java | 112 +
.../schema/TimeSeriesSchemaScanOperator.java | 136 +
.../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 | 86 +
.../source/SeriesAggregateScanOperator.java | 431 +-
.../db/mpp/operator/source/SeriesScanOperator.java | 81 +-
.../db/mpp/operator/source/SeriesScanUtil.java | 51 +-
.../schedule/FragmentInstanceAbortedException.java | 35 +
.../db/mpp/schedule/FragmentInstanceManager.java | 358 --
.../db/mpp/schedule/FragmentInstanceScheduler.java | 363 ++
.../mpp/schedule/FragmentInstanceTaskExecutor.java | 7 +-
.../schedule/FragmentInstanceTimeoutSentinel.java | 1 +
.../db/mpp/schedule/IFragmentInstanceManager.java | 56 -
.../mpp/schedule/IFragmentInstanceScheduler.java | 61 +
.../db/mpp/schedule/queue/L1PriorityQueue.java | 37 +-
.../db/mpp/schedule/queue/L2PriorityQueue.java | 66 +-
.../db/mpp/schedule/task/FragmentInstanceTask.java | 30 +-
.../mpp/schedule/task/FragmentInstanceTaskID.java | 10 +-
.../apache/iotdb/db/mpp/sql/analyze/Analysis.java | 57 +-
.../apache/iotdb/db/mpp/sql/analyze/Analyzer.java | 415 +-
.../mpp/sql/analyze/ClusterPartitionFetcher.java | 218 +-
.../db/mpp/sql/analyze/ClusterSchemaFetcher.java | 89 +-
.../mpp/sql/analyze/FakePartitionFetcherImpl.java | 154 +-
.../db/mpp/sql/analyze/FakeSchemaFetcherImpl.java | 69 +-
.../db/mpp/sql/analyze/IPartitionFetcher.java | 20 +-
.../iotdb/db/mpp/sql/analyze/ISchemaFetcher.java | 13 +
.../sql/analyze/StandalonePartitionFetcher.java | 90 +-
.../mpp/sql/analyze/StandaloneSchemaFetcher.java | 53 +
.../iotdb/db/mpp/sql/constant/StatementType.java | 5 +-
.../apache/iotdb/db/mpp/sql/parser/ASTVisitor.java | 368 +-
.../db/mpp/sql/parser/StatementGenerator.java | 207 +-
.../db/mpp/sql/planner/DistributionPlanner.java | 289 +-
.../mpp/sql/planner/IFragmentParallelPlaner.java | 38 +
.../db/mpp/sql/planner/LocalExecutionPlanner.java | 338 +-
.../iotdb/db/mpp/sql/planner/LogicalPlanner.java | 419 +-
.../iotdb/db/mpp/sql/planner/QueryPlanBuilder.java | 337 ++
.../sql/planner/SimpleFragmentParallelPlanner.java | 140 +
.../sql/planner/WriteFragmentParallelPlanner.java | 73 +
.../db/mpp/sql/planner/plan/FragmentInstance.java | 125 +-
.../sql/planner/plan/IFragmentParallelPlaner.java | 36 -
.../db/mpp/sql/planner/plan/PlanFragment.java | 44 +-
.../plan/SimpleFragmentParallelPlanner.java | 125 -
.../iotdb/db/mpp/sql/planner/plan/SubPlan.java | 3 +-
.../sql/planner/plan/node/PlanGraphPrinter.java | 309 ++
.../db/mpp/sql/planner/plan/node/PlanNode.java | 54 +-
.../db/mpp/sql/planner/plan/node/PlanNodeId.java | 14 +
.../sql/planner/plan/node/PlanNodeIdAllocator.java | 36 -
.../db/mpp/sql/planner/plan/node/PlanNodeType.java | 49 +-
.../db/mpp/sql/planner/plan/node/PlanNodeUtil.java | 3 +
.../db/mpp/sql/planner/plan/node/PlanVisitor.java | 45 +
.../planner/plan/node/SimplePlanNodeRewriter.java | 4 +
.../mpp/sql/planner/plan/node/WritePlanNode.java | 36 +
.../node/metedata/read/DevicesSchemaScanNode.java | 126 +
.../plan/node/metedata/read/SchemaFetchNode.java | 103 +
.../plan/node/metedata/read/SchemaMergeNode.java | 98 +
.../plan/node/metedata/read/SchemaScanNode.java | 139 +
.../plan/node/metedata/read/ShowDevicesNode.java | 63 -
.../planner/plan/node/metedata/read/ShowNode.java | 34 -
.../metedata/read/TimeSeriesSchemaScanNode.java | 163 +
.../node/metedata/write/AlterTimeSeriesNode.java | 156 +-
.../write/CreateAlignedTimeSeriesNode.java | 224 +-
.../node/metedata/write/CreateTimeSeriesNode.java | 186 +-
.../planner/plan/node/process/AggregateNode.java | 145 +-
.../planner/plan/node/process/DeviceMergeNode.java | 125 +-
.../planner/plan/node/process/ExchangeNode.java | 98 +-
.../sql/planner/plan/node/process/FillNode.java | 52 +-
.../sql/planner/plan/node/process/FilterNode.java | 93 +-
.../planner/plan/node/process/FilterNullNode.java | 92 +-
.../plan/node/process/GroupByLevelNode.java | 160 +-
.../sql/planner/plan/node/process/LimitNode.java | 58 +-
.../sql/planner/plan/node/process/OffsetNode.java | 57 +-
.../sql/planner/plan/node/process/SortNode.java | 65 +-
.../planner/plan/node/process/TimeJoinNode.java | 169 +-
.../planner/plan/node/sink/FragmentSinkNode.java | 115 +-
.../plan/node/source/SeriesAggregateScanNode.java | 241 +-
.../planner/plan/node/source/SeriesScanNode.java | 173 +-
.../sql/planner/plan/node/source/SourceNode.java | 28 +-
.../plan/node/write/InsertMultiTabletNode.java | 69 -
.../plan/node/write/InsertMultiTabletsNode.java | 201 +
.../sql/planner/plan/node/write/InsertNode.java | 199 +-
.../sql/planner/plan/node/write/InsertRowNode.java | 405 +-
.../planner/plan/node/write/InsertRowsNode.java | 112 +-
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 108 +-
.../planner/plan/node/write/InsertTabletNode.java | 690 ++-
.../sql/planner/plan/parameter/Aggregation.java | 43 +
.../planner/plan/parameter/AggregationStep.java | 73 +
.../plan/parameter/FilterNullParameter.java | 88 +
.../plan/parameter/GroupByTimeParameter.java | 173 +
.../sql/planner/plan/parameter/InputLocation.java | 72 +
.../sql/planner/plan/parameter/OutputColumn.java | 91 +
.../sql/rewriter/ColumnPaginationController.java | 46 +-
.../db/mpp/sql/rewriter/ConcatPathRewriter.java | 9 +-
.../db/mpp/sql/rewriter/WildcardsRemover.java | 52 +-
.../db/mpp/sql/statement/ConfigStatement.java | 36 +
.../db/mpp/sql/statement/StatementVisitor.java | 97 +-
.../db/mpp/sql/statement/component/FillPolicy.java | 2 +-
.../statement/component/FilterNullComponent.java | 43 +
.../statement/component/GroupByLevelComponent.java | 5 +
.../component/GroupByLevelController.java | 24 +-
.../mpp/sql/statement/component/ResultColumn.java | 9 +
.../sql/statement/component/SelectComponent.java | 45 +-
.../statement/crud/AggregationQueryStatement.java | 39 +-
.../mpp/sql/statement/crud/FillQueryStatement.java | 7 +-
.../statement/crud/GroupByFillQueryStatement.java | 5 +
.../sql/statement/crud/GroupByQueryStatement.java | 16 +
.../sql/statement/crud/InsertBaseStatement.java | 56 +
.../crud/InsertMultiTabletsStatement.java | 88 +
.../mpp/sql/statement/crud/InsertRowStatement.java | 209 +
.../crud/InsertRowsOfOneDeviceStatement.java | 97 +
.../sql/statement/crud/InsertRowsStatement.java | 95 +
.../db/mpp/sql/statement/crud/InsertStatement.java | 1 +
.../sql/statement/crud/InsertTabletStatement.java | 105 +
.../mpp/sql/statement/crud/LastQueryStatement.java | 18 +-
.../db/mpp/sql/statement/crud/QueryStatement.java | 116 +-
.../mpp/sql/statement/crud/UDAFQueryStatement.java | 7 +-
.../mpp/sql/statement/crud/UDTFQueryStatement.java | 6 +
.../metadata/AlterTimeSeriesStatement.java | 1 +
.../metadata/CreateAlignedTimeSeriesStatement.java | 1 +
.../metadata/CreateTimeSeriesStatement.java | 1 +
.../statement/metadata/SchemaFetchStatement.java | 56 +
.../metadata/SetStorageGroupStatement.java | 53 +
.../statement/metadata/ShowDevicesStatement.java | 6 +
.../mpp/sql/statement/metadata/ShowStatement.java | 10 +
.../metadata/ShowStorageGroupStatement.java | 49 +
.../metadata/ShowTimeSeriesStatement.java | 6 +
.../db/mpp/sql/statement/sys/AuthorStatement.java | 147 +
.../influxdb/function/InfluxFunctionFactory.java | 8 +-
.../db/protocol/influxdb/handler/QueryHandler.java | 21 +-
.../protocol/influxdb/input/InfluxLineParser.java | 5 +-
.../influxdb/meta/InfluxDBMetaManager.java | 13 +-
.../protocol/influxdb/sql/InfluxDBSqlVisitor.java | 3 +-
.../db/protocol/influxdb/util/JacksonUtils.java | 44 +
.../protocol/influxdb/util/QueryResultUtils.java | 3 +-
.../db/protocol/influxdb/util/StringUtils.java | 3 +-
.../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 | 30 +
.../apache/iotdb/db/qp/executor/IPlanExecutor.java | 6 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 302 +-
.../org/apache/iotdb/db/qp/logical/Operator.java | 14 +-
.../db/qp/logical/sys/CreatePipeOperator.java | 69 +
.../db/qp/logical/sys/CreatePipeSinkOperator.java | 61 +
.../iotdb/db/qp/logical/sys/DropPipeOperator.java | 44 +
.../db/qp/logical/sys/DropPipeSinkOperator.java | 43 +
.../iotdb/db/qp/logical/sys/ShowPipeOperator.java | 45 +
.../db/qp/logical/sys/ShowPipeServerOperator.java | 38 +
.../db/qp/logical/sys/ShowPipeSinkOperator.java | 45 +
.../qp/logical/sys/ShowPipeSinkTypeOperator.java | 38 +
.../iotdb/db/qp/logical/sys/StartPipeOperator.java | 44 +
.../db/qp/logical/sys/StartPipeServerOperator.java | 38 +
.../iotdb/db/qp/logical/sys/StopPipeOperator.java | 44 +
.../db/qp/logical/sys/StopPipeServerOperator.java | 38 +
.../org/apache/iotdb/db/qp/physical/BatchPlan.java | 2 +-
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 77 +-
.../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 +-
.../apache/iotdb/db/qp/physical/crud/UDTFPlan.java | 37 +-
.../iotdb/db/qp/physical/sys/AuthorPlan.java | 2 +-
.../physical/sys/CreateAlignedTimeSeriesPlan.java | 15 +-
.../qp/physical/sys/CreateMultiTimeSeriesPlan.java | 4 +-
.../iotdb/db/qp/physical/sys/CreatePipePlan.java | 110 +
.../db/qp/physical/sys/CreatePipeSinkPlan.java | 98 +
.../db/qp/physical/sys/CreateTimeSeriesPlan.java | 10 +
.../db/qp/physical/sys/DeleteTimeSeriesPlan.java | 6 +-
.../iotdb/db/qp/physical/sys/DropPipeSinkPlan.java | 45 +
.../iotdb/db/qp/physical/sys/OperatePipePlan.java | 45 +
.../iotdb/db/qp/physical/sys/ShowPipePlan.java | 33 +
.../db/qp/physical/sys/ShowPipeServerPlan.java | 26 +
.../iotdb/db/qp/physical/sys/ShowPipeSinkPlan.java | 33 +
.../db/qp/physical/sys/ShowPipeSinkTypePlan.java | 26 +
.../apache/iotdb/db/qp/physical/sys/ShowPlan.java | 6 +-
.../db/qp/physical/sys/StartPipeServerPlan.java | 56 +
.../db/qp/physical/sys/StopPipeServerPlan.java | 56 +
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 280 +-
.../apache/iotdb/db/qp/utils/DatetimeUtils.java | 15 +
.../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 | 150 +-
.../db/query/dataset/AlignByDeviceDataSet.java | 4 +-
.../apache/iotdb/db/query/dataset/UDTFDataSet.java | 3 +-
.../query/dataset/groupby/GroupByFillDataSet.java | 8 +-
.../query/dataset/groupby/GroupByTimeDataSet.java | 30 +-
.../dataset/groupby/GroupByTimeEngineDataSet.java | 24 +-
.../groupby/GroupByWithValueFilterDataSet.java | 17 +-
.../groupby/GroupByWithoutValueFilterDataSet.java | 20 +-
.../db/query/executor/AggregationExecutor.java | 20 +-
.../iotdb/db/query/executor/FillQueryExecutor.java | 10 +-
.../iotdb/db/query/executor/LastQueryExecutor.java | 14 +-
.../iotdb/db/query/executor/QueryRouter.java | 7 +-
.../db/query/executor/RawDataQueryExecutor.java | 27 +-
.../iotdb/db/query/expression/Expression.java | 121 +-
.../iotdb/db/query/expression/ExpressionType.java | 52 +
.../iotdb/db/query/expression/ResultColumn.java | 18 +
.../expression/binary/AdditionExpression.java | 12 +
.../query/expression/binary/BinaryExpression.java | 32 +-
.../expression/binary/DivisionExpression.java | 12 +
.../query/expression/binary/EqualToExpression.java | 13 +
.../expression/binary/GreaterEqualExpression.java | 12 +
.../expression/binary/GreaterThanExpression.java | 13 +
.../expression/binary/LessEqualExpression.java | 12 +
.../expression/binary/LessThanExpression.java | 12 +
.../expression/binary/LogicAndExpression.java | 13 +
.../query/expression/binary/LogicOrExpression.java | 13 +
.../query/expression/binary/ModuloExpression.java | 12 +
.../binary/MultiplicationExpression.java | 12 +
.../expression/binary/NonEqualExpression.java | 12 +
.../expression/binary/SubtractionExpression.java | 12 +
.../db/query/expression/unary/ConstantOperand.java | 29 +-
.../query/expression/unary/FunctionExpression.java | 80 +-
.../query/expression/unary/LogicNotExpression.java | 44 +-
.../query/expression/unary/NegationExpression.java | 43 +-
.../query/expression/unary/RegularExpression.java | 191 +
.../query/expression/unary/TimeSeriesOperand.java | 37 +-
.../db/query/factory/AggregateResultFactory.java | 17 +-
.../query/reader/series/SeriesAggregateReader.java | 20 +-
.../reader/series/SeriesRawDataBatchReader.java | 39 +-
.../iotdb/db/query/reader/series/SeriesReader.java | 3 +
.../reader/series/SeriesReaderByTimestamp.java | 6 +-
.../query/timegenerator/ServerTimeGenerator.java | 10 +-
.../db/query/udf/builtin/BuiltinFunction.java | 5 +-
.../udf/builtin/UDTFEqualSizeBucketAggSample.java | 487 ++
.../udf/builtin/UDTFEqualSizeBucketM4Sample.java | 238 +
.../builtin/UDTFEqualSizeBucketRandomSample.java | 68 +
.../udf/builtin/UDTFEqualSizeBucketSample.java | 48 +
.../db/query/udf/core/executor/UDTFContext.java | 60 +
.../iotdb/db/query/udf/core/layer/DAGBuilder.java | 9 +-
.../query/udf/core/layer/EvaluationDAGBuilder.java | 100 +
.../layer/MultiInputColumnIntermediateLayer.java | 14 +
.../query/udf/core/layer/RawQueryInputLayer.java | 4 +
...InputColumnMultiReferenceIntermediateLayer.java | 14 +
...nputColumnSingleReferenceIntermediateLayer.java | 14 +
.../query/udf/core/layer/TsBlockInputDataSet.java | 64 +
.../transformer/ArithmeticNegationTransformer.java | 6 +-
.../udf/core/transformer/LogicNotTransformer.java | 6 +-
.../apache/iotdb/db/rescon/MemTableManager.java | 14 +-
.../org/apache/iotdb/db/rescon/SystemInfo.java | 10 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 268 +-
.../iotdb/db/service/DataNodeManagementServer.java | 97 -
.../db/service/DataNodeManagementServerMBean.java | 22 -
.../apache/iotdb/db/service/InternalService.java | 55 +-
.../iotdb/db/service/InternalServiceImpl.java | 73 -
.../iotdb/db/service/InternalServiceMBean.java | 22 +
.../java/org/apache/iotdb/db/service/IoTDB.java | 54 +-
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 4 +
.../org/apache/iotdb/db/service/RPCService.java | 12 +-
.../db/service/basic/BasicOpenSessionResp.java | 2 +-
.../iotdb/db/service/basic/ServiceProvider.java | 172 -
.../iotdb/db/service/metrics/MetricsService.java | 37 +-
.../handler/DataNodeManagementServiceHandler.java | 58 -
.../handler/InternalServiceThriftHandler.java | 44 +
.../thrift/handler/RPCServiceThriftHandler.java | 10 +-
.../thrift/impl/DataNodeManagementServiceImpl.java | 55 -
.../thrift/impl/DataNodeTSIServiceImpl.java | 827 ++++
.../service/thrift/impl/InfluxDBServiceImpl.java | 62 +-
.../service/thrift/impl/InternalServiceImpl.java | 222 +
.../db/service/thrift/impl/TSIEventHandler.java | 25 +
.../db/service/thrift/impl/TSServiceImpl.java | 221 +-
.../apache/iotdb/db/sync/conf/SyncConstant.java | 85 +-
.../apache/iotdb/db/sync/conf/SyncPathUtil.java | 111 +
.../iotdb/db/sync/conf/SyncSenderConfig.java | 127 -
.../iotdb/db/sync/conf/SyncSenderDescriptor.java | 124 -
.../org/apache/iotdb/db/sync/package-info.java | 38 -
.../iotdb/db/sync/pipedata/DeletionPipeData.java | 85 +
.../apache/iotdb/db/sync/pipedata/PipeData.java | 96 +
.../iotdb/db/sync/pipedata/SchemaPipeData.java | 98 +
.../iotdb/db/sync/pipedata/TsFilePipeData.java | 177 +
.../sync/pipedata/queue/BufferedPipeDataQueue.java | 438 ++
.../db/sync/pipedata/queue/PipeDataQueue.java | 37 +
.../sync/pipedata/queue/PipeDataQueueFactory.java | 57 +
.../iotdb/db/sync/receiver/ReceiverService.java | 300 ++
.../iotdb/db/sync/receiver/SyncServerManager.java | 124 -
.../db/sync/receiver/SyncServerManagerMBean.java | 34 -
.../db/sync/receiver/SyncServerThriftHandler.java | 56 -
.../db/sync/receiver/collector/Collector.java | 170 +
.../db/sync/receiver/load/DeletionLoader.java | 48 +
.../iotdb/db/sync/receiver/load/FileLoader.java | 203 -
.../db/sync/receiver/load/FileLoaderManager.java | 213 -
.../iotdb/db/sync/receiver/load/IFileLoader.java | 50 -
.../iotdb/db/sync/receiver/load/ILoadLogger.java | 57 -
.../iotdb/db/sync/receiver/load/ILoader.java | 29 +
.../iotdb/db/sync/receiver/load/LoadLogger.java | 72 -
.../iotdb/db/sync/receiver/load/LoadType.java | 25 -
.../iotdb/db/sync/receiver/load/SchemaLoader.java | 60 +
.../iotdb/db/sync/receiver/load/TsFileLoader.java | 67 +
.../iotdb/db/sync/receiver/manager/PipeInfo.java | 85 +
.../db/sync/receiver/manager/PipeMessage.java | 76 +
.../db/sync/receiver/manager/ReceiverManager.java | 229 +
.../receiver/recover/ISyncReceiverLogAnalyzer.java | 33 -
.../sync/receiver/recover/ISyncReceiverLogger.java | 50 -
.../receiver/recover/SyncReceiverLogAnalyzer.java | 154 -
.../sync/receiver/recover/SyncReceiverLogger.java | 72 -
.../db/sync/receiver/recovery/ReceiverLog.java | 127 +
.../receiver/recovery/ReceiverLogAnalyzer.java | 153 +
.../db/sync/receiver/transfer/SyncServiceImpl.java | 370 --
.../db/sync/sender/manage/ISyncFileManager.java | 72 -
.../db/sync/sender/manage/SyncFileManager.java | 291 --
.../db/sync/sender/manager/SchemaSyncManager.java | 161 +
.../db/sync/sender/manager/TsFileSyncManager.java | 118 +
.../iotdb/db/sync/sender/pipe/IoTDBPipeSink.java | 97 +
.../org/apache/iotdb/db/sync/sender/pipe/Pipe.java | 106 +
.../apache/iotdb/db/sync/sender/pipe/PipeSink.java | 47 +
.../iotdb/db/sync/sender/pipe/TsFilePipe.java | 334 ++
.../sender/recover/ISyncSenderLogAnalyzer.java | 47 -
.../db/sync/sender/recover/ISyncSenderLogger.java | 67 -
.../sync/sender/recover/SyncSenderLogAnalyzer.java | 128 -
.../db/sync/sender/recover/SyncSenderLogger.java | 72 -
.../db/sync/sender/recovery/SenderLogAnalyzer.java | 172 +
.../db/sync/sender/recovery/SenderLogger.java | 141 +
.../db/sync/sender/recovery/TsFilePipeLogger.java | 150 +
.../db/sync/sender/service/SenderService.java | 415 ++
.../db/sync/sender/service/TransportHandler.java | 127 +
.../iotdb/db/sync/sender/transfer/ISyncClient.java | 95 -
.../iotdb/db/sync/sender/transfer/SyncClient.java | 810 ----
.../db/sync/transport/client/ITransportClient.java | 28 +
.../db/sync/transport/client/TransportClient.java | 534 +++
.../db/sync/transport/conf/TransportConfig.java | 45 +
.../db/sync/transport/conf/TransportConstant.java | 36 +
.../transport/server/TransportServerManager.java | 124 +
.../server/TransportServerManagerMBean.java | 34 +
.../server/TransportServerThriftHandler.java | 52 +
.../transport/server/TransportServiceImpl.java | 398 ++
.../apache/iotdb/db/tools/TsFileSketchTool.java | 6 +-
.../java/org/apache/iotdb/db/tools/WalChecker.java | 81 +-
.../db/tools/dataregion/DeviceMappingViewer.java | 63 +
.../org/apache/iotdb/db/tools/mlog/MLogParser.java | 251 --
.../apache/iotdb/db/tools/schema/MLogParser.java | 251 ++
.../db/tools/schema/SchemaFileSketchTool.java | 165 +
.../db/tools/virtualsg/DeviceMappingViewer.java | 64 -
.../org/apache/iotdb/db/utils/DataTypeUtils.java | 8 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 361 --
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 17 +-
.../org/apache/iotdb/db/utils/FileLoaderUtils.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 | 285 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 2 +-
.../org/apache/iotdb/db/utils/SerializedSize.java | 29 +
.../org/apache/iotdb/db/utils/StatusUtils.java | 46 -
.../java/org/apache/iotdb/db/utils/SyncUtils.java | 109 -
.../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 +-
.../timerangeiterator/AggrWindowIterator.java | 38 +-
.../timerangeiterator/ITimeRangeIterator.java | 8 +-
.../timerangeiterator/PreAggrWindowIterator.java | 38 +-
.../PreAggrWindowWithNaturalMonthIterator.java | 50 +-
.../SingleTimeWindowIterator.java | 65 +
.../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 | 251 ++
.../iotdb/db/wal/buffer/AbstractWALBuffer.java | 71 +
.../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 | 480 ++
.../org/apache/iotdb/db/wal/buffer/WALEntry.java | 220 +
.../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 | 285 ++
.../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 | 391 ++
.../db/wal/recover/CheckpointRecoverUtils.java | 78 +
.../iotdb/db/wal/recover/WALNodeRecoverTask.java | 157 +
.../iotdb/db/wal/recover/WALRecoverManager.java | 175 +
.../file/AbstractTsFileRecoverPerformer.java | 126 +
.../recover/file/SealedTsFileRecoverPerformer.java | 54 +
.../db/wal/recover/file/TsFilePlanRedoer.java | 210 +
.../file/UnsealedTsFileRecoverPerformer.java | 276 ++
.../org/apache/iotdb/db/wal/utils/WALMode.java | 35 +
.../apache/iotdb/db/wal/utils/WALWriteUtils.java | 176 +
.../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 --
.../db/engine/cache/BloomFilterCacheTest.java | 5 +-
.../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 | 55 +-
.../engine/compaction/cross/MergeUpgradeTest.java | 6 +-
.../cross/RewriteCompactionFileSelectorTest.java | 87 +-
.../RewriteCrossSpaceCompactionRecoverTest.java | 25 +-
.../cross/RewriteCrossSpaceCompactionTest.java | 56 +-
.../compaction/inner/InnerCompactionLogTest.java | 2 +-
.../inner/InnerCompactionSchedulerTest.java | 43 +-
.../compaction/inner/InnerCompactionTest.java | 20 +-
.../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 +-
.../db/engine/storagegroup/DataRegionTest.java | 910 ++++
.../storagegroup/StorageGroupProcessorTest.java | 129 +-
.../iotdb/db/engine/storagegroup/TTLTest.java | 60 +-
.../engine/storagegroup/TsFileProcessorTest.java | 21 +-
.../engine/storagegroup/TsFileProcessorV2Test.java | 477 ++
.../dataregion/HashVirtualPartitionerTest.java | 63 +
.../virtualSg/HashVirtualPartitionerTest.java | 63 -
.../apache/iotdb/db/metadata/SchemaBasicTest.java | 123 +-
.../org/apache/iotdb/db/metadata/TemplateTest.java | 18 +
.../db/metadata/cache/DataNodeSchemaCacheTest.java | 95 +
.../db/metadata/idtable/IDTableFlushTimeTest.java | 16 +-
.../iotdb/db/metadata/idtable/IDTableTest.java | 2 +-
.../db/metadata/idtable/InsertWithIDTableTest.java | 7 +-
.../apache/iotdb/db/metadata/mnode/MNodeTest.java | 4 +-
.../iotdb/db/metadata/mtree/MTreeAboveSGTest.java | 14 +-
.../iotdb/db/metadata/mtree/MTreeBelowSGTest.java | 112 +-
.../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 | 790 ++++
.../metadata/mtree/schemafile/SchemaPageTest.java | 130 +
.../db/metadata/mtree/schemafile/SegmentTest.java | 151 +
.../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 | 265 ++
.../rocksdb/RSchemaReadWriteHandlerTest.java | 77 +
.../rocksdb/RSchemaRegionAdvancedTest.java | 169 +
.../rocksdb/RocksDBBenchmarkEngine.java | 153 +
.../schemaregion/rocksdb/RocksDBBenchmarkTask.java | 109 +
.../schemaregion/rocksdb/RocksDBTestUtils.java | 72 +
.../db/metadata/upgrade/MetadataUpgradeTest.java | 9 +-
.../apache/iotdb/db/mpp/buffer/SinkHandleTest.java | 509 +++
.../iotdb/db/mpp/buffer/SourceHandleTest.java | 632 +++
.../apache/iotdb/db/mpp/buffer/StubSinkHandle.java | 101 +
.../java/org/apache/iotdb/db/mpp/buffer/Utils.java | 106 +
.../iotdb/db/mpp/common/PathPatternTreeTest.java | 131 -
.../mpp/common/schematree/PathPatternTreeTest.java | 193 +
.../db/mpp/common/schematree/SchemaTreeTest.java | 364 ++
.../db/mpp/execution/ConfigExecutionTest.java | 161 +
.../iotdb/db/mpp/execution/DataDriverTest.java | 230 +
.../db/mpp/execution/QueryStateMachineTest.java | 142 +
.../apache/iotdb/db/mpp/memory/MemoryPoolTest.java | 140 +-
.../db/mpp/operator/DeviceViewOperatorTest.java | 198 +
.../iotdb/db/mpp/operator/LimitOperatorTest.java | 40 +-
.../db/mpp/operator/MultiColumnMergerTest.java | 208 +
.../operator/SeriesAggregateScanOperatorTest.java | 384 ++
.../db/mpp/operator/SeriesScanOperatorTest.java | 32 +-
.../db/mpp/operator/SingleColumnMergerTest.java | 209 +
.../db/mpp/operator/TimeJoinOperatorTest.java | 162 +-
.../operator/schema/SchemaFetchOperatorTest.java | 149 +
.../operator/schema/SchemaScanOperatorTest.java | 254 ++
.../db/mpp/schedule/DefaultTaskSchedulerTest.java | 99 +-
.../mpp/schedule/FragmentInstanceManagerTest.java | 134 -
.../schedule/FragmentInstanceSchedulerTest.java | 168 +
.../FragmentInstanceTimeoutSentinelTest.java | 123 +-
.../db/mpp/schedule/queue/L1PriorityQueueTest.java | 22 +
.../db/mpp/schedule/queue/L2PriorityQueueTest.java | 27 +
.../iotdb/db/mpp/sql/analyze/AnalyzerTest.java | 7 +-
.../db/mpp/sql/plan/DistributionPlannerTest.java | 458 +-
.../db/mpp/sql/plan/FragmentInstanceIdTest.java | 38 +
.../db/mpp/sql/plan/FragmentInstanceSerdeTest.java | 175 +
.../iotdb/db/mpp/sql/plan/LogicalPlanPrinter.java | 11 +-
.../iotdb/db/mpp/sql/plan/LogicalPlannerTest.java | 232 +-
.../db/mpp/sql/plan/QueryLogicalPlanUtil.java | 575 +++
.../iotdb/db/mpp/sql/plan/QueryPlannerTest.java | 13 +-
.../sql/plan/node/PlanNodeDeserializeHelper.java | 37 +
.../read/DeviceSchemaScanNodeSerdeTest.java | 76 +
.../read/TimeSeriesSchemaScanNodeSerdeTest.java | 79 +
.../plan/node/process/AggregateNodeSerdeTest.java | 69 +
.../node/process/DeviceMergeNodeSerdeTest.java | 89 +
.../plan/node/process/ExchangeNodeSerdeTest.java | 109 +
.../sql/plan/node/process/FillNodeSerdeTest.java | 92 +
.../sql/plan/node/process/FilterNodeSerdeTest.java | 104 +
.../plan/node/process/FilterNullNodeSerdeTest.java | 112 +
.../node/process/GroupByLevelNodeSerdeTest.java | 127 +
.../sql/plan/node/process/LimitNodeSerdeTest.java | 129 +
.../sql/plan/node/process/OffsetNodeSerdeTest.java | 199 +
.../sql/plan/node/process/SortNodeSerdeTest.java | 139 +
.../plan/node/process/TimeJoinNodeSerdeTest.java | 147 +
.../plan/node/sink/FragmentSinkNodeSerdeTest.java | 56 +
.../source/SeriesAggregateScanNodeSerdeTest.java | 76 +
.../plan/node/source/SeriesScanNodeSerdeTest.java | 57 +
.../plan/node/write/InsertRowNodeSerdeTest.java | 126 +
.../plan/node/write/InsertTabletNodeSerdeTest.java | 94 +
.../influxdb/sql/InfluxDBLogicalGeneratorTest.java | 6 +-
.../db/protocol/mqtt/PayloadFormatManagerTest.java | 2 +-
.../iotdb/db/protocol/mqtt/PublishHandlerTest.java | 14 +-
.../db/qp/physical/InsertTabletMultiPlanTest.java | 19 +-
.../iotdb/db/qp/physical/PhysicalPlanTest.java | 28 +
.../iotdb/db/qp/physical/SerializedSizeTest.java | 130 +
.../dataset/EngineDataSetWithValueFilterTest.java | 5 +-
.../dataset/groupby/GroupByTimeDataSetTest.java | 74 +-
.../query/reader/series/SeriesReaderTestUtil.java | 8 +
.../SerializableBinaryTVListTest.java | 3 +-
.../datastructure/SerializableFloatTVListTest.java | 3 +-
.../datastructure/SerializableIntTVListTest.java | 3 +-
.../datastructure/SerializableLongTVListTest.java | 3 +-
.../valuefilter/RawQueryWithValueFilterTest.java | 4 +-
.../iotdb/db/service/InternalServiceImplTest.java | 280 ++
.../sync/pipedata/BufferedPipeDataQueueTest.java | 543 +++
.../iotdb/db/sync/pipedata/PipeDataTest.java | 91 +
.../db/sync/receiver/load/FileLoaderTest.java | 410 --
.../sync/receiver/manager/ReceiverManagerTest.java | 98 +
.../recover/SyncReceiverLogAnalyzerTest.java | 230 -
.../receiver/recover/SyncReceiverLoggerTest.java | 115 -
.../receiver/recovery/ReceiverLogAnalyzerTest.java | 123 +
.../db/sync/sender/manage/SyncFileManagerTest.java | 350 --
.../sender/recover/SyncSenderLogAnalyzerTest.java | 201 -
.../sync/sender/recover/SyncSenderLoggerTest.java | 112 -
.../db/sync/sender/transfer/SyncClientTest.java | 161 -
.../db/sync/transport/TransportServiceTest.java | 208 +
.../org/apache/iotdb/db/tools/MLogParserTest.java | 2 +-
.../iotdb/db/tools/SchemaFileSketchTest.java | 158 +
.../iotdb/db/tools/TsFileSelfCheckToolTest.java | 8 +-
.../org/apache/iotdb/db/tools/WalCheckerTest.java | 117 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 380 ++
.../iotdb/db/utils/MathQueryDataSetUtilsTest.java | 2 +-
.../org/apache/iotdb/db/utils/MemUtilsTest.java | 8 +-
.../org/apache/iotdb/db/utils/SchemaTestUtils.java | 0
.../iotdb/db/utils/TimeRangeIteratorTest.java | 230 +-
.../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 | 115 +
.../iotdb/db/wal/buffer/WALBufferCommonTest.java | 160 +
.../apache/iotdb/db/wal/buffer/WALBufferTest.java | 38 +
.../db/wal/checkpoint/CheckpointManagerTest.java | 157 +
.../apache/iotdb/db/wal/io/CheckpointFileTest.java | 135 +
.../org/apache/iotdb/db/wal/io/WALFileTest.java | 223 +
.../apache/iotdb/db/wal/node/WALFakeNodeTest.java | 74 +
.../org/apache/iotdb/db/wal/node/WALNodeTest.java | 276 ++
.../db/wal/recover/WALRecoverManagerTest.java | 474 ++
.../file/SealedTsFileRecoverPerformerTest.java | 310 ++
.../db/wal/recover/file/TsFilePlanRedoerTest.java | 402 ++
.../file/UnsealedTsFileRecoverPerformerTest.java | 263 ++
.../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 --
.../datanode1conf/iotdb-engine.properties | 37 +
.../test/resources/datanode1conf}/iotdb-metric.yml | 0
.../resources/datanode1conf}/logback.xml | 0
.../datanode2conf/iotdb-engine.properties | 37 +
.../test/resources/datanode2conf}/iotdb-metric.yml | 0
.../resources/datanode2conf}/logback.xml | 0
.../datanode3conf/iotdb-engine.properties | 37 +
.../test/resources/datanode3conf}/iotdb-metric.yml | 0
.../resources/datanode3conf}/logback.xml | 0
server/src/test/resources/iotdb-engine.properties | 4 +
server/src/test/resources/logback-test.xml | 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 | 18 +-
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 21 +-
.../iotdb/rpc/StatementExecutionException.java | 6 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 19 +-
.../java/org/apache/iotdb/session/Session.java | 52 +-
.../apache/iotdb/session/SessionConnection.java | 18 +-
.../apache/iotdb/session/util/SessionUtils.java | 12 +-
.../apache/iotdb/session/SessionCacheLeaderUT.java | 28 +-
site/iotdb-doap.rdf | 16 +-
site/src/main/.vuepress/config.js | 15 +-
spark-iotdb-connector/pom.xml | 2 +-
.../apache/iotdb/spark/db/EnvironmentUtils.java | 14 +-
.../java/org/apache/iotdb/db/sql/SingleNodeIT.java | 8 +-
testcontainer/src/tool/parser.py | 4 +-
thrift-cluster/pom.xml | 5 +
thrift-cluster/src/main/thrift/cluster.thrift | 4 +-
thrift-commons/pom.xml | 62 +
thrift-commons/src/main/thrift/common.thrift | 70 +
thrift-confignode/pom.xml | 2 +-
.../src/main/thrift/confignode.thrift | 151 +-
thrift-datanode/pom.xml | 67 -
thrift-datanode/src/main/thrift/datanode.thrift | 92 -
thrift-influxdb/src/main/thrift/influxdb.thrift | 36 +-
thrift-procedure/pom.xml | 66 +
thrift-procedure/src/main/thrift/procedure.thrift | 42 +
thrift-sync/src/main/thrift/sync.thrift | 51 -
thrift-sync/src/main/thrift/transport.thrift | 90 +
thrift/pom.xml | 5 +
thrift/src/main/thrift/mpp.thrift | 119 +-
thrift/src/main/thrift/rpc.thrift | 92 +-
tsfile/pom.xml | 22 +
.../iotdb/tsfile/encoding/decoder/FreqDecoder.java | 26 +-
.../iotdb/tsfile/encoding/encoder/FreqEncoder.java | 26 +-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 18 +-
.../org/apache/iotdb/tsfile/read/common/Path.java | 21 +
.../apache/iotdb/tsfile/read/common/TimeRange.java | 24 +-
.../iotdb/tsfile/read/common/block/TsBlock.java | 136 +-
.../tsfile/read/common/block/TsBlockBuilder.java | 20 +-
.../block/column/BinaryArrayColumnEncoder.java | 85 +
.../read/common/block/column/BinaryColumn.java | 21 +
.../common/block/column/BinaryColumnBuilder.java | 38 +-
.../read/common/block/column/BooleanColumn.java | 21 +
.../common/block/column/BooleanColumnBuilder.java | 38 +-
.../block/column/ByteArrayColumnEncoder.java | 68 +
.../tsfile/read/common/block/column/Column.java | 18 +
.../read/common/block/column/ColumnBuilder.java | 26 +-
.../read/common/block/column/ColumnEncoder.java | 120 +
.../common/block/column/ColumnEncoderFactory.java | 42 +
.../read/common/block/column/ColumnEncoding.java | 64 +
.../read/common/block/column/DoubleColumn.java | 21 +
.../common/block/column/DoubleColumnBuilder.java | 38 +-
.../read/common/block/column/FloatColumn.java | 21 +
.../common/block/column/FloatColumnBuilder.java | 32 +-
.../block/column/Int32ArrayColumnEncoder.java | 87 +
.../block/column/Int64ArrayColumnEncoder.java | 87 +
.../tsfile/read/common/block/column/IntColumn.java | 21 +
.../read/common/block/column/IntColumnBuilder.java | 38 +-
.../read/common/block/column/LongColumn.java | 21 +
.../common/block/column/LongColumnBuilder.java | 38 +-
.../read/common/block/column/NullColumn.java | 50 +
.../block/column/RunLengthEncodedColumn.java | 36 +-
.../read/common/block/column/TimeColumn.java | 25 +
.../common/block/column/TimeColumnBuilder.java | 28 +-
.../read/common/block/column/TsBlockSerde.java | 125 +
.../read/controller/MetadataQuerierByFileImpl.java | 17 +-
.../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 +
.../query/dataset/DataSetWithoutTimeGenerator.java | 6 +-
.../apache/iotdb/tsfile/utils/BitConstructor.java | 30 +-
.../org/apache/iotdb/tsfile/utils/BloomFilter.java | 7 +-
.../apache/iotdb/tsfile/utils/FilePathUtils.java | 2 +-
.../iotdb/tsfile/utils/ReadWriteIOUtils.java | 118 +-
.../org/apache/iotdb/tsfile/utils/TsFileUtils.java | 20 +
.../tsfile/v2/read/TsFileSequenceReaderForV2.java | 17 +-
.../apache/iotdb/tsfile/write/TsFileWriter.java | 4 -
.../apache/iotdb/tsfile/write/record/Tablet.java | 4 +-
.../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 +-
.../common/block/BinaryArrayColumnEncoderTest.java | 82 +
.../common/block/ByteArrayColumnEncoderTest.java | 78 +
.../tsfile/common/block/ColumnEncoderTest.java | 144 +
.../common/block/Int32ArrayColumnEncoderTest.java | 120 +
.../common/block/Int64ArrayColumnEncoderTest.java | 121 +
.../tsfile/common/block/NullColumnUnitTest.java | 120 +
.../tsfile/common/block/TsBlockSerdeTest.java | 112 +
.../iotdb/tsfile/common/block/TsBlockTest.java | 12 +-
.../apache/iotdb/tsfile/read/TsFileReaderTest.java | 4 +
.../tsfile/read/TsFileSequenceReaderTest.java | 47 +
.../iotdb/tsfile/read/common/BatchDataTest.java | 4 +-
.../iotdb/tsfile/utils/FilePathUtilsTest.java | 12 +-
.../iotdb/tsfile/utils/TsFileGeneratorForTest.java | 12 +
.../write/writer/RestorableTsFileIOWriterTest.java | 5 +-
zeppelin-interpreter/pom.xml | 1 -
1649 files changed, 142668 insertions(+), 48013 deletions(-)
create mode 100644 .github/workflows/client-cpp.yml
create mode 100644 .github/workflows/client-python.yml
delete mode 100644 .github/workflows/client.yml
delete mode 100644 client-py/SessionAlignedTimeseriesTest.py
delete mode 100644 client-py/SessionTest.py
create mode 100644 client-py/tests/test_aligned_timeseries.py
create mode 100644 client-py/tests/test_numpy_tablet.py
create mode 100644 client-py/tests/test_session.py
create mode 100644 client-py/tests/test_tablet.py
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/cli/TemporaryClient.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/client/ConfigNodeClientPoolFactory.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/ConfigRequest.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/ConfigRequestType.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/auth/AuthorReq.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetOrCreateDataPartitionReq.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetOrCreateSchemaPartitionReq.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/QueryDataNodeInfoReq.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/QueryStorageGroupSchemaReq.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/CreateDataPartitionReq.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/CreateRegionsReq.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/CreateSchemaPartitionReq.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/DeleteStorageGroupReq.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/RegisterDataNodeReq.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/SetStorageGroupReq.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/DataNodeConfigurationResp.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/DataNodeLocationsResp.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/DataNodesInfoDataSet.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/DataPartitionResp.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/PermissionInfoResp.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/SchemaPartitionResp.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/StorageGroupSchemaDataSet.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/StorageGroupSchemaResp.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/ClusterSchemaManager.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/ConsensusManager.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/DataNodeManager.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/Manager.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/PartitionManager.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/DataNodeInfo.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/partition/DataPartitionInfo.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/partition/PartitionTable.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/partition/SchemaPartitionInfo.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/partition/StorageGroupSchema.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/persistence/AuthorInfo.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/persistence/DataNodeInfo.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/persistence/PartitionInfo.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/persistence/StorageGroupInfo.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/physical/PhysicalPlan.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/physical/PhysicalPlanType.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/physical/sys/DeleteStorageGroupPlan.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/physical/sys/QueryDataNodeInfoPlan.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/physical/sys/QueryStorageGroupSchemaPlan.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/physical/sys/RegisterDataNodePlan.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/physical/sys/SetStorageGroupPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/ConfigNodeRPCService.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/ConfigNodeRPCServiceHandler.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/ConfigNodeRPCServiceMBean.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/ConfigNodeRPCServiceProcessor.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/server/ConfigNodeRPCServer.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/server/ConfigNodeRPCServerMBean.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/server/ConfigNodeRPCServerProcessor.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/server/ConfigNodeRPCServiceHandler.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/cli/TemporaryClientDemo.java
delete mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/consensus/RatisConsensusDemo.java
delete mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/manager/ConfigManagerManualTest.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/physical/ConfigRequestSerDeTest.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/service/thrift/ConfigNodeRPCServiceProcessorTest.java
delete mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/service/thrift/server/ConfigNodeRPCServerProcessorTest.java
create mode 100644 confignode/src/test/resources/confignode1conf/iotdb-confignode.properties
copy confignode/src/{assembly/resources/conf => test/resources/confignode1conf}/logback.xml (100%)
create mode 100644 confignode/src/test/resources/confignode2conf/iotdb-confignode.properties
copy confignode/src/{assembly/resources/conf => test/resources/confignode2conf}/logback.xml (100%)
create mode 100644 confignode/src/test/resources/confignode3conf/iotdb-confignode.properties
copy confignode/src/{assembly/resources/conf => test/resources/confignode3conf}/logback.xml (100%)
create mode 100644 consensus/README.md
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/ConsensusGroupId.java
delete mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/common/ConsensusType.java
delete mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/common/Endpoint.java
delete mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/common/GroupType.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/common/SnapshotMeta.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/ratis/RatisClientFactory.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/ratis/SnapshotStorage.java
create mode 100644 consensus/src/test/java/org/apache/iotdb/consensus/ratis/SnapshotTest.java
create mode 100644 consensus/src/test/java/org/apache/iotdb/consensus/ratis/TestUtils.java
create mode 100644 docker/src/main/Dockerfile-single-influxdb
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
create mode 100644 docs/UserGuide/Data-Modeling/SchemaRegion-rocksdb.md
delete mode 100644 docs/UserGuide/Data-Modeling/VirtualStorageGroup.md
delete mode 100644 docs/UserGuide/Library-UDF/Anomaly-Detection.md
create mode 100644 docs/UserGuide/Maintenance-Tools/SchemaFileSketch-Tool.md
create mode 100644 docs/zh/Community/About.md
create mode 100644 docs/zh/UserGuide/Data-Modeling/DataRegion.md
create mode 100644 docs/zh/UserGuide/Data-Modeling/SchemaRegion-rocksdb.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 docs/zh/UserGuide/Maintenance-Tools/SchemaFileSketch-Tool.md
create mode 100644 example/rest-client-c-example/CMakeLists.txt
create mode 100644 example/rest-client-c-example/README.md
create mode 100644 example/rest-client-c-example/base64.c
create mode 100644 example/rest-client-c-example/base64.h
create mode 100644 example/rest-client-c-example/main.c
create mode 100644 grafana-metrics-example/Apache IoTDB Dashboard v0.13.1.json
create mode 100644 grafana-metrics-example/Apache IoTDB Dashboard v0.14.0.json
create mode 100644 grafana-plugin/Magefile.go
create mode 100755 grafana-plugin/backend-compile.sh
create mode 100644 grafana-plugin/go.mod
create mode 100644 grafana-plugin/go.sum
create mode 100644 grafana-plugin/pkg/main.go
create mode 100644 grafana-plugin/pkg/plugin/plugin.go
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBSelectSchemaIT.java
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
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/sync/IoTDBSyncReceiverCollectorIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/sync/IoTDBSyncReceiverIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/sync/IoTDBSyncReceiverLoaderIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/sync/IoTDBSyncSenderIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/sync/SyncTestUtil.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/sync/TransportClientMock.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/client/AsyncBaseClientFactory.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/client/BaseClientFactory.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/client/ClientFactoryProperty.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/client/ClientManager.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/client/ClientPoolProperty.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/client/IClientManager.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/client/IClientPoolFactory.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/client/async/AsyncConfigNodeIServiceClient.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/client/async/AsyncDataNodeDataBlockServiceClient.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/client/async/AsyncDataNodeInternalServiceClient.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/client/sync/SyncConfigNodeIServiceClient.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/client/sync/SyncDataNodeDataBlockServiceClient.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/client/sync/SyncDataNodeInternalServiceClient.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/consensus/ConsensusGroupId.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
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/exception/runtime/ThriftSerDeException.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
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/partition/DataPartition.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/partition/DataPartitionInfo.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/partition/DataRegionId.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/partition/DataRegionReplicaSet.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/partition/DeviceGroupId.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/partition/Partition.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/partition/PartitionInfo.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/partition/SchemaPartition.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/partition/SchemaPartitionInfo.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/partition/SchemaRegionId.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/partition/SchemaRegionReplicaSet.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/partition/TimePartitionId.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/BasicStructureSerDeUtil.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/utils/StatusUtils.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/utils/ThriftCommonsSerDeUtils.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/utils/ThriftConfigNodeSerDeUtils.java
create mode 100644 node-commons/src/test/java/org/apache/iotdb/commons/ClientManagerTest.java
create mode 100644 node-commons/src/test/java/org/apache/iotdb/commons/ConsensusGroupIdTest.java
create mode 100644 node-commons/src/test/java/org/apache/iotdb/commons/utils/BasicStructureSerDeUtilTest.java
create mode 100644 node-commons/src/test/java/org/apache/iotdb/commons/utils/ThriftCommonsSerDeUtilsTest.java
create mode 100644 node-commons/src/test/java/org/apache/iotdb/commons/utils/ThriftConfigNodeSerDeUtilsTest.java
create mode 100644 procedure/pom.xml
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/CompletedProcedureCleaner.java
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/CompletedProcedureRetainer.java
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/InternalProcedure.java
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/Procedure.java
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/ProcedureExecutor.java
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/ProcedureLockState.java
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/RootProcedureStack.java
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/StateMachineProcedure.java
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/StoppableThread.java
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/TimeoutExecutorThread.java
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/conf/ProcedureNodeConfig.java
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/conf/ProcedureNodeConfigDescriptor.java
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/conf/ProcedureNodeConstant.java
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/env/ClusterProcedureEnvironment.java
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/exception/ProcedureAbortedException.java
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/exception/ProcedureException.java
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/exception/ProcedureSuspendedException.java
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/exception/ProcedureTimeoutException.java
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/exception/ProcedureYieldException.java
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/scheduler/AbstractProcedureScheduler.java
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/scheduler/ProcedureScheduler.java
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/scheduler/SimpleProcedureScheduler.java
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/service/ProcedureNode.java
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/service/ProcedureNodeMBean.java
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/service/ProcedureServer.java
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/service/ProcedureServerCommandLine.java
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/service/ProcedureServerProcessor.java
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/service/ProcedureServiceHanlder.java
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/store/IProcedureStore.java
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/store/ProcedureStore.java
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/store/ProcedureWAL.java
create mode 100644 procedure/src/test/java/org/apache/iotdb/procedure/NoopProcedureStore.java
create mode 100644 procedure/src/test/java/org/apache/iotdb/procedure/TestLockRegime.java
create mode 100644 procedure/src/test/java/org/apache/iotdb/procedure/TestProcEnv.java
create mode 100644 procedure/src/test/java/org/apache/iotdb/procedure/TestProcedureBase.java
create mode 100644 procedure/src/test/java/org/apache/iotdb/procedure/TestProcedureExecutor.java
create mode 100644 procedure/src/test/java/org/apache/iotdb/procedure/TestSTMProcedure.java
create mode 100644 procedure/src/test/java/org/apache/iotdb/procedure/entity/IncProcedure.java
create mode 100644 procedure/src/test/java/org/apache/iotdb/procedure/entity/NoopProcedure.java
create mode 100644 procedure/src/test/java/org/apache/iotdb/procedure/entity/SimpleLockProcedure.java
create mode 100644 procedure/src/test/java/org/apache/iotdb/procedure/entity/SimpleSTMProcedure.java
create mode 100644 procedure/src/test/java/org/apache/iotdb/procedure/entity/SleepProcedure.java
create mode 100644 procedure/src/test/java/org/apache/iotdb/procedure/entity/StuckProcedure.java
create mode 100644 procedure/src/test/java/org/apache/iotdb/procedure/entity/StuckSTMProcedure.java
create mode 100644 procedure/src/test/java/org/apache/iotdb/procedure/service/TestProcedureService.java
create mode 100644 procedure/src/test/java/org/apache/iotdb/procedure/store/TestProcedureStore.java
create mode 100644 procedure/src/test/java/org/apache/iotdb/procedure/util/ProcedureTestUtil.java
delete mode 100644 server/src/assembly/resources/conf/iotdb-sync-client.properties
create mode 100644 server/src/assembly/resources/conf/schema-rocksdb.properties
delete mode 100644 server/src/assembly/resources/tools/mlog/mLogParser.bat
delete mode 100644 server/src/assembly/resources/tools/mlog/mLogParser.sh
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/assembly/resources/tools/schema/SchemaFileSketcher.bat
create mode 100644 server/src/assembly/resources/tools/schema/SchemaFileSketcher.sh
create mode 100644 server/src/assembly/resources/tools/schema/mLogParser.bat
create mode 100644 server/src/assembly/resources/tools/schema/mLogParser.sh
delete mode 100755 server/src/assembly/resources/tools/start-sync-client.bat
delete mode 100755 server/src/assembly/resources/tools/start-sync-client.sh
delete mode 100755 server/src/assembly/resources/tools/stop-sync-client.bat
delete mode 100755 server/src/assembly/resources/tools/stop-sync-client.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/client/ConfigNodeClient.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/client/DataNodeClientPoolFactory.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/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
delete mode 100644 server/src/main/java/org/apache/iotdb/db/exception/SyncDeviceOwnerConflictException.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/exception/sync/PipeDataLoadBearableException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/sync/PipeDataLoadException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/sync/PipeDataLoadUnbearableException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/sync/PipeException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/sync/PipeServerException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/sync/PipeSinkException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/localconfignode/LocalConfigNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/localconfignode/LocalDataPartitionTable.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/localconfignode/LocalSchemaPartitionTable.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/LocalConfigManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/LocalSchemaPartitionTable.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/cache/DataNodeSchemaCache.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/cache/SchemaCacheEntity.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/IMTreeBelowSG.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/MTreeBelowSG.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/MTreeBelowSGCachedImpl.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/MTreeBelowSGMemoryImpl.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
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaRegion.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaRegionMemoryImpl.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaRegionSchemaFileImpl.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/RSchemaConfLoader.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
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/utils/ResourceByPathUtils.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/visitor/SchemaExecutionVisitor.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/DataBlockServiceMBean.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/IDataBlockManagerCallback.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/TsBlockSerdeFactory.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/DataRegion.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/GroupByTimeParameter.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/header/ColumnHeader.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/header/DatasetHeader.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/header/HeaderConstant.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/common/schematree/SchemaTreeVisitor.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/FragmentInstanceFailureListener.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/FragmentInstanceStateMachine.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/IDriver.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/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/config/AuthorizerConfigTask.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/config/ConfigExecution.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/config/ConfigTaskResult.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/config/ConfigTaskVisitor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/config/IConfigTask.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/config/SetStorageGroupTask.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
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/process/DeviceMergeOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/process/DeviceViewOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/process/FilterOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/process/TransformOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/process/merge/ColumnMerger.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/process/merge/MultiColumnMerger.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/process/merge/SingleColumnMerger.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/schema/DevicesSchemaScanOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/schema/SchemaFetchOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/schema/SchemaMergeOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/schema/SchemaScanOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/schema/TimeSeriesSchemaScanOperator.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
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/schedule/FragmentInstanceAbortedException.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/IFragmentParallelPlaner.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/SimpleFragmentParallelPlanner.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/WriteFragmentParallelPlanner.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/IFragmentParallelPlaner.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/SimpleFragmentParallelPlanner.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/PlanGraphPrinter.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/WritePlanNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/read/DevicesSchemaScanNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/read/SchemaFetchNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/read/SchemaMergeNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/read/SchemaScanNode.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/read/ShowDevicesNode.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/read/ShowNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/read/TimeSeriesSchemaScanNode.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/planner/plan/parameter/Aggregation.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/parameter/AggregationStep.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/parameter/FilterNullParameter.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/parameter/GroupByTimeParameter.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/parameter/InputLocation.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/parameter/OutputColumn.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/ConfigStatement.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/InsertRowStatement.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/metadata/SchemaFetchStatement.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/metadata/SetStorageGroupStatement.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/metadata/ShowStorageGroupStatement.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/sys/AuthorStatement.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/util/JacksonUtils.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/CreatePipeOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/CreatePipeSinkOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/DropPipeOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/DropPipeSinkOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/ShowPipeOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/ShowPipeServerOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/ShowPipeSinkOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/ShowPipeSinkTypeOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/StartPipeOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/StartPipeServerOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/StopPipeOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/StopPipeServerOperator.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/qp/physical/sys/CreatePipePlan.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/CreatePipeSinkPlan.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/DropPipeSinkPlan.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/OperatePipePlan.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/ShowPipePlan.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/ShowPipeServerPlan.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/ShowPipeSinkPlan.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/ShowPipeSinkTypePlan.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/StartPipeServerPlan.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/StopPipeServerPlan.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/query/expression/unary/RegularExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFEqualSizeBucketAggSample.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFEqualSizeBucketM4Sample.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFEqualSizeBucketRandomSample.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFEqualSizeBucketSample.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/core/executor/UDTFContext.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/core/layer/EvaluationDAGBuilder.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/core/layer/TsBlockInputDataSet.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/service/DataNodeManagementServer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/service/DataNodeManagementServerMBean.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/service/InternalServiceImpl.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/service/InternalServiceMBean.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/service/thrift/handler/DataNodeManagementServiceHandler.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/service/thrift/handler/InternalServiceThriftHandler.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/service/thrift/impl/DataNodeManagementServiceImpl.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/service/thrift/impl/DataNodeTSIServiceImpl.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/service/thrift/impl/InternalServiceImpl.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/service/thrift/impl/TSIEventHandler.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/conf/SyncPathUtil.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/conf/SyncSenderConfig.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/conf/SyncSenderDescriptor.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/package-info.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/pipedata/DeletionPipeData.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/pipedata/PipeData.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/pipedata/SchemaPipeData.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/pipedata/TsFilePipeData.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/pipedata/queue/BufferedPipeDataQueue.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/pipedata/queue/PipeDataQueue.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/pipedata/queue/PipeDataQueueFactory.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/ReceiverService.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/SyncServerManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/SyncServerManagerMBean.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/SyncServerThriftHandler.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/collector/Collector.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/load/DeletionLoader.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/load/FileLoader.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/load/FileLoaderManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/load/IFileLoader.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/load/ILoadLogger.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/load/ILoader.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/load/LoadLogger.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/load/LoadType.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/load/SchemaLoader.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/load/TsFileLoader.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/manager/PipeInfo.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/manager/PipeMessage.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/manager/ReceiverManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/recover/ISyncReceiverLogAnalyzer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/recover/ISyncReceiverLogger.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/recover/SyncReceiverLogAnalyzer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/recover/SyncReceiverLogger.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/recovery/ReceiverLog.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/recovery/ReceiverLogAnalyzer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/transfer/SyncServiceImpl.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/manage/ISyncFileManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/manage/SyncFileManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/manager/SchemaSyncManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/manager/TsFileSyncManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/pipe/IoTDBPipeSink.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/pipe/Pipe.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/pipe/PipeSink.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/pipe/TsFilePipe.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/recover/ISyncSenderLogAnalyzer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/recover/ISyncSenderLogger.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/recover/SyncSenderLogAnalyzer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/recover/SyncSenderLogger.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/recovery/SenderLogAnalyzer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/recovery/SenderLogger.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/recovery/TsFilePipeLogger.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/service/SenderService.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/service/TransportHandler.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/transfer/ISyncClient.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/transfer/SyncClient.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/transport/client/ITransportClient.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/transport/client/TransportClient.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/transport/conf/TransportConfig.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/transport/conf/TransportConstant.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/transport/server/TransportServerManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/transport/server/TransportServerManagerMBean.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/transport/server/TransportServerThriftHandler.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/transport/server/TransportServiceImpl.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/mlog/MLogParser.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/tools/schema/MLogParser.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/tools/schema/SchemaFileSketchTool.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/tools/virtualsg/DeviceMappingViewer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/utils/EnvironmentUtils.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
delete mode 100644 server/src/main/java/org/apache/iotdb/db/utils/SyncUtils.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/utils/timerangeiterator/SingleTimeWindowIterator.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/DataRegionTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessorV2Test.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/cache/DataNodeSchemaCacheTest.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/StubSinkHandle.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/buffer/Utils.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/common/PathPatternTreeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/common/schematree/PathPatternTreeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/common/schematree/SchemaTreeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/execution/ConfigExecutionTest.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
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/operator/DeviceViewOperatorTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/operator/MultiColumnMergerTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/operator/SeriesAggregateScanOperatorTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/operator/SingleColumnMergerTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/operator/schema/SchemaFetchOperatorTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/operator/schema/SchemaScanOperatorTest.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/DeviceSchemaScanNodeSerdeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/metadata/read/TimeSeriesSchemaScanNodeSerdeTest.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/mpp/sql/plan/node/write/InsertRowNodeSerdeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/write/InsertTabletNodeSerdeTest.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/sync/pipedata/BufferedPipeDataQueueTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/sync/pipedata/PipeDataTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/sync/receiver/load/FileLoaderTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/sync/receiver/manager/ReceiverManagerTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/sync/receiver/recover/SyncReceiverLogAnalyzerTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/sync/receiver/recover/SyncReceiverLoggerTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/sync/receiver/recovery/ReceiverLogAnalyzerTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/sync/sender/manage/SyncFileManagerTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/sync/sender/recover/SyncSenderLogAnalyzerTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/sync/sender/recover/SyncSenderLoggerTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/sync/sender/transfer/SyncClientTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/sync/transport/TransportServiceTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/tools/SchemaFileSketchTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/utils/EnvironmentUtils.java
rename server/src/{main => test}/java/org/apache/iotdb/db/utils/SchemaTestUtils.java (100%)
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
create mode 100644 server/src/test/resources/datanode1conf/iotdb-engine.properties
copy {cluster/src/test/resources/node1conf => server/src/test/resources/datanode1conf}/iotdb-metric.yml (100%)
copy server/src/{assembly/resources/conf => test/resources/datanode1conf}/logback.xml (100%)
create mode 100644 server/src/test/resources/datanode2conf/iotdb-engine.properties
copy {cluster/src/test/resources/node1conf => server/src/test/resources/datanode2conf}/iotdb-metric.yml (100%)
copy server/src/{assembly/resources/conf => test/resources/datanode2conf}/logback.xml (100%)
create mode 100644 server/src/test/resources/datanode3conf/iotdb-engine.properties
copy {cluster/src/test/resources/node1conf => server/src/test/resources/datanode3conf}/iotdb-metric.yml (100%)
copy server/src/{assembly/resources/conf => test/resources/datanode3conf}/logback.xml (100%)
create mode 100644 thrift-commons/pom.xml
create mode 100644 thrift-commons/src/main/thrift/common.thrift
delete mode 100644 thrift-datanode/pom.xml
delete mode 100644 thrift-datanode/src/main/thrift/datanode.thrift
create mode 100644 thrift-procedure/pom.xml
create mode 100644 thrift-procedure/src/main/thrift/procedure.thrift
delete mode 100755 thrift-sync/src/main/thrift/sync.thrift
create mode 100644 thrift-sync/src/main/thrift/transport.thrift
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/BinaryArrayColumnEncoder.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/ByteArrayColumnEncoder.java
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/NullColumn.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/BinaryArrayColumnEncoderTest.java
create mode 100644 tsfile/src/test/java/org/apache/iotdb/tsfile/common/block/ByteArrayColumnEncoderTest.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/NullColumnUnitTest.java
create mode 100644 tsfile/src/test/java/org/apache/iotdb/tsfile/common/block/TsBlockSerdeTest.java