This is an automated email from the ASF dual-hosted git repository. ejttianyu pushed a commit to branch win_e_option in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
commit 46e4393b884490bf33703bcfdd879128d02a4fde Merge: f67d775 6a3219b Author: EJTTianyu <[email protected]> AuthorDate: Mon Apr 13 21:54:21 2020 +0800 Merge branch 'master' of https://github.com/apache/incubator-iotdb into origin_master .gitignore | 4 + .travis.yml | 136 +- Jenkinsfile | 24 +- LICENSE | 13 - LICENSE-binary | 4 +- README.md | 32 +- README_ZH.md | 383 + client-py/src/client_example.py | 33 +- .../org/apache/iotdb/client/AbstractClient.java | 104 +- .../main/java/org/apache/iotdb/client/Client.java | 5 +- .../java/org/apache/iotdb/client/WinClient.java | 6 + client/src/test/resources/logback.xml | 12 +- distribution/pom.xml | 13 + docker/ReadMe.md | 69 + docker/src/main/Dockerfile | 1 + docker/src/main/Dockerfile-0.8.1 | 40 + docker/src/main/Dockerfile-0.9.0 | 41 + docker/src/main/Dockerfile-0.9.1 | 41 + docs/Community/Community-History&Vision.md | 24 - docs/Community/Community-Powered By.md | 15 +- docs/Community/Community-Project Committers.md | 33 +- docs/Development/ContributeGuide.md | 101 + docs/Development/Development-Chinese.md | 99 - docs/Development/Development-Contributing.md | 214 - docs/Development/Development-Document.md | 51 - docs/Development/Development-IDE.md | 65 - docs/Development/Development-VoteRelease.md | 198 - docs/Development/VoteRelease.md | 202 + .../SystemDesign/0-Architecture/1-Architecture.md | 55 - .../SystemDesign/1-TsFile/2-Format.md | 470 - .../SystemDesign/1-TsFile/3-Write.md | 65 - .../SystemDesign/1-TsFile/4-Read.md | 27 - .../SystemDesign/2-QueryEngine/1-QueryEngine.md | 64 - .../4-StorageEngine/1-StorageEngine.md | 92 - .../SystemDesign/4-StorageEngine/4-MergeManager.md | 26 - .../SystemDesign/5-DataQuery/1-DataQuery.md | 67 - .../SystemDesign/6-Tools/1-Sync.md | 298 - .../SystemDesign/7-Connector/2-Hive-TsFile.md | 114 - .../UserGuide/0-Get Started/1-QuickStart.md | 283 - .../0-Get Started/2-Frequently asked questions.md | 166 - .../UserGuide/0-Get Started/3-Publication.md | 31 - .../UserGuide/1-Overview/1-What is IoTDB.md | 26 - .../UserGuide/1-Overview/2-Architecture.md | 36 - .../UserGuide/1-Overview/3-Scenario.md | 78 - .../UserGuide/1-Overview/4-Features.md | 51 - .../2-Concept/1-Data Model and Terminology.md | 220 - .../UserGuide/2-Concept/2-Data Type.md | 42 - .../UserGuide/2-Concept/3-Encoding.md | 67 - .../UserGuide/2-Concept/4-Compression.md | 33 - .../UserGuide/3-Server/1-Download.md | 122 - .../UserGuide/3-Server/2-Single Node Setup.md | 32 - .../UserGuide/3-Server/3-Cluster Setup.md | 23 - .../UserGuide/3-Server/4-Config Manual.md | 442 - .../UserGuide/3-Server/5-Docker Image.md | 89 - .../4-Client/1-Command Line Interface (CLI).md | 148 - .../4-Client/2-Programming - Native API.md | 101 - .../UserGuide/4-Client/3-Programming - JDBC.md | 278 - .../4-Client/4-Programming - Other Languages.md | 24 - .../4-Client/5-Programming - TsFile API.md | 701 - .../1-DDL (Data Definition Language).md | 181 - .../2-DML (Data Manipulation Language).md | 296 - .../3-Account Management Statements.md | 134 - .../5-Operation Manual/4-SQL Reference.md | 848 - .../UserGuide/6-System Tools/1-Sync Tool.md | 276 - .../6-System Tools/2-Memory Estimation Tool.md | 90 - .../UserGuide/6-System Tools/3-JMX Tool.md | 34 - .../UserGuide/6-System Tools/4-Watermark Tool.md | 213 - .../UserGuide/6-System Tools/5-Log Visualizer.md | 147 - .../6-Query History Visualization Tool.md | 32 - .../6-System Tools/7-Monitor and Log Tools.md | 257 - .../6-System Tools/8-Load External Tsfile.md | 78 - .../UserGuide/7-Ecosystem Integration/1-Grafana.md | 136 - .../7-Ecosystem Integration/2-MapReduce TsFile.md | 217 - .../7-Ecosystem Integration/3-Spark TsFile.md | 24 - .../7-Ecosystem Integration/4-Spark IoTDB.md | 23 - .../7-Ecosystem Integration/5-Hive TsFile.md | 192 - .../UserGuide/8-Architecture/1-Files.md | 63 - .../8-Architecture/2-Writing Data on HDFS.md | 171 - .../8-Architecture/3-Shared Nothing Cluster.md | 26 - docs/Documentation/OtherMaterial-Sample Data.txt | 60509 ------------------- docs/Documentation/SystemDesign/0-Content.md | 46 - .../SystemDesign/1-TsFile/1-TsFile.md | 30 - .../SystemDesign/1-TsFile/2-Format.md | 470 - .../Documentation/SystemDesign/1-TsFile/3-Write.md | 22 - docs/Documentation/SystemDesign/1-TsFile/4-Read.md | 22 - docs/Documentation/SystemDesign/release.adoc | 519 - docs/Documentation/UserGuide/0-Content.md | 71 - .../UserGuide/0-Get Started/1-QuickStart.md | 251 - .../0-Get Started/2-Frequently asked questions.md | 167 - .../UserGuide/0-Get Started/3-Publication.md | 30 - .../UserGuide/1-Overview/1-What is IoTDB.md | 26 - .../UserGuide/1-Overview/2-Architecture.md | 36 - .../UserGuide/1-Overview/3-Scenario.md | 78 - .../UserGuide/1-Overview/4-Features.md | 52 - .../2-Concept/1-Data Model and Terminology.md | 221 - .../UserGuide/2-Concept/2-Data Type.md | 44 - .../UserGuide/2-Concept/3-Encoding.md | 66 - .../UserGuide/2-Concept/4-Compression.md | 34 - .../Documentation/UserGuide/3-Server/1-Download.md | 75 - .../UserGuide/3-Server/2-Single Node Setup.md | 32 - .../UserGuide/3-Server/3-Cluster Setup.md | 24 - .../UserGuide/3-Server/4-Config Manual.md | 482 - .../UserGuide/3-Server/5-Docker Image.md | 90 - .../4-Client/1-Command Line Interface (CLI).md | 144 - .../4-Client/2-Programming - Native API.md | 127 - .../UserGuide/4-Client/3-Programming - JDBC.md | 267 - .../4-Client/4-Programming - Other Languages.md | 74 - .../4-Client/5-Programming - TsFile API.md | 709 - .../1-DDL (Data Definition Language).md | 178 - .../2-DML (Data Manipulation Language).md | 610 - .../3-Account Management Statements.md | 124 - .../5-Operation Manual/4-SQL Reference.md | 885 - .../UserGuide/6-System Tools/1-Sync Tool.md | 295 - .../6-System Tools/2-Memory Estimation Tool.md | 84 - .../UserGuide/6-System Tools/3-JMX Tool.md | 34 - .../UserGuide/6-System Tools/4-Watermark Tool.md | 201 - .../UserGuide/6-System Tools/5-Log Visualizer.md | 162 - .../6-Query History Visualization Tool.md | 32 - .../6-System Tools/7-Monitor and Log Tools.md | 471 - .../6-System Tools/8-Load External Tsfile.md | 72 - .../UserGuide/7-Ecosystem Integration/1-Grafana.md | 140 - .../7-Ecosystem Integration/2-MapReduce TsFile.md | 213 - .../7-Ecosystem Integration/3-Spark TsFile.md | 343 - .../7-Ecosystem Integration/4-Spark IoTDB.md | 173 - .../7-Ecosystem Integration/5-Hive TsFile.md | 190 - .../UserGuide/8-Architecture/1-Files.md | 62 - .../8-Architecture/2-Writing Data on HDFS.md | 171 - .../8-Architecture/3-Shared Nothing Cluster.md | 26 - docs/Download/README.md | 65 + docs/README.md | 21 + docs/SystemDesign/0-Architecture/1-Architecture.md | 54 + docs/SystemDesign/1-TsFile/1-TsFile.md | 30 + docs/SystemDesign/1-TsFile/2-Format.md | 484 + docs/SystemDesign/1-TsFile/3-Write.md | 64 + docs/SystemDesign/1-TsFile/4-Read.md | 559 + docs/SystemDesign/2-QueryEngine/1-QueryEngine.md | 64 + docs/SystemDesign/2-QueryEngine/2-Planner.md | 65 + docs/SystemDesign/2-QueryEngine/3-PlanExecutor.md | 26 + .../3-SchemaManager/1-SchemaManager.md | 26 + .../4-StorageEngine/1-StorageEngine.md | 68 + docs/SystemDesign/4-StorageEngine/2-WAL.md | 26 + .../SystemDesign/4-StorageEngine/3-FlushManager.md | 84 + .../SystemDesign/4-StorageEngine/4-MergeManager.md | 107 + .../4-StorageEngine/5-DataPartition.md | 86 + .../4-StorageEngine/6-DataManipulation.md | 98 + docs/SystemDesign/5-DataQuery/1-DataQuery.md | 44 + docs/SystemDesign/5-DataQuery/2-SeriesReader.md | 384 + .../5-DataQuery/3-ModificationHandle.md | 73 + docs/SystemDesign/5-DataQuery/4-RawDataQuery.md | 303 + .../SystemDesign/5-DataQuery/5-AggregationQuery.md | 114 + docs/SystemDesign/5-DataQuery/6-GroupByQuery.md | 260 + docs/SystemDesign/5-DataQuery/7-LastQuery.md | 122 + .../5-DataQuery/8-AlignByDeviceQuery.md | 200 + docs/SystemDesign/5-DataQuery/9-FillFunction.md | 149 + docs/SystemDesign/6-Tools/1-Sync.md | 249 + docs/SystemDesign/7-Connector/2-Hive-TsFile.md | 114 + docs/SystemDesign/7-Connector/3-Spark-TsFile.md | 94 + docs/SystemDesign/7-Connector/4-Spark-IOTDB.md | 87 + docs/UserGuide/0-Get Started/1-QuickStart.md | 261 + .../0-Get Started/2-Frequently asked questions.md | 167 + docs/UserGuide/0-Get Started/3-Publication.md | 38 + docs/UserGuide/1-Overview/1-What is IoTDB.md | 24 + docs/UserGuide/1-Overview/2-Architecture.md | 34 + docs/UserGuide/1-Overview/3-Scenario.md | 76 + docs/UserGuide/1-Overview/4-Features.md | 50 + .../2-Concept/1-Data Model and Terminology.md | 221 + docs/UserGuide/2-Concept/2-Data Type.md | 43 + docs/UserGuide/2-Concept/3-Encoding.md | 65 + docs/UserGuide/2-Concept/4-Compression.md | 32 + docs/UserGuide/3-Server/1-Download.md | 74 + docs/UserGuide/3-Server/2-Single Node Setup.md | 36 + docs/UserGuide/3-Server/3-Cluster Setup.md | 24 + docs/UserGuide/3-Server/4-Config Manual.md | 497 + docs/UserGuide/3-Server/5-Docker Image.md | 89 + .../UserGuide/4-Client/1-Command Line Interface.md | 144 + .../4-Client/2-Programming - Native API.md | 167 + docs/UserGuide/4-Client/3-Programming - JDBC.md | 274 + .../4-Client/4-Programming - Other Languages.md | 72 + .../4-Client/5-Programming - TsFile API.md | 710 + docs/UserGuide/4-Client/6-Programming - MQTT.md | 100 + docs/UserGuide/4-Client/7-Status Codes.md | 65 + .../1-DDL Data Definition Language.md | 184 + .../2-DML Data Manipulation Language.md | 669 + .../3-Account Management Statements.md | 134 + .../5-Operation Manual/4-SQL Reference.md | 927 + docs/UserGuide/6-System Tools/1-Sync Tool.md | 295 + .../6-System Tools/2-Memory Estimation Tool.md | 84 + docs/UserGuide/6-System Tools/3-JMX Tool.md | 54 + docs/UserGuide/6-System Tools/4-Watermark Tool.md | 199 + docs/UserGuide/6-System Tools/5-Log Visualizer.md | 160 + .../6-Query History Visualization Tool.md | 30 + .../6-System Tools/7-Monitor and Log Tools.md | 471 + .../6-System Tools/8-Load External Tsfile.md | 71 + .../UserGuide/7-Ecosystem Integration/1-Grafana.md | 139 + .../7-Ecosystem Integration/2-MapReduce TsFile.md | 212 + .../7-Ecosystem Integration/3-Spark TsFile.md | 339 + .../7-Ecosystem Integration/4-Spark IoTDB.md | 172 + .../7-Ecosystem Integration/5-Hive TsFile.md | 190 + docs/UserGuide/8-Architecture/1-Files.md | 60 + .../8-Architecture/2-Writing Data on HDFS.md | 171 + .../8-Architecture/3-Shared Nothing Cluster.md | 24 + docs/UserGuide/UserGuideReadme.md | 31 + docs/zh/Community/Community-Powered By.md | 36 + docs/zh/Community/Community-Project Committers.md | 22 + docs/zh/Development/ContributeGuide.md | 119 + docs/zh/Development/VoteRelease.md | 198 + docs/zh/Download/README.md | 64 + docs/zh/README.md | 21 + .../SystemDesign/0-Architecture/1-Architecture.md | 55 + .../SystemDesign/1-TsFile/1-TsFile.md | 0 docs/zh/SystemDesign/1-TsFile/2-Format.md | 484 + docs/zh/SystemDesign/1-TsFile/3-Write.md | 65 + docs/zh/SystemDesign/1-TsFile/4-Read.md | 566 + .../zh/SystemDesign/2-QueryEngine/1-QueryEngine.md | 64 + .../SystemDesign/2-QueryEngine/2-Planner.md | 0 .../SystemDesign/2-QueryEngine/3-PlanExecutor.md | 0 .../3-SchemaManager/1-SchemaManager.md | 0 .../4-StorageEngine/1-StorageEngine.md | 67 + .../SystemDesign/4-StorageEngine/2-WAL.md | 0 .../SystemDesign/4-StorageEngine/3-FlushManager.md | 0 .../SystemDesign/4-StorageEngine/4-MergeManager.md | 112 + .../4-StorageEngine/5-DataPartition.md | 86 + .../4-StorageEngine/6-DataManipulation.md | 100 + docs/zh/SystemDesign/5-DataQuery/1-DataQuery.md | 44 + docs/zh/SystemDesign/5-DataQuery/2-SeriesReader.md | 384 + .../5-DataQuery/3-ModificationHandle.md | 73 + docs/zh/SystemDesign/5-DataQuery/4-RawDataQuery.md | 323 + .../SystemDesign/5-DataQuery/5-AggregationQuery.md | 114 + docs/zh/SystemDesign/5-DataQuery/6-GroupByQuery.md | 268 + docs/zh/SystemDesign/5-DataQuery/7-LastQuery.md | 119 + .../5-DataQuery/8-AlignByDeviceQuery.md | 200 + docs/zh/SystemDesign/5-DataQuery/9-FillFunction.md | 148 + docs/zh/SystemDesign/6-Tools/1-Sync.md | 299 + docs/zh/SystemDesign/7-Connector/2-Hive-TsFile.md | 121 + docs/zh/SystemDesign/7-Connector/3-Spark-TsFile.md | 109 + docs/zh/SystemDesign/7-Connector/4-Spark-IOTDB.md | 89 + docs/zh/UserGuide/0-Get Started/1-QuickStart.md | 297 + .../0-Get Started/2-Frequently asked questions.md | 167 + docs/zh/UserGuide/0-Get Started/3-Publication.md | 38 + docs/zh/UserGuide/1-Overview/1-What is IoTDB.md | 24 + docs/zh/UserGuide/1-Overview/2-Architecture.md | 34 + docs/zh/UserGuide/1-Overview/3-Scenario.md | 76 + docs/zh/UserGuide/1-Overview/4-Features.md | 49 + .../2-Concept/1-Data Model and Terminology.md | 220 + docs/zh/UserGuide/2-Concept/2-Data Type.md | 41 + docs/zh/UserGuide/2-Concept/3-Encoding.md | 65 + docs/zh/UserGuide/2-Concept/4-Compression.md | 31 + docs/zh/UserGuide/3-Server/1-Download.md | 120 + docs/zh/UserGuide/3-Server/2-Single Node Setup.md | 37 + docs/zh/UserGuide/3-Server/3-Cluster Setup.md | 24 + docs/zh/UserGuide/3-Server/4-Config Manual.md | 440 + docs/zh/UserGuide/3-Server/5-Docker Image.md | 89 + .../UserGuide/4-Client/1-Command Line Interface.md | 150 + .../4-Client/2-Programming - Native API.md | 132 + docs/zh/UserGuide/4-Client/3-Programming - JDBC.md | 276 + .../4-Client/4-Programming - Other Languages.md | 66 + .../4-Client/5-Programming - TsFile API.md | 703 + docs/zh/UserGuide/4-Client/6-Programming - MQTT.md | 101 + docs/zh/UserGuide/4-Client/7-Status Codes.md | 64 + .../1-DDL Data Definition Language.md | 185 + .../2-DML Data Manipulation Language.md | 728 + .../3-Account Management Statements.md | 134 + .../5-Operation Manual/4-SQL Reference.md | 889 + docs/zh/UserGuide/6-System Tools/1-Sync Tool.md | 275 + .../6-System Tools/2-Memory Estimation Tool.md | 88 + docs/zh/UserGuide/6-System Tools/3-JMX Tool.md | 54 + .../UserGuide/6-System Tools/4-Watermark Tool.md | 208 + .../UserGuide/6-System Tools/5-Log Visualizer.md | 146 + .../6-Query History Visualization Tool.md | 30 + .../6-System Tools/7-Monitor and Log Tools.md | 449 + .../6-System Tools/8-Load External Tsfile.md | 78 + .../UserGuide/7-Ecosystem Integration/1-Grafana.md | 135 + .../7-Ecosystem Integration/2-MapReduce TsFile.md | 218 + .../7-Ecosystem Integration/3-Spark TsFile.md | 344 + .../7-Ecosystem Integration/4-Spark IoTDB.md | 175 + .../7-Ecosystem Integration/5-Hive TsFile.md | 189 + docs/zh/UserGuide/8-Architecture/1-Files.md | 61 + .../8-Architecture/2-Writing Data on HDFS.md | 171 + .../8-Architecture/3-Shared Nothing Cluster.md | 24 + docs/zh/UserGuide/UserGuideReadme.md | 31 + example/flink/README.md | 38 + example/flink/pom.xml | 50 + .../org/apache/iotdb/flink/FlinkIoTDBSink.java | 79 + .../apache/iotdb/flink/FlinkTsFileBatchSource.java | 80 + .../iotdb/flink/FlinkTsFileStreamSource.java | 84 + .../java/org/apache/iotdb/flink/TsFlieUtils.java | 72 + .../org/apache/iotdb/hadoop/tsfile/Constant.java | 35 + .../iotdb/hadoop/tsfile/TSFMRReadExample.java | 3 - .../iotdb/hadoop/tsfile/TSMRWriteExample.java | 260 +- .../apache/iotdb/hadoop/tsfile/TsFileHelper.java | 20 +- .../iotdb/hadoop/tsfile/TsFileWriteToHDFS.java | 73 + .../main/java/org/apache/iotdb/JDBCExample.java | 2 +- example/kafka/readme.md | 2 +- example/mqtt/README.md | 32 + example/mqtt/pom.xml | 39 + .../java/org/apache/iotdb/mqtt/MQTTClient.java | 50 + example/pom.xml | 2 + example/rocketmq/readme.md | 34 +- .../apache/iotdb/rocketmq/RocketMQConsumer.java | 36 +- .../main/java/org/apache/iotdb/SessionExample.java | 157 +- .../java/org/apache/iotdb/tsfile/Constant.java | 34 + .../apache/iotdb/tsfile/TsFileSequenceRead.java | 39 +- .../iotdb/tsfile/TsFileWriteWithRowBatch.java | 9 +- .../iotdb/tsfile/TsFileWriteWithTSRecord.java | 33 +- flink-iotdb-connector/README.md | 58 + flink-iotdb-connector/pom.xml | 55 + .../iotdb/flink/DefaultIoTSerializationSchema.java | 99 + .../main/java/org/apache/iotdb/flink/Event.java | 54 + .../java/org/apache/iotdb/flink/IoTDBOptions.java | 152 + .../java/org/apache/iotdb/flink/IoTDBSink.java | 192 + .../apache/iotdb/flink/IoTSerializationSchema.java | 31 + .../flink/DefaultIoTSerializationSchemaTest.java | 49 + .../iotdb/flink/IoTDBSinkBatchInsertTest.java | 102 + .../iotdb/flink/IoTDBSinkBatchTimerTest.java | 74 + .../apache/iotdb/flink/IoTDBSinkInsertTest.java | 66 + flink-tsfile-connector/README.md | 93 + flink-tsfile-connector/pom.xml | 54 + .../apache/iotdb/flink/tsfile/RowRecordParser.java | 46 + .../iotdb/flink/tsfile/RowRowRecordParser.java | 120 + .../iotdb/flink/tsfile/TsFileInputFormat.java | 168 + .../iotdb/flink/tsfile/util/TSFileConfigUtil.java | 65 + .../flink/tsfile/RowTsFileInputFormatITCase.java | 109 + .../flink/tsfile/RowTsFileInputFormatTest.java | 89 + .../flink/tsfile/RowTsFileInputFormatTestBase.java | 118 + .../util/TSFileConfigUtilCompletenessTest.java | 84 + .../apache/iotdb/flink/util/TsFileWriteUtil.java | 230 + .../apache/iotdb/web/grafana/bean/TimeValues.java | 6 +- .../controller/DatabaseConnectController.java | 2 +- .../iotdb/web/grafana/dao/impl/BasicDaoImpl.java | 49 +- hadoop/README.md | 2 +- hadoop/pom.xml | 55 + .../iotdb/hadoop/fileSystem/HDFSConfUtil.java | 5 +- .../apache/iotdb/hadoop/fileSystem/HDFSFile.java | 2 +- .../apache/iotdb/hadoop/fileSystem/HDFSOutput.java | 7 +- .../apache/iotdb/hadoop/tsfile/TSFInputFormat.java | 97 +- .../apache/iotdb/hadoop/tsfile/TSFInputSplit.java | 251 +- .../iotdb/hadoop/tsfile/TSFOutputFormat.java | 3 - .../iotdb/hadoop/tsfile/TSFRecordReader.java | 157 +- .../iotdb/hadoop/tsfile/TSFRecordWriter.java | 1 - .../iotdb/hadoop/tsfile/record/HDFSTSRecord.java | 3 - .../iotdb/hadoop/tsfile/TSFInputSplitTest.java | 23 +- .../iotdb/hadoop/tsfile/TsFileTestHelper.java | 7 +- hadoop/src/test/resources/logback.xml | 2 +- hive-connector/pom.xml | 16 + .../apache/iotdb/hive/TSFHiveInputFormatTest.java | 29 +- .../apache/iotdb/hive/TSFHiveRecordReaderTest.java | 30 +- .../apache/iotdb/hive/TsFileDeserializerTest.java | 3 - .../org/apache/iotdb/hive/TsFileTestHelper.java | 14 +- hive-connector/src/test/resources/logback.xml | 39 + jdbc/README.md | 23 + jdbc/osgi.bnd | 31 + jdbc/pom.xml | 97 + jdbc/src/main/feature/feature.xml | 35 + .../apache/iotdb/jdbc/AbstractIoTDBResultSet.java | 41 +- .../main/java/org/apache/iotdb/jdbc/Activator.java | 40 + .../main/java/org/apache/iotdb/jdbc/Config.java | 2 +- .../org/apache/iotdb/jdbc/IoTDBConnection.java | 36 +- .../org/apache/iotdb/jdbc/IoTDBDataSource.java | 146 + .../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 15 +- .../java/org/apache/iotdb/jdbc/IoTDBDriver.java | 4 +- .../iotdb/jdbc/IoTDBNonAlignQueryResultSet.java | 25 +- .../apache/iotdb/jdbc/IoTDBPreparedStatement.java | 92 +- .../org/apache/iotdb/jdbc/IoTDBQueryResultSet.java | 14 +- .../org/apache/iotdb/jdbc/IoTDBResultMetadata.java | 7 +- .../org/apache/iotdb/jdbc/IoTDBSQLException.java | 2 +- .../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 62 +- .../apache/iotdb/jdbc/IoTDbDataSourceFactory.java | 79 + .../src/main/java/org/apache/iotdb/jdbc/Utils.java | 16 +- .../resources/services/META-INF/java.sql.Driver | 19 + .../test/java/org/apache/iotdb/jdbc/BatchTest.java | 55 +- .../org/apache/iotdb/jdbc/IoTDBConnectionTest.java | 12 +- .../iotdb/jdbc/IoTDBPreparedStatementTest.java | 2 +- .../apache/iotdb/jdbc/IoTDBQueryResultSetTest.java | 14 +- .../apache/iotdb/jdbc/IoTDBResultMetadataTest.java | 30 +- .../org/apache/iotdb/jdbc/IoTDBStatementTest.java | 7 +- .../test/java/org/apache/iotdb/jdbc/UtilsTest.java | 28 +- pom.xml | 72 +- server/pom.xml | 28 +- .../resources/conf/iotdb-engine.properties | 75 +- server/src/assembly/resources/conf/iotdb-env.bat | 30 +- server/src/assembly/resources/conf/iotdb-env.sh | 30 +- server/src/assembly/resources/conf/jmx.access | 22 + server/src/assembly/resources/conf/jmx.password | 22 + server/src/assembly/resources/conf/logback.xml | 21 +- .../src/assembly/resources/sbin/start-server.bat | 16 +- server/src/assembly/resources/sbin/start-server.sh | 20 +- .../org/apache/iotdb/db/qp/strategy/SqlBase.g4 | 207 +- .../org/apache/iotdb/db/auth/AuthorityChecker.java | 1 - .../org/apache/iotdb/db/concurrent/ThreadName.java | 4 +- .../iotdb/db/concurrent/WrappedRunnable.java | 42 + .../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 303 +- .../org/apache/iotdb/db/conf/IoTDBConfigCheck.java | 33 +- .../org/apache/iotdb/db/conf/IoTDBConstant.java | 18 +- .../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 164 +- .../iotdb/db/conf/ServerConfigConsistent.java | 37 + .../db/conf/adapter/ActiveTimeSeriesCounter.java | 19 +- .../iotdb/db/cost/statistic/Measurement.java | 9 +- .../org/apache/iotdb/db/engine/StorageEngine.java | 196 +- .../db/engine/cache/CacheHitRatioMonitor.java | 14 +- .../engine/cache/CacheHitRatioMonitorMXBean.java | 4 + .../apache/iotdb/db/engine/cache/ChunkCache.java | 176 + .../iotdb/db/engine/cache/ChunkMetadataCache.java | 185 + .../iotdb/db/engine/cache/DeviceMetaDataCache.java | 234 - .../iotdb/db/engine/cache/RamUsageEstimator.java | 34 +- .../db/engine/cache/TimeSeriesMetadataCache.java | 223 + .../iotdb/db/engine/cache/TsFileMetaDataCache.java | 108 +- .../iotdb/db/engine/cache/TsFileMetadataUtils.java | 122 - .../apache/iotdb/db/engine/flush/FlushManager.java | 39 +- .../iotdb/db/engine/flush/MemTableFlushTask.java | 100 +- .../iotdb/db/engine/flush/NotifyFlushMemTable.java | 4 +- .../iotdb/db/engine/flush/TsFileFlushPolicy.java | 2 +- .../iotdb/db/engine/memtable/AbstractMemTable.java | 105 +- .../apache/iotdb/db/engine/memtable/IMemTable.java | 17 +- .../db/engine/memtable/IWritableMemChunk.java | 22 +- .../db/engine/memtable/MemSeriesLazyMerger.java | 50 - .../db/engine/memtable/PrimitiveMemTable.java | 6 +- .../engine/memtable/TimeValuePairInMemTable.java | 45 - .../db/engine/memtable/TimeValuePairSorter.java | 55 - .../iotdb/db/engine/memtable/WritableMemChunk.java | 90 +- .../iotdb/db/engine/merge/manage/MergeManager.java | 40 + .../db/engine/merge/manage/MergeResource.java | 38 +- .../iotdb/db/engine/merge/recover/LogAnalyzer.java | 4 +- .../iotdb/db/engine/merge/task/MergeFileTask.java | 96 +- .../db/engine/merge/task/MergeMultiChunkTask.java | 101 +- .../iotdb/db/engine/merge/task/MergeTask.java | 26 +- .../db/engine/merge/task/RecoverMergeTask.java | 10 +- .../db/engine/querycontext/QueryDataSource.java | 13 +- .../db/engine/querycontext/ReadOnlyMemChunk.java | 136 +- .../engine/storagegroup/StorageGroupProcessor.java | 917 +- .../db/engine/storagegroup/TsFileProcessor.java | 336 +- .../db/engine/storagegroup/TsFileResource.java | 193 +- .../iotdb/db/engine/upgrade/UpgradeTask.java | 18 +- .../db/exception/ConfigAdjusterException.java | 5 +- .../exception/DiskSpaceInsufficientException.java | 4 +- .../apache/iotdb/db/exception/IoTDBException.java | 46 + .../iotdb/db/exception/LoadEmptyFileException.java | 29 + .../iotdb/db/exception/LoadFileException.java | 33 + .../apache/iotdb/db/exception/MergeException.java | 5 +- .../db/exception/PartitionViolationException.java | 29 + .../iotdb/db/exception/ProcessException.java | 35 - .../exception/QueryInBatchStatementException.java | 6 +- .../iotdb/db/exception/StartupException.java | 12 +- .../iotdb/db/exception/StorageEngineException.java | 22 +- .../exception/StorageGroupProcessorException.java | 34 + .../db/exception/SyncConnectionException.java | 11 +- .../SyncDeviceOwnerConflictException.java | 8 +- .../iotdb/db/exception/SystemCheckException.java | 6 +- .../db/exception/TsFileProcessorException.java | 8 +- .../iotdb/db/exception/WriteProcessException.java | 44 + .../exception/metadata/IllegalPathException.java | 31 + .../db/exception/metadata/MetadataException.java | 28 +- .../metadata/PathAlreadyExistException.java | 33 + .../exception/metadata/PathNotExistException.java | 27 + .../metadata/StorageGroupAlreadySetException.java | 29 + .../metadata/StorageGroupNotSetException.java | 29 + .../metadata/TimeseriesAlreadyExistException.java | 34 - .../db/exception/path/MTreePathException.java | 38 - .../exception/path/NotStorageGroupException.java | 33 - .../db/exception/path/PTreePathException.java | 27 - .../iotdb/db/exception/path/PathException.java | 37 - .../exception/query/LogicalOperatorException.java | 21 +- .../exception/query/LogicalOptimizeException.java | 11 +- .../db/exception/query/OutOfTTLException.java | 7 +- .../iotdb/db/exception/query/PathException.java | 38 + .../db/exception/query/QueryProcessException.java | 16 +- .../query/UnSupportedFillTypeException.java | 4 +- .../db/exception/runtime/RPCServiceException.java | 33 + .../runtime/StorageEngineFailureException.java | 4 +- .../storageGroup/StorageGroupException.java | 33 - .../storageGroup/StorageGroupNotSetException.java | 29 - .../storageGroup/StorageGroupPathException.java | 30 - .../StorageGroupProcessorException.java | 37 - .../java/org/apache/iotdb/db/metadata/MGraph.java | 419 - .../org/apache/iotdb/db/metadata/MManager.java | 1371 +- .../java/org/apache/iotdb/db/metadata/MNode.java | 241 - .../java/org/apache/iotdb/db/metadata/MTree.java | 1212 +- .../org/apache/iotdb/db/metadata/MetaUtils.java | 60 +- .../iotdb/db/metadata/MetadataOperationType.java | 15 +- .../java/org/apache/iotdb/db/metadata/PNode.java | 127 - .../java/org/apache/iotdb/db/metadata/PTree.java | 244 - .../iotdb/db/metadata/mnode/InternalMNode.java | 68 + .../apache/iotdb/db/metadata/mnode/LeafMNode.java | 105 + .../org/apache/iotdb/db/metadata/mnode/MNode.java | 113 + .../iotdb/db/metadata/mnode/StorageGroupMNode.java | 46 + .../iotdb/db/metrics/server/QueryServlet.java | 4 - .../apache/iotdb/db/metrics/ui/MetricsPage.java | 87 +- .../org/apache/iotdb/db/monitor/StatMonitor.java | 29 +- .../iotdb/db/monitor/collector/FileSize.java | 24 +- .../apache/iotdb/db/mqtt/BrokerAuthenticator.java | 48 + .../apache/iotdb/db/mqtt/JSONPayloadFormatter.java | 90 + .../java/org/apache/iotdb/db/mqtt/Message.java | 73 + .../apache/iotdb/db/mqtt/PayloadFormatManager.java | 47 + .../org/apache/iotdb/db/mqtt/PayloadFormatter.java | 40 + .../org/apache/iotdb/db/mqtt/PublishHandler.java | 110 + .../main/java/org/apache/iotdb/db/qp/Planner.java | 137 + .../org/apache/iotdb/db/qp/QueryProcessor.java | 137 - .../apache/iotdb/db/qp/constant/DatetimeUtils.java | 2 + .../apache/iotdb/db/qp/constant/SQLConstant.java | 10 +- .../qp/executor/AbstractQueryProcessExecutor.java | 390 - .../apache/iotdb/db/qp/executor/IPlanExecutor.java | 95 + .../db/qp/executor/IQueryProcessExecutor.java | 129 - .../apache/iotdb/db/qp/executor/PlanExecutor.java | 1150 + .../iotdb/db/qp/executor/QueryProcessExecutor.java | 919 - .../org/apache/iotdb/db/qp/logical/Operator.java | 4 +- .../db/qp/logical/crud/BasicFunctionOperator.java | 12 +- .../iotdb/db/qp/logical/crud/FilterOperator.java | 66 +- .../iotdb/db/qp/logical/crud/InOperator.java | 12 +- .../iotdb/db/qp/logical/crud/QueryOperator.java | 20 +- .../iotdb/db/qp/logical/crud/SFWOperator.java | 8 + .../iotdb/db/qp/logical/crud/SelectOperator.java | 7 + .../iotdb/db/qp/logical/sys/PropertyOperator.java | 106 - .../apache/iotdb/db/qp/physical/PhysicalPlan.java | 43 +- .../iotdb/db/qp/physical/crud/AggregationPlan.java | 6 +- .../db/qp/physical/crud/AlignByDevicePlan.java | 125 + .../iotdb/db/qp/physical/crud/BatchInsertPlan.java | 269 +- .../iotdb/db/qp/physical/crud/DeletePlan.java | 10 + .../iotdb/db/qp/physical/crud/FillQueryPlan.java | 2 +- .../iotdb/db/qp/physical/crud/GroupByPlan.java | 13 +- .../iotdb/db/qp/physical/crud/InsertPlan.java | 69 +- .../iotdb/db/qp/physical/crud/LastQueryPlan.java | 30 + .../iotdb/db/qp/physical/crud/QueryPlan.java | 205 +- .../db/qp/physical/crud/RawDataQueryPlan.java | 88 + .../apache/iotdb/db/qp/physical/sys/CountPlan.java | 3 + .../db/qp/physical/sys/CreateTimeSeriesPlan.java | 66 +- .../iotdb/db/qp/physical/sys/PropertyPlan.java | 95 - .../db/qp/physical/sys/SetStorageGroupPlan.java | 48 +- .../db/qp/physical/sys/ShowChildPathsPlan.java | 11 +- .../iotdb/db/qp/strategy/LogicalGenerator.java | 124 +- .../iotdb/db/qp/strategy/PhysicalGenerator.java | 408 +- .../qp/strategy/optimizer/ConcatPathOptimizer.java | 52 +- .../db/qp/strategy/optimizer/IFilterOptimizer.java | 3 +- .../db/query/aggregation/AggreResultData.java | 192 - .../db/query/aggregation/AggregateFunction.java | 122 - .../db/query/aggregation/AggregateResult.java | 308 + .../db/query/aggregation/AggregationType.java | 100 + .../db/query/aggregation/impl/AvgAggrFunc.java | 173 - .../db/query/aggregation/impl/AvgAggrResult.java | 161 + .../db/query/aggregation/impl/CountAggrFunc.java | 156 - .../db/query/aggregation/impl/CountAggrResult.java | 106 + .../query/aggregation/impl/FirstValueAggrFunc.java | 154 - .../aggregation/impl/FirstValueAggrResult.java | 129 + .../query/aggregation/impl/LastValueAggrFunc.java | 151 - .../aggregation/impl/LastValueAggrResult.java | 124 + .../db/query/aggregation/impl/MaxTimeAggrFunc.java | 135 - .../query/aggregation/impl/MaxTimeAggrResult.java | 113 + .../query/aggregation/impl/MaxValueAggrFunc.java | 170 - .../query/aggregation/impl/MaxValueAggrResult.java | 112 + .../db/query/aggregation/impl/MinTimeAggrFunc.java | 156 - .../query/aggregation/impl/MinTimeAggrResult.java | 108 + .../query/aggregation/impl/MinValueAggrFunc.java | 166 - .../query/aggregation/impl/MinValueAggrResult.java | 109 + .../db/query/aggregation/impl/SumAggrFunc.java | 47 - .../db/query/aggregation/impl/SumAggrResult.java | 127 + .../iotdb/db/query/context/QueryContext.java | 4 +- .../iotdb/db/query/control/FileReaderManager.java | 98 +- .../iotdb/db/query/control/QueryFileManager.java | 17 +- .../db/query/control/QueryResourceManager.java | 35 +- .../query/dataset/AggreResultDataPointReader.java | 56 - .../db/query/dataset/AlignByDeviceDataSet.java | 238 + .../db/query/dataset/DeviceIterateDataSet.java | 284 - .../dataset/EngineDataSetWithValueFilter.java | 106 - .../NewEngineDataSetWithoutValueFilter.java | 423 - .../db/query/dataset/NonAlignEngineDataSet.java | 50 +- .../OldEngineDataSetWithoutValueFilter.java | 153 - .../dataset/RawQueryDataSetWithValueFilter.java | 98 + .../dataset/RawQueryDataSetWithoutValueFilter.java | 450 + .../iotdb/db/query/dataset/SingleDataSet.java | 3 +- .../dataset/groupby/GroupByEngineDataSet.java | 91 +- .../db/query/dataset/groupby/GroupByExecutor.java | 43 + .../groupby/GroupByWithValueFilterDataSet.java | 91 +- .../groupby/GroupByWithoutValueFilterDataSet.java | 325 +- .../dataset/groupby/LocalGroupByExecutor.java | 221 + .../db/query/executor/AggregateEngineExecutor.java | 336 - .../db/query/executor/AggregationExecutor.java | 337 + .../iotdb/db/query/executor/EngineExecutor.java | 136 - .../iotdb/db/query/executor/EngineQueryRouter.java | 165 - .../db/query/executor/FillEngineExecutor.java | 86 - .../iotdb/db/query/executor/FillQueryExecutor.java | 105 + .../db/query/executor/IEngineQueryRouter.java | 58 - .../iotdb/db/query/executor/IQueryRouter.java | 66 + .../iotdb/db/query/executor/LastQueryExecutor.java | 159 + .../iotdb/db/query/executor/QueryRouter.java | 181 + .../db/query/executor/RawDataQueryExecutor.java | 144 + .../db/query/externalsort/ExternalSortJob.java | 5 +- .../query/externalsort/ExternalSortJobEngine.java | 7 +- .../db/query/externalsort/ExternalSortJobPart.java | 2 +- .../externalsort/ExternalSortJobScheduler.java | 19 +- .../iotdb/db/query/externalsort/LineMerger.java | 6 +- .../MultiSourceExternalSortJobPart.java | 2 +- .../externalsort/SimpleExternalSortEngine.java | 33 +- .../SingleSourceExternalSortJobPart.java | 28 +- .../adapter/ByTimestampReaderAdapter.java | 35 +- .../serialize/IExternalSortFileDeserializer.java | 6 +- .../serialize/IExternalSortFileSerializer.java | 2 +- .../FixLengthIExternalSortFileDeserializer.java | 6 +- .../impl/FixLengthTimeValuePairSerializer.java | 2 +- .../iotdb/db/query/factory/AggreFuncFactory.java | 80 - .../db/query/factory/AggregateResultFactory.java | 104 + .../java/org/apache/iotdb/db/query/fill/IFill.java | 67 +- .../org/apache/iotdb/db/query/fill/LinearFill.java | 66 +- .../apache/iotdb/db/query/fill/PreviousFill.java | 237 +- .../apache/iotdb/db/query/filter/TsFileFilter.java | 31 + .../apache/iotdb/db/query/reader/IPointReader.java | 34 - .../iotdb/db/query/reader/IReaderByTimestamp.java | 40 - .../iotdb/db/query/reader/ManagedSeriesReader.java | 37 - .../db/query/reader/chunk/ChunkDataIterator.java | 75 + .../db/query/reader/chunk/ChunkReaderWrap.java | 104 + .../db/query/reader/chunk/DiskChunkLoader.java | 50 + .../reader/chunk/DiskChunkReaderByTimestamp.java | 78 + .../db/query/reader/chunk/MemChunkLoader.java | 55 + .../db/query/reader/chunk/MemChunkReader.java | 124 + .../iotdb/db/query/reader/chunk/MemPageReader.java | 61 + .../chunk/metadata/DiskChunkMetadataLoader.java | 81 + .../chunk/metadata/MemChunkMetadataLoader.java | 68 + .../reader/chunkRelated/CachedDiskChunkReader.java | 88 - .../query/reader/chunkRelated/ChunkReaderWrap.java | 102 - .../query/reader/chunkRelated/DiskChunkReader.java | 87 - .../chunkRelated/DiskChunkReaderByTimestamp.java | 79 - .../query/reader/chunkRelated/MemChunkReader.java | 123 - .../chunkRelated/MemChunkReaderByTimestamp.java | 78 - .../FileSeriesReaderByTimestampAdapter.java | 49 - .../fileRelated/UnSealedTsFileIterateReader.java | 130 - .../UnSealedTsFileReaderByTimestamp.java | 96 - .../resource/CachedUnseqResourceMergeReader.java | 42 + .../CachedUnseqResourceMergeReader.java | 41 - .../NewUnseqResourceMergeReader.java | 199 - .../OldUnseqResourceMergeReader.java | 140 - .../resourceRelated/ResourceRelatedUtil.java | 48 - .../resourceRelated/SeqResourceIterateReader.java | 157 - .../SeqResourceReaderByTimestamp.java | 190 - .../UnseqResourceReaderByTimestamp.java | 101 - .../db/query/reader/series/IAggregateReader.java | 60 + .../db/query/reader/series/IReaderByTimestamp.java | 35 + .../query/reader/series/ManagedSeriesReader.java | 37 + .../query/reader/series/SeriesAggregateReader.java | 121 + .../reader/series/SeriesRawDataBatchReader.java | 161 + .../reader/series/SeriesRawDataPointReader.java | 90 + .../iotdb/db/query/reader/series/SeriesReader.java | 662 + .../reader/series/SeriesReaderByTimestamp.java | 131 + .../seriesRelated/SeriesReaderByTimestamp.java | 57 - .../seriesRelated/SeriesReaderWithValueFilter.java | 113 - .../SeriesReaderWithoutValueFilter.java | 266 - .../universal/CachedPriorityMergeReader.java | 8 +- .../db/query/reader/universal/IterateReader.java | 90 - .../reader/universal/PriorityMergeReader.java | 49 +- .../universal/PriorityMergeReaderByTimestamp.java | 75 - .../timegenerator/AbstractNodeConstructor.java | 75 - .../db/query/timegenerator/EngineLeafNode.java | 63 - .../query/timegenerator/EngineNodeConstructor.java | 68 - .../query/timegenerator/EngineTimeGenerator.java | 67 - .../query/timegenerator/ServerTimeGenerator.java | 83 + .../java/org/apache/iotdb/db/service/IService.java | 2 + .../java/org/apache/iotdb/db/service/IoTDB.java | 16 +- .../apache/iotdb/db/service/IoTDBShutdownHook.java | 2 +- .../org/apache/iotdb/db/service/JDBCService.java | 257 - .../iotdb/db/service/JDBCServiceEventHandler.java | 59 - .../apache/iotdb/db/service/JDBCServiceMBean.java | 34 - .../org/apache/iotdb/db/service/JMXService.java | 64 +- .../org/apache/iotdb/db/service/MQTTService.java | 103 + .../apache/iotdb/db/service/MetricsService.java | 11 +- .../org/apache/iotdb/db/service/RPCService.java | 248 + .../iotdb/db/service/RPCServiceEventHandler.java | 56 + .../apache/iotdb/db/service/RPCServiceMBean.java | 34 + .../apache/iotdb/db/service/RegisterManager.java | 2 +- .../org/apache/iotdb/db/service/ServiceType.java | 6 +- .../org/apache/iotdb/db/service/StartupChecks.java | 9 +- .../org/apache/iotdb/db/service/StaticResps.java | 16 +- .../org/apache/iotdb/db/service/TSServiceImpl.java | 898 +- .../iotdb/db/sync/receiver/SyncServerManager.java | 35 +- .../iotdb/db/sync/receiver/load/FileLoader.java | 4 +- .../db/sync/receiver/transfer/SyncServiceImpl.java | 21 +- .../db/sync/sender/manage/SyncFileManager.java | 18 +- .../iotdb/db/sync/sender/transfer/SyncClient.java | 9 +- .../db/sync/thrift/SyncServiceEventHandler.java | 56 + .../apache/iotdb/db/tools/IoTDBDataDirViewer.java | 2 +- .../iotdb/db/tools/TsFileResourcePrinter.java | 2 +- .../apache/iotdb/db/tools/TsFileSketchTool.java | 140 +- .../db/tools/memestimation/MemEstToolCmd.java | 5 +- .../iotdb/db/tools/upgrade/OfflineUpgradeTool.java | 68 - .../watermark/GroupedLSBWatermarkEncoder.java | 2 +- .../org/apache/iotdb/db/utils/CommonUtils.java | 43 + .../org/apache/iotdb/db/utils/FileLoaderUtils.java | 187 +- .../org/apache/iotdb/db/utils/FilePathUtils.java | 7 + .../java/org/apache/iotdb/db/utils/FileUtils.java | 8 +- .../java/org/apache/iotdb/db/utils/MemUtils.java | 23 +- .../java/org/apache/iotdb/db/utils/MergeUtils.java | 58 +- .../apache/iotdb/db/utils/QueryDataSetUtils.java | 24 +- .../java/org/apache/iotdb/db/utils/QueryUtils.java | 36 +- .../apache/iotdb/db/utils/RandomDeleteCache.java | 16 +- .../org/apache/iotdb/db/utils/SchemaUtils.java | 128 +- .../java/org/apache/iotdb/db/utils/TestOnly.java | 4 + .../org/apache/iotdb/db/utils/TimeValuePair.java | 81 - .../apache/iotdb/db/utils/TimeValuePairUtils.java | 66 +- .../iotdb/db/utils/datastructure/BinaryTVList.java | 26 +- .../db/utils/datastructure/BooleanTVList.java | 27 +- .../iotdb/db/utils/datastructure/DoubleTVList.java | 31 +- .../iotdb/db/utils/datastructure/FloatTVList.java | 31 +- .../iotdb/db/utils/datastructure/IntTVList.java | 27 +- .../iotdb/db/utils/datastructure/LongTVList.java | 26 +- .../iotdb/db/utils/datastructure/TVList.java | 122 +- .../iotdb/db/writelog/recover/LogReplayer.java | 50 +- .../writelog/recover/TsFileRecoverPerformer.java | 130 +- .../org.apache.iotdb.db.mqtt.PayloadFormatter | 20 + .../iotdb/db/auth/LocalFIleRoleAccessorTest.java | 91 - .../iotdb/db/auth/LocalFileRoleAccessorTest.java | 91 + .../db/concurrent/IoTDBThreadPoolFactoryTest.java | 4 +- .../conf/adapter/ActiveTimeSeriesCounterTest.java | 19 +- .../org/apache/iotdb/db/constant/TestConstant.java | 82 +- .../iotdb/db/engine/MetadataManagerHelper.java | 123 +- .../db/engine/cache/ChunkMetadataCacheTest.java | 165 + .../db/engine/cache/DeviceMetaDataCacheTest.java | 168 - .../db/engine/memtable/MemTableFlushTaskTest.java | 8 +- .../iotdb/db/engine/memtable/MemTablePoolTest.java | 13 - .../db/engine/memtable/MemTableTestUtils.java | 6 +- .../db/engine/memtable/MemtableBenchmark.java | 4 +- .../db/engine/memtable/PrimitiveMemTableTest.java | 87 +- .../engine/merge/MaxFileMergeFileSelectorTest.java | 6 +- .../merge/MaxSeriesMergeFileSelectorTest.java | 21 +- .../apache/iotdb/db/engine/merge/MergeLogTest.java | 5 +- .../iotdb/db/engine/merge/MergeOverLapTest.java | 49 +- .../iotdb/db/engine/merge/MergeTaskTest.java | 191 +- .../apache/iotdb/db/engine/merge/MergeTest.java | 23 +- .../iotdb/db/engine/merge/MergeUpgradeTest.java | 13 +- .../engine/modification/DeletionFileNodeTest.java | 99 +- .../db/engine/modification/DeletionQueryTest.java | 42 +- .../storagegroup/FileNodeManagerBenchmark.java | 15 +- .../storagegroup/StorageGroupProcessorTest.java | 96 +- .../iotdb/db/engine/storagegroup/TTLTest.java | 160 +- .../engine/storagegroup/TsFileProcessorTest.java | 195 +- .../org/apache/iotdb/db/integration/Constant.java | 100 - .../iotdb/db/integration/IOTDBGroupByIT.java | 140 +- .../integration/IOTDBGroupByInnerIntervalIT.java | 28 +- .../db/integration/IoTDBAggregationDeleteIT.java | 98 + .../iotdb/db/integration/IoTDBAggregationIT.java | 204 +- .../integration/IoTDBAggregationLargeDataIT.java | 76 +- .../integration/IoTDBAggregationSmallDataIT.java | 147 +- .../iotdb/db/integration/IoTDBAlignByDeviceIT.java | 1487 + .../iotdb/db/integration/IoTDBAuthorizationIT.java | 3 +- .../db/integration/IoTDBAutoCreateSchemaIT.java | 5 +- .../apache/iotdb/db/integration/IoTDBCloseIT.java | 11 +- .../iotdb/db/integration/IoTDBCompleteIT.java | 12 +- .../apache/iotdb/db/integration/IoTDBDaemonIT.java | 2 +- .../db/integration/IoTDBDeleteStorageGroupIT.java | 33 +- .../iotdb/db/integration/IoTDBDeletionIT.java | 21 +- .../iotdb/db/integration/IoTDBDisableAlignIT.java | 4 +- .../db/integration/IoTDBEngineTimeGeneratorIT.java | 51 +- .../apache/iotdb/db/integration/IoTDBFillIT.java | 318 +- .../db/integration/IoTDBFloatPrecisionIT.java | 2 +- .../db/integration/IoTDBFlushQueryMergeIT.java | 157 + .../db/integration/IoTDBFlushQueryMergeTest.java | 161 - .../iotdb/db/integration/IoTDBGroupbyDeviceIT.java | 1488 - .../iotdb/db/integration/IoTDBLargeDataIT.java | 35 +- .../apache/iotdb/db/integration/IoTDBLastIT.java | 311 + .../iotdb/db/integration/IoTDBLimitSlimitIT.java | 4 +- .../db/integration/IoTDBLoadExternalTsfileIT.java | 500 + .../integration/IoTDBLoadExternalTsfileTest.java | 491 - .../iotdb/db/integration/IoTDBMergeTest.java | 6 +- .../iotdb/db/integration/IoTDBMetadataFetchIT.java | 10 +- .../iotdb/db/integration/IoTDBMultiSeriesIT.java | 52 +- .../db/integration/IoTDBMultiStatementsIT.java | 9 +- .../iotdb/db/integration/IoTDBNumberPathIT.java | 3 +- .../iotdb/db/integration/IoTDBQuotedPathIT.java | 2 +- .../iotdb/db/integration/IoTDBRecoverIT.java | 11 +- .../iotdb/db/integration/IoTDBRestartIT.java | 145 + .../IoTDBSameMeasurementsDifferentTypesIT.java | 190 + .../db/integration/IoTDBSequenceDataQueryIT.java | 88 +- .../iotdb/db/integration/IoTDBSeriesReaderIT.java | 133 +- .../iotdb/db/integration/IoTDBSimpleQueryIT.java | 231 + .../iotdb/db/integration/IoTDBSimpleQueryTest.java | 86 - .../apache/iotdb/db/integration/IoTDBTtlIT.java | 25 +- .../org/apache/iotdb/db/metadata/MGraphTest.java | 81 - .../iotdb/db/metadata/MManagerAdvancedTest.java | 112 +- .../iotdb/db/metadata/MManagerBasicTest.java | 376 +- .../iotdb/db/metadata/MManagerImproveTest.java | 146 +- .../org/apache/iotdb/db/metadata/MTreeTest.java | 301 +- .../org/apache/iotdb/db/metadata/MetadataTest.java | 88 - .../iotdb/db/mqtt/BrokerAuthenticatorTest.java | 35 + .../iotdb/db/mqtt/JSONPayloadFormatTest.java | 69 + .../iotdb/db/mqtt/PayloadFormatManagerTest.java | 35 + .../apache/iotdb/db/mqtt/PublishHandlerTest.java | 59 + .../java/org/apache/iotdb/db/qp/PlannerTest.java | 154 + .../org/apache/iotdb/db/qp/QueryProcessorTest.java | 151 - .../iotdb/db/qp/bench/QueryParseBenchmark.java | 11 +- .../iotdb/db/qp/other/TSPlanContextAuthorTest.java | 9 +- .../db/qp/other/TSPlanContextPropertyTest.java | 92 - .../iotdb/db/qp/plan/ConcatOptimizerTest.java | 122 + .../iotdb/db/qp/plan/LogicalPlanSmallTest.java | 67 +- .../apache/iotdb/db/qp/plan/PhysicalPlanTest.java | 340 +- .../org/apache/iotdb/db/qp/plan/QPUpdateTest.java | 206 - .../iotdb/db/qp/plan/TestConcatOptimizer.java | 134 - .../apache/iotdb/db/qp/utils/MemIntQpExecutor.java | 196 - .../db/query/aggregation/AggregateResultTest.java | 265 + .../iotdb/db/query/component/SimpleFileWriter.java | 54 - .../db/query/control/FileReaderManagerTest.java | 4 +- .../dataset/EngineDataSetWithValueFilterTest.java | 14 +- .../query/executor/GroupByEngineDataSetTest.java | 29 +- .../query/externalsort/ExternalSortEngineTest.java | 40 +- .../db/query/externalsort/FakeChunkReaderWrap.java | 6 +- ...ExternalSortFileSerializerDeserializerTest.java | 6 +- .../iotdb/db/query/reader/ReaderTestHelper.java | 11 +- .../fileRelated/UnSealedTsFileReaderTest.java | 112 - .../NewUnseqResourceMergeReaderTest.java | 109 - .../resourceRelated/SeqResourceReaderTest.java | 116 - .../resourceRelated/UnseqResourceReaderTest.java | 146 - .../reader/series/SeriesAggregateReaderTest.java | 130 + .../reader/series/SeriesReaderByTimestampTest.java | 88 + .../db/query/reader/series/SeriesReaderTest.java | 134 + .../query/reader/series/SeriesReaderTestUtil.java | 187 + .../reader/seriesRelated/FakedIBatchPoint.java | 110 - .../reader/seriesRelated/FakedIPointReader.java | 79 - .../SeriesReaderWithValueFilterTest.java | 59 - .../SeriesReaderWithoutValueFilterTest.java | 74 - .../query/reader/universal/FakedSeriesReader.java | 10 +- .../universal/FakedSeriesReaderByTimestamp.java | 79 - .../PriorityMergeReaderByTimestampTest.java | 172 - .../reader/universal/PriorityMergeReaderTest.java | 8 +- .../reader/universal/PriorityMergeReaderTest2.java | 13 +- .../db/sql/DatetimeQueryDataSetUtilsTest.java | 23 + .../db/sync/receiver/load/FileLoaderTest.java | 6 +- .../recover/SyncReceiverLogAnalyzerTest.java | 6 +- .../db/sync/sender/manage/SyncFileManagerTest.java | 2 +- .../sender/recover/SyncSenderLogAnalyzerTest.java | 2 +- .../apache/iotdb/db/tools/IoTDBWatermarkTest.java | 21 +- .../apache/iotdb/db/utils/EnvironmentUtils.java | 87 +- .../db/utils/datastructure/LongTVListTest.java | 2 +- .../apache/iotdb/db/writelog/PerformanceTest.java | 17 +- .../iotdb/db/writelog/recover/LogReplayerTest.java | 69 +- .../db/writelog/recover/SeqTsFileRecoverTest.java | 96 +- .../writelog/recover/UnseqTsFileRecoverTest.java | 97 +- server/src/test/resources/logback.xml | 12 +- service-rpc/pom.xml | 55 + service-rpc/rpc-changelist.md | 5 +- .../apache/iotdb/rpc/BatchExecutionException.java | 45 + .../apache/iotdb/rpc/IoTDBConnectionException.java | 36 + .../org/apache/iotdb/rpc/IoTDBRPCException.java | 29 - .../main/java/org/apache/iotdb/rpc/RpcUtils.java | 104 +- .../iotdb/rpc/StatementExecutionException.java | 34 + .../java/org/apache/iotdb/rpc/TSStatusCode.java | 16 +- service-rpc/src/main/thrift/rpc.thrift | 28 +- service-rpc/src/main/thrift/sync.thrift | 23 +- session/pom.xml | 1 + .../main/java/org/apache/iotdb/session/Config.java | 12 +- .../iotdb/session/IoTDBSessionException.java | 36 - .../java/org/apache/iotdb/session/Session.java | 325 +- .../org/apache/iotdb/session/SessionDataSet.java | 49 +- .../org/apache/iotdb/session/SessionUtils.java | 4 +- .../iotdb/session/pool/SessionDataSetWrapper.java | 81 + .../org/apache/iotdb/session/pool/SessionPool.java | 677 + .../iotdb/session/CheckPathValidityTest.java | 49 + .../org/apache/iotdb/session/IoTDBSessionIT.java | 350 +- .../apache/iotdb/session/pool/SessionPoolTest.java | 236 + site/README-zh.md | 206 + site/README.md | 207 + site/pom.xml | 389 + site/src/main/.vuepress/config.js | 891 + site/src/main/.vuepress/enhanceApp.js | 31 + site/src/main/.vuepress/public/img/arrow.png | Bin 0 -> 88 bytes .../public/img/contributor-avatar/jlq.png | Bin 0 -> 122303 bytes .../public/img/contributor-avatar/kfx.jpeg | Bin 0 -> 134257 bytes .../public/img/contributor-avatar/user.svg | 51 + .../public/img/contributor-avatar/xdh.jpg | Bin 0 -> 136069 bytes .../.vuepress/public/img/contributor-avatar/yt.jpg | Bin 0 -> 131028 bytes .../public/img/contributor-avatar/zss.jpg | Bin 0 -> 98085 bytes site/src/main/.vuepress/public/img/home-Slide1.png | Bin 0 -> 438294 bytes site/src/main/.vuepress/public/img/home-Slide2.png | Bin 0 -> 440893 bytes site/src/main/.vuepress/public/img/home-Slide3.png | Bin 0 -> 441335 bytes site/src/main/.vuepress/public/img/home-icon1.png | Bin 0 -> 30032 bytes site/src/main/.vuepress/public/img/home-icon2.png | Bin 0 -> 5529 bytes site/src/main/.vuepress/public/img/home-icon3.png | Bin 0 -> 20637 bytes site/src/main/.vuepress/public/img/home-icon4.png | Bin 0 -> 13225 bytes site/src/main/.vuepress/public/img/home-icon5.png | Bin 0 -> 1989 bytes site/src/main/.vuepress/public/img/home-icon6.png | Bin 0 -> 16502 bytes site/src/main/.vuepress/public/img/logo.png | Bin 0 -> 31747 bytes site/src/main/.vuepress/public/img/tools.jpg | Bin 0 -> 347602 bytes site/src/main/.vuepress/styles/index.styl | 23 + site/src/main/.vuepress/styles/palette.styl | 23 + .../theme/components/AlgoliaSearchBox.vue | 172 + .../.vuepress/theme/components/DropdownLink.vue | 196 + .../theme/components/DropdownTransition.vue | 50 + site/src/main/.vuepress/theme/components/Home.vue | 179 + .../main/.vuepress/theme/components/NavLink.vue | 65 + .../main/.vuepress/theme/components/NavLinks.vue | 166 + .../src/main/.vuepress/theme/components/Navbar.vue | 139 + site/src/main/.vuepress/theme/components/Page.vue | 278 + .../main/.vuepress/theme/components/Sidebar.vue | 76 + .../.vuepress/theme/components/SidebarButton.vue | 44 + .../.vuepress/theme/components/SidebarGroup.vue | 146 + .../.vuepress/theme/components/SidebarLink.vue | 126 + .../.vuepress/theme/components/SidebarLinks.vue | 103 + .../.vuepress/theme/global-components/Badge.vue | 61 + .../theme/global-components/Contributor.vue | 348 + .../.vuepress/theme/global-components/IoTDB.vue | 305 + .../.vuepress/theme/global-components/IoTDBZH.vue | 299 + site/src/main/.vuepress/theme/index.js | 63 + site/src/main/.vuepress/theme/layouts/404.vue | 43 + site/src/main/.vuepress/theme/layouts/Layout.vue | 166 + site/src/main/.vuepress/theme/noopModule.js | 18 + site/src/main/.vuepress/theme/styles/arrow.styl | 39 + site/src/main/.vuepress/theme/styles/code.styl | 166 + .../main/.vuepress/theme/styles/custom-blocks.styl | 47 + site/src/main/.vuepress/theme/styles/index.styl | 227 + site/src/main/.vuepress/theme/styles/mobile.styl | 54 + site/src/main/.vuepress/theme/styles/toc.styl | 20 + site/src/main/.vuepress/theme/styles/wrapper.styl | 26 + site/src/main/.vuepress/theme/util/index.js | 256 + site/src/main/deploy.js | 25 + site/src/main/package.json | 43 + spark-iotdb-connector/Readme.md | 2 +- .../org/apache/iotdb/spark/db/Converter.scala | 37 +- .../org/apache/iotdb/spark/db/DefaultSource.scala | 37 +- .../org/apache/iotdb/spark/db/IoTDBOptions.scala | 37 +- .../scala/org/apache/iotdb/spark/db/IoTDBRDD.scala | 37 +- .../org/apache/iotdb/spark/db/IoTDBRelation.scala | 37 +- .../org/apache/iotdb/spark/db/Transformer.scala | 37 +- .../scala/org/apache/iotdb/spark/db/package.scala | 37 +- .../apache/iotdb/spark/db/EnvironmentUtils.java | 5 +- .../org/apache/iotdb/spark/db/IoTDBTest.scala | 37 +- spark-tsfile/README.md | 2 +- .../tsfile/qp/optimizer/PhysicalOptimizer.java | 39 +- .../org/apache/iotdb/spark/tsfile/Converter.scala | 37 +- .../apache/iotdb/spark/tsfile/DefaultSource.scala | 42 +- .../iotdb/spark/tsfile/NarrowConverter.scala | 61 +- .../spark/tsfile/NarrowTsFileOutputWriter.scala | 37 +- .../apache/iotdb/spark/tsfile/Transformer.scala | 37 +- .../iotdb/spark/tsfile/TsFileWriterFactory.scala | 36 +- .../apache/iotdb/spark/tsfile/WideConverter.scala | 73 +- .../spark/tsfile/WideTsFileOutputWriter.scala | 37 +- .../org/apache/iotdb/spark/tsfile/package.scala | 46 +- .../org/apache/iotdb/spark/tool/TsFileExample.java | 13 +- .../apache/iotdb/spark/tool/TsFileWriteTool.java | 39 +- .../apache/iotdb/spark/tsfile/ConverterTest.scala | 43 +- .../org/apache/iotdb/spark/tsfile/TSFileSuit.scala | 115 +- tsfile/format-changelist.md | 12 +- tsfile/pom.xml | 55 + .../apache/iotdb/tsfile/common/cache/Cache.java | 1 + .../apache/iotdb/tsfile/common/cache/LRUCache.java | 8 +- .../iotdb/tsfile/common/conf/TSFileConfig.java | 59 +- .../iotdb/tsfile/common/conf/TSFileDescriptor.java | 46 +- .../tsfile/common/constant/JsonFormatConstant.java | 6 +- .../tsfile/common/constant/QueryConstant.java | 3 +- .../tsfile/common/constant/TsFileConstant.java | 4 +- .../apache/iotdb/tsfile/compress/ICompressor.java | 10 +- .../iotdb/tsfile/compress/IUnCompressor.java | 12 +- .../tsfile/encoding/bitpacking/IntPacker.java | 46 +- .../tsfile/encoding/bitpacking/LongPacker.java | 51 +- .../tsfile/encoding/common/EncodingConfig.java | 4 +- .../tsfile/encoding/decoder/BitmapDecoder.java | 30 +- .../iotdb/tsfile/encoding/decoder/Decoder.java | 5 +- .../encoding/decoder/DeltaBinaryDecoder.java | 5 +- .../encoding/decoder/DoublePrecisionDecoder.java | 6 +- .../tsfile/encoding/decoder/FloatDecoder.java | 25 +- .../tsfile/encoding/decoder/GorillaDecoder.java | 6 +- .../tsfile/encoding/decoder/IntRleDecoder.java | 33 +- .../tsfile/encoding/decoder/LongRleDecoder.java | 35 +- .../tsfile/encoding/decoder/PlainDecoder.java | 5 +- .../encoding/decoder/RegularDataDecoder.java | 10 +- .../iotdb/tsfile/encoding/decoder/RleDecoder.java | 56 +- .../encoding/decoder/SinglePrecisionDecoder.java | 8 +- .../tsfile/encoding/encoder/BitmapEncoder.java | 29 +- .../encoding/encoder/DeltaBinaryEncoder.java | 47 +- .../encoding/encoder/DoublePrecisionEncoder.java | 12 +- .../iotdb/tsfile/encoding/encoder/Encoder.java | 12 +- .../tsfile/encoding/encoder/FloatEncoder.java | 13 +- .../tsfile/encoding/encoder/GorillaEncoder.java | 4 +- .../tsfile/encoding/encoder/IntRleEncoder.java | 1 + .../tsfile/encoding/encoder/LongRleEncoder.java | 3 +- .../tsfile/encoding/encoder/PlainEncoder.java | 41 +- .../encoding/encoder/RegularDataEncoder.java | 43 +- .../iotdb/tsfile/encoding/encoder/RleEncoder.java | 56 +- .../encoding/encoder/SinglePrecisionEncoder.java | 12 +- .../tsfile/encoding/encoder/TSEncodingBuilder.java | 20 +- .../tsfile/exception/NotCompatibleException.java | 27 - .../exception/NotCompatibleTsFileException.java | 28 + .../tsfile/exception/TsFileRuntimeException.java | 4 +- .../tsfile/exception/cache/CacheException.java | 5 +- .../CompressionTypeNotSupportedException.java | 4 +- .../encoding/TsFileDecodingException.java | 6 +- .../encoding/TsFileEncodingException.java | 6 +- .../exception/write/NoMeasurementException.java | 3 +- .../write/UnknownColumnTypeException.java | 4 +- .../exception/write/WriteProcessException.java | 1 - .../org/apache/iotdb/tsfile/file/MetaMarker.java | 1 + .../iotdb/tsfile/file/footer/ChunkGroupFooter.java | 27 +- .../iotdb/tsfile/file/header/ChunkHeader.java | 45 +- .../iotdb/tsfile/file/header/PageHeader.java | 1 + .../iotdb/tsfile/file/header/package-info.java | 9 +- .../tsfile/file/metadata/ChunkGroupMetaData.java | 178 - .../tsfile/file/metadata/ChunkGroupMetadata.java | 44 + .../iotdb/tsfile/file/metadata/ChunkMetaData.java | 216 - .../iotdb/tsfile/file/metadata/ChunkMetadata.java | 202 + .../tsfile/file/metadata/TimeseriesMetadata.java | 119 + .../tsfile/file/metadata/TsDeviceMetadata.java | 142 - .../file/metadata/TsDeviceMetadataIndex.java | 163 - .../iotdb/tsfile/file/metadata/TsFileMetaData.java | 423 - .../iotdb/tsfile/file/metadata/TsFileMetadata.java | 210 + .../tsfile/file/metadata/enums/TSDataType.java | 18 +- .../tsfile/file/metadata/enums/TSFreqType.java | 61 - .../file/metadata/statistics/BinaryStatistics.java | 8 +- .../metadata/statistics/BooleanStatistics.java | 5 +- .../file/metadata/statistics/DoubleStatistics.java | 17 +- .../file/metadata/statistics/FloatStatistics.java | 10 +- .../metadata/statistics/IntegerStatistics.java | 10 +- .../file/metadata/statistics/LongStatistics.java | 10 +- .../file/metadata/statistics/Statistics.java | 73 +- .../iotdb/tsfile/fileSystem/FSFactoryProducer.java | 1 - .../fileInputFactory/HDFSInputFactory.java | 7 +- .../fileInputFactory/LocalFSInputFactory.java | 8 +- .../fileOutputFactory/HDFSOutputFactory.java | 7 +- .../fileOutputFactory/LocalFSOutputFactory.java | 8 +- .../tsfile/fileSystem/fsFactory/HDFSFactory.java | 36 +- .../fileSystem/fsFactory/LocalFSFactory.java | 1 + .../org/apache/iotdb/tsfile/read/IDataReader.java | 28 - .../apache/iotdb/tsfile/read/ReadOnlyTsFile.java | 4 +- .../apache/iotdb/tsfile/read/TimeValuePair.java | 82 + .../iotdb/tsfile/read/TsFileRestorableReader.java | 18 +- .../iotdb/tsfile/read/TsFileSequenceReader.java | 582 +- .../iotdb/tsfile/read/UnClosedTsFileReader.java | 16 +- .../apache/iotdb/tsfile/read/common/BatchData.java | 201 +- .../org/apache/iotdb/tsfile/read/common/Chunk.java | 4 +- .../tsfile/read/common/ExceptionBatchData.java | 37 + .../org/apache/iotdb/tsfile/read/common/Field.java | 45 +- .../org/apache/iotdb/tsfile/read/common/Path.java | 40 +- .../apache/iotdb/tsfile/read/common/RowRecord.java | 5 + .../iotdb/tsfile/read/common/SignalBatchData.java | 5 + .../iotdb/tsfile/read/common/TimeColumn.java | 111 + .../apache/iotdb/tsfile/read/common/TimeRange.java | 20 +- .../read/controller/CachedChunkLoaderImpl.java | 71 + .../tsfile/read/controller/ChunkLoaderImpl.java | 74 - .../iotdb/tsfile/read/controller/IChunkLoader.java | 12 +- .../read/controller/IChunkMetadataLoader.java | 33 + .../tsfile/read/controller/IMetadataQuerier.java | 18 +- .../read/controller/MetadataQuerierByFileImpl.java | 187 +- .../tsfile/read/expression/ExpressionType.java | 20 +- .../iotdb/tsfile/read/expression/IExpression.java | 4 +- .../tsfile/read/expression/QueryExpression.java | 3 +- .../read/expression/impl/BinaryExpression.java | 1 + .../read/expression/impl/GlobalTimeExpression.java | 1 + .../expression/impl/SingleSeriesExpression.java | 1 + .../read/expression/util/ExpressionOptimizer.java | 63 +- .../iotdb/tsfile/read/filter/GroupByFilter.java | 30 +- .../tsfile/read/filter/basic/UnaryFilter.java | 4 + .../iotdb/tsfile/read/filter/operator/In.java | 4 + .../query/dataset/DataSetWithTimeGenerator.java | 4 +- .../query/dataset/DataSetWithoutTimeGenerator.java | 8 +- .../tsfile/read/query/dataset/EmptyDataSet.java | 39 + .../tsfile/read/query/dataset/QueryDataSet.java | 37 +- .../query/executor/ExecutorWithTimeGenerator.java | 18 +- .../tsfile/read/query/executor/TsFileExecutor.java | 16 +- .../read/query/timegenerator/TimeGenerator.java | 77 +- .../query/timegenerator/TimeGeneratorImpl.java | 130 - .../query/timegenerator/TsFileTimeGenerator.java | 51 + .../read/query/timegenerator/node/AndNode.java | 7 +- .../read/query/timegenerator/node/LeafNode.java | 64 +- .../read/query/timegenerator/node/OrNode.java | 2 +- .../tsfile/read/reader/BatchDataIterator.java | 55 + .../tsfile/read/reader/DefaultTsFileInput.java | 92 - .../iotdb/tsfile/read/reader/IAggregateReader.java | 35 - .../iotdb/tsfile/read/reader/IChunkReader.java | 35 + .../iotdb/tsfile/read/reader/IPageReader.java | 34 + .../iotdb/tsfile/read/reader/IPointReader.java | 34 + .../iotdb/tsfile/read/reader/LocalTsFileInput.java | 92 + .../iotdb/tsfile/read/reader/TsFileInput.java | 71 +- .../tsfile/read/reader/chunk/ChunkReader.java | 89 +- .../read/reader/chunk/ChunkReaderByTimestamp.java | 4 +- .../iotdb/tsfile/read/reader/page/PageReader.java | 45 +- .../reader/series/AbstractFileSeriesReader.java | 57 +- .../read/reader/series/EmptyFileSeriesReader.java | 11 +- .../read/reader/series/FileSeriesReader.java | 12 +- .../reader/series/FileSeriesReaderByTimestamp.java | 20 +- .../tool/upgrade/TsfileUpgradeToolV0_8_0.java | 543 - .../iotdb/tsfile/tool/upgrade/UpgradeTool.java | 108 - .../java/org/apache/iotdb/tsfile/utils/Binary.java | 7 +- .../org/apache/iotdb/tsfile/utils/BloomFilter.java | 3 +- .../org/apache/iotdb/tsfile/utils/BytesUtils.java | 21 +- .../java/org/apache/iotdb/tsfile/utils/Loader.java | 4 +- .../apache/iotdb/tsfile/utils/Murmur128Hash.java | 84 +- .../java/org/apache/iotdb/tsfile/utils/Pair.java | 4 +- .../org/apache/iotdb/tsfile/utils/PublicBAOS.java | 26 +- .../tsfile/utils/ReadWriteForEncodingUtils.java | 65 +- .../iotdb/tsfile/utils/ReadWriteIOUtils.java | 31 +- .../apache/iotdb/tsfile/utils/StringContainer.java | 63 +- .../apache/iotdb/tsfile/utils/VersionUtils.java | 43 + .../apache/iotdb/tsfile/write/TsFileWriter.java | 126 +- .../tsfile/write/chunk/ChunkGroupWriterImpl.java | 9 +- .../iotdb/tsfile/write/chunk/ChunkWriterImpl.java | 16 +- .../tsfile/write/chunk/IChunkGroupWriter.java | 1 - .../apache/iotdb/tsfile/write/page/PageWriter.java | 42 +- .../apache/iotdb/tsfile/write/record/RowBatch.java | 135 +- .../apache/iotdb/tsfile/write/record/TSRecord.java | 18 +- .../write/record/datapoint/BooleanDataPoint.java | 4 +- .../tsfile/write/record/datapoint/DataPoint.java | 9 +- .../write/record/datapoint/DoubleDataPoint.java | 4 +- .../write/record/datapoint/FloatDataPoint.java | 4 +- .../write/record/datapoint/IntDataPoint.java | 4 +- .../write/record/datapoint/LongDataPoint.java | 4 +- .../write/record/datapoint/StringDataPoint.java | 4 +- .../tsfile/write/schema/MeasurementSchema.java | 54 +- .../apache/iotdb/tsfile/write/schema/Schema.java | 139 +- .../iotdb/tsfile/write/schema/SchemaBuilder.java | 93 - .../tsfile/write/writer/DefaultTsFileOutput.java | 90 - .../write/writer/ForceAppendTsFileWriter.java | 41 +- .../tsfile/write/writer/LocalTsFileOutput.java | 86 + .../write/writer/RestorableTsFileIOWriter.java | 190 +- .../iotdb/tsfile/write/writer/TsFileIOWriter.java | 328 +- .../iotdb/tsfile/write/writer/TsFileOutput.java | 15 +- .../apache/iotdb/tsfile/common/LRUCacheTest.java | 4 +- .../apache/iotdb/tsfile/compress/CompressTest.java | 6 +- .../apache/iotdb/tsfile/compress/SnappyTest.java | 10 +- .../apache/iotdb/tsfile/constant/TestConstant.java | 8 +- .../tsfile/encoding/bitpacking/IntPackerTest.java | 3 + .../tsfile/encoding/bitpacking/LongPackerTest.java | 5 +- .../tsfile/encoding/decoder/BitmapDecoderTest.java | 7 +- .../tsfile/encoding/decoder/FloatDecoderTest.java | 23 +- .../encoding/decoder/GorillaDecoderTest.java | 10 +- .../tsfile/encoding/decoder/IntRleDecoderTest.java | 10 +- .../encoding/decoder/LongRleDecoderTest.java | 10 +- .../delta/DeltaBinaryEncoderIntegerTest.java | 10 +- .../decoder/delta/DeltaBinaryEncoderLongTest.java | 38 +- .../regular/RegularDataEncoderIntegerTest.java | 5 +- .../regular/RegularDataEncoderLongTest.java | 30 +- .../iotdb/tsfile/file/header/PageHeaderTest.java | 12 +- .../file/metadata/ChunkGroupMetaDataTest.java | 108 - .../file/metadata/TimeSeriesMetadataTest.java | 23 +- .../file/metadata/TsDeviceMetadataIndexTest.java | 77 - .../tsfile/file/metadata/TsFileMetaDataTest.java | 102 - .../tsfile/file/metadata/TsFileMetadataTest.java | 105 + .../metadata/statistics/BooleanStatisticsTest.java | 4 +- .../metadata/statistics/DoubleStatisticsTest.java | 3 + .../metadata/statistics/FloatStatisticsTest.java | 3 + .../metadata/statistics/IntegerStatisticsTest.java | 3 + .../metadata/statistics/LongStatisticsTest.java | 6 +- .../metadata/statistics/StringStatisticsTest.java | 5 +- .../tsfile/file/metadata/utils/TestHelper.java | 62 +- .../iotdb/tsfile/file/metadata/utils/Utils.java | 100 +- .../apache/iotdb/tsfile/read/ExpressionTest.java | 60 + .../iotdb/tsfile/read/ReadInPartitionTest.java | 112 +- .../iotdb/tsfile/read/ReadOnlyTsFileTest.java | 36 +- .../org/apache/iotdb/tsfile/read/ReadTest.java | 58 +- .../iotdb/tsfile/read/TimePlainEncodeReadTest.java | 67 +- .../tsfile/read/TsFileRestorableReaderTest.java | 8 +- .../tsfile/read/TsFileSequenceReaderTest.java | 57 +- .../iotdb/tsfile/read/common/BatchDataTest.java | 82 + .../apache/iotdb/tsfile/read/common/PathTest.java | 2 - .../iotdb/tsfile/read/common/TimeRangeTest.java | 35 +- .../tsfile/read/controller/ChunkLoaderTest.java | 21 +- .../controller/IMetadataQuerierByFileImplTest.java | 97 +- .../read/filter/IExpressionOptimizerTest.java | 124 +- .../read/filter/MinTimeMaxTimeFilterTest.java | 10 +- .../iotdb/tsfile/read/filter/OperatorTest.java | 12 +- .../tsfile/read/filter/StatisticsFilterTest.java | 8 +- .../read/query/executor/QueryExecutorTest.java | 43 +- .../tsfile/read/query/timegenerator/NodeTest.java | 70 +- .../read/query/timegenerator/ReadWriteTest.java | 181 + .../query/timegenerator/ReaderByTimestampTest.java | 12 +- .../timegenerator/TimeGeneratorReadEmptyTest.java | 143 + .../timegenerator/TimeGeneratorReadWriteTest.java | 184 + .../query/timegenerator/TimeGeneratorTest.java | 9 +- .../TsFileGeneratorForSeriesReaderByTimestamp.java | 52 +- .../iotdb/tsfile/read/reader/FakedBatchReader.java | 55 + .../tsfile/read/reader/FakedMultiBatchReader.java | 62 + .../tsfile/read/reader/FakedTimeGenerator.java | 73 + .../iotdb/tsfile/read/reader/ReaderTest.java | 20 +- .../apache/iotdb/tsfile/utils/BloomFilterTest.java | 5 +- .../apache/iotdb/tsfile/utils/BytesUtilsTest.java | 4 +- .../apache/iotdb/tsfile/utils/FileGenerator.java | 48 +- .../org/apache/iotdb/tsfile/utils/FileUtils.java | 23 +- .../apache/iotdb/tsfile/utils/FileUtilsTest.java | 20 +- .../org/apache/iotdb/tsfile/utils/PairTest.java | 3 + .../tsfile/utils/ReadWriteStreamUtilsTest.java | 15 +- .../tsfile/utils/ReadWriteToBytesUtilsTest.java | 9 +- .../org/apache/iotdb/tsfile/utils/RecordUtils.java | 19 +- .../apache/iotdb/tsfile/utils/RecordUtilsTest.java | 27 +- .../iotdb/tsfile/utils/StringContainerTest.java | 2 + .../iotdb/tsfile/utils/TsFileGeneratorForTest.java | 135 +- .../iotdb/tsfile/utils/TsPrimitiveTypeTest.java | 60 + .../org/apache/iotdb/tsfile/write/PerfTest.java | 53 +- .../iotdb/tsfile/write/ReadPageInMemTest.java | 37 +- ...SameMeasurementsWithDifferentDataTypesTest.java | 201 + .../iotdb/tsfile/write/TsFileIOWriterTest.java | 33 +- .../iotdb/tsfile/write/TsFileReadWriteTest.java | 83 +- .../iotdb/tsfile/write/TsFileWriterTest.java | 47 +- .../org/apache/iotdb/tsfile/write/WriteTest.java | 81 +- .../write/schema/converter/SchemaBuilderTest.java | 80 +- .../iotdb/tsfile/write/writer/PageWriterTest.java | 36 +- .../write/writer/RestorableTsFileIOWriterTest.java | 161 +- tsfile/src/test/resources/logback.xml | 12 +- 1186 files changed, 66863 insertions(+), 108064 deletions(-)
