This is an automated email from the ASF dual-hosted git repository. ejttianyu pushed a commit to branch dev_new_merge in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
commit 6fe2b2a55065ccfb41b5b203c5de66adc19d4706 Merge: 6605e90 3366216 Author: EJTTianyu <[email protected]> AuthorDate: Thu May 21 15:14:27 2020 +0800 merge new merge strategy .asf.yaml | 0 .checkstyle | 0 .github/ISSUE_TEMPLATE/bug_report.md | 0 .github/ISSUE_TEMPLATE/custom.md | 0 .github/ISSUE_TEMPLATE/feature_request.md | 0 .gitignore | 3 + .mvn/wrapper/MavenWrapperDownloader.java | 0 .mvn/wrapper/maven-wrapper.properties | 0 .travis.yml | 0 DISCLAIMER | 0 Jenkinsfile | 0 LICENSE | 0 LICENSE-binary | 4 +- NOTICE | 0 NOTICE-binary | 0 README.md | 18 +- README_ZH.md | 14 +- RELEASE_NOTES.md | 0 asf.header | 0 checkstyle.xml | 0 {client => cli}/pom.xml | 6 +- .../client.xml => cli/src/assembly/cli.xml | 2 +- .../src/assembly/resources/sbin/start-cli.bat | 10 +- .../src/assembly/resources/sbin/start-cli.sh | 2 +- .../src/assembly/resources/tools/export-csv.bat | 0 .../src/assembly/resources/tools/export-csv.sh | 0 .../src/assembly/resources/tools/import-csv.bat | 0 .../src/assembly/resources/tools/import-csv.sh | 0 .../java/org/apache/iotdb/cli/AbstractCli.java | 92 +- .../src/main/java/org/apache/iotdb/cli/Cli.java | 10 +- .../src/main/java/org/apache/iotdb/cli/WinCli.java | 6 +- .../apache/iotdb/exception/ArgsErrorException.java | 0 .../org/apache/iotdb/tool/AbstractCsvTool.java | 0 .../main/java/org/apache/iotdb/tool/ExportCsv.java | 4 +- .../main/java/org/apache/iotdb/tool/ImportCsv.java | 0 .../java/org/apache/iotdb/cli/AbstractCliIT.java | 218 +++++ .../java/org/apache/iotdb/cli}/AbstractScript.java | 4 +- .../org/apache/iotdb/cli}/StartClientScriptIT.java | 8 +- .../org/apache/iotdb/tool/ExportCsvTestIT.java | 2 +- .../org/apache/iotdb/tool/ImportCsvTestIT.java | 2 +- {client => cli}/src/test/resources/logback.xml | 0 client-py/compile.bat | 0 client-py/compile.sh | 0 client-py/readme.md | 0 client-py/src/client_example.py | 8 +- .../org/apache/iotdb/client/AbstractClientIT.java | 0 codecov.yml | 0 distribution/pom.xml | 2 +- distribution/src/assembly/distribution.xml | 0 docker/ReadMe.md | 0 docker/src/main/Dockerfile | 0 docker/src/main/Dockerfile-0.8.1 | 0 docker/src/main/Dockerfile-0.9.0 | 0 docker/src/main/Dockerfile-0.9.1 | 0 .../{Dockerfile-0.9.1 => Dockerfile-0.9.1-jre8} | 2 +- docs/Community/Community-Powered By.md | 0 docs/Community/Community-Project Committers.md | 0 docs/Community/Feedback.md | 48 + docs/Community/Materials.md | 100 +++ docs/Development/Committer.md | 0 docs/Development/ContributeGuide.md | 15 +- docs/Development/HowToCommit.md | 0 docs/Development/VoteRelease.md | 0 docs/Download/README.md | 10 + docs/README.md | 0 docs/SystemDesign/0-Architecture/1-Architecture.md | 0 docs/SystemDesign/1-TsFile/1-TsFile.md | 0 docs/SystemDesign/1-TsFile/2-Format.md | 283 ++++-- docs/SystemDesign/1-TsFile/3-Write.md | 4 +- docs/SystemDesign/1-TsFile/4-Read.md | 0 docs/SystemDesign/2-QueryEngine/1-QueryEngine.md | 0 docs/SystemDesign/2-QueryEngine/2-Planner.md | 0 docs/SystemDesign/2-QueryEngine/3-PlanExecutor.md | 0 .../2-QueryEngine/4-ResultSetConstruction.md | 177 ++++ .../3-SchemaManager/1-SchemaManager.md | 218 ++++- .../4-StorageEngine/1-StorageEngine.md | 0 docs/SystemDesign/4-StorageEngine/2-WAL.md | 0 .../SystemDesign/4-StorageEngine/3-FlushManager.md | 0 .../SystemDesign/4-StorageEngine/4-MergeManager.md | 0 .../4-StorageEngine/5-DataPartition.md | 0 .../4-StorageEngine/6-DataManipulation.md | 2 +- docs/SystemDesign/5-DataQuery/1-DataQuery.md | 4 +- .../5-DataQuery/10-GroupByFillQuery.md | 0 .../5-DataQuery/2-QueryFundamentals.md | 128 +++ .../5-DataQuery/3-ModificationHandle.md | 0 .../{2-SeriesReader.md => 3-SeriesReader.md} | 0 docs/SystemDesign/5-DataQuery/4-RawDataQuery.md | 0 .../SystemDesign/5-DataQuery/5-AggregationQuery.md | 0 docs/SystemDesign/5-DataQuery/6-GroupByQuery.md | 0 docs/SystemDesign/5-DataQuery/7-LastQuery.md | 0 .../5-DataQuery/8-AlignByDeviceQuery.md | 0 docs/SystemDesign/5-DataQuery/9-FillFunction.md | 12 +- docs/SystemDesign/6-Tools/1-Sync.md | 0 docs/SystemDesign/7-Connector/2-Hive-TsFile.md | 0 docs/SystemDesign/7-Connector/3-Spark-TsFile.md | 0 docs/SystemDesign/7-Connector/4-Spark-IOTDB.md | 0 docs/UserGuide/0-Get Started/1-QuickStart.md | 12 +- .../0-Get Started/2-Frequently asked questions.md | 14 +- docs/UserGuide/0-Get Started/3-Publication.md | 0 docs/UserGuide/1-Overview/1-What is IoTDB.md | 0 docs/UserGuide/1-Overview/2-Architecture.md | 0 docs/UserGuide/1-Overview/3-Scenario.md | 0 docs/UserGuide/1-Overview/4-Features.md | 0 .../2-Concept/1-Data Model and Terminology.md | 0 docs/UserGuide/2-Concept/2-Data Type.md | 0 docs/UserGuide/2-Concept/3-Encoding.md | 0 docs/UserGuide/2-Concept/4-Compression.md | 0 docs/UserGuide/3-Server/1-Download.md | 0 docs/UserGuide/3-Server/2-Single Node Setup.md | 0 docs/UserGuide/3-Server/3-Cluster Setup.md | 0 docs/UserGuide/3-Server/4-Config Manual.md | 21 + docs/UserGuide/3-Server/5-Docker Image.md | 0 .../UserGuide/4-Client/1-Command Line Interface.md | 44 +- .../4-Client/2-Programming - Native API.md | 114 ++- docs/UserGuide/4-Client/3-Programming - JDBC.md | 8 + .../4-Client/4-Programming - Other Languages.md | 0 .../4-Client/5-Programming - TsFile API.md | 153 +--- docs/UserGuide/4-Client/6-Programming - MQTT.md | 0 docs/UserGuide/4-Client/7-Status Codes.md | 11 +- .../1-DDL Data Definition Language.md | 145 ++- .../2-DML Data Manipulation Language.md | 7 +- .../3-Account Management Statements.md | 2 +- .../5-Operation Manual/4-SQL Reference.md | 89 +- docs/UserGuide/6-System Tools/1-Sync Tool.md | 0 .../6-System Tools/2-Memory Estimation Tool.md | 0 docs/UserGuide/6-System Tools/3-JMX Tool.md | 47 +- docs/UserGuide/6-System Tools/4-Watermark Tool.md | 0 docs/UserGuide/6-System Tools/5-Log Visualizer.md | 0 .../6-Query History Visualization Tool.md | 0 .../6-System Tools/7-Monitor and Log Tools.md | 0 .../6-System Tools/8-Load External Tsfile.md | 4 +- .../UserGuide/7-Ecosystem Integration/1-Grafana.md | 73 +- .../7-Ecosystem Integration/2-MapReduce TsFile.md | 0 .../7-Ecosystem Integration/3-Spark TsFile.md | 0 .../7-Ecosystem Integration/4-Spark IoTDB.md | 0 .../7-Ecosystem Integration/5-Hive TsFile.md | 0 docs/UserGuide/8-Architecture/1-Files.md | 0 .../8-Architecture/2-Writing Data on HDFS.md | 0 .../8-Architecture/3-Shared Nothing Cluster.md | 0 docs/UserGuide/UserGuideReadme.md | 0 docs/zh/Community/Community-Powered By.md | 0 docs/zh/Community/Community-Project Committers.md | 0 docs/zh/Community/Feedback.md | 44 + docs/zh/Community/Materials.md | 95 ++ docs/zh/Development/Committer.md | 2 +- docs/zh/Development/ContributeGuide.md | 12 +- docs/zh/Development/HowToCommit.md | 0 docs/zh/Development/VoteRelease.md | 0 docs/zh/Download/README.md | 10 + docs/zh/README.md | 0 .../SystemDesign/0-Architecture/1-Architecture.md | 0 docs/zh/SystemDesign/1-TsFile/1-TsFile.md | 0 docs/zh/SystemDesign/1-TsFile/2-Format.md | 2 +- docs/zh/SystemDesign/1-TsFile/3-Write.md | 2 +- docs/zh/SystemDesign/1-TsFile/4-Read.md | 0 .../zh/SystemDesign/2-QueryEngine/1-QueryEngine.md | 0 docs/zh/SystemDesign/2-QueryEngine/2-Planner.md | 0 .../SystemDesign/2-QueryEngine/3-PlanExecutor.md | 0 .../2-QueryEngine/4-ResultSetConstruction.md | 175 ++++ .../3-SchemaManager/1-SchemaManager.md | 210 ++++- .../4-StorageEngine/1-StorageEngine.md | 0 docs/zh/SystemDesign/4-StorageEngine/2-WAL.md | 0 .../SystemDesign/4-StorageEngine/3-FlushManager.md | 0 .../SystemDesign/4-StorageEngine/4-MergeManager.md | 0 .../4-StorageEngine/5-DataPartition.md | 0 .../4-StorageEngine/6-DataManipulation.md | 2 +- docs/zh/SystemDesign/5-DataQuery/1-DataQuery.md | 4 +- .../5-DataQuery/10-GroupByFillQuery.md | 0 .../5-DataQuery/2-QueryFundamentals.md | 110 +++ .../5-DataQuery/3-ModificationHandle.md | 0 .../{2-SeriesReader.md => 3-SeriesReader.md} | 0 docs/zh/SystemDesign/5-DataQuery/4-RawDataQuery.md | 0 .../SystemDesign/5-DataQuery/5-AggregationQuery.md | 0 docs/zh/SystemDesign/5-DataQuery/6-GroupByQuery.md | 0 docs/zh/SystemDesign/5-DataQuery/7-LastQuery.md | 0 .../5-DataQuery/8-AlignByDeviceQuery.md | 0 docs/zh/SystemDesign/5-DataQuery/9-FillFunction.md | 13 +- docs/zh/SystemDesign/6-Tools/1-Sync.md | 0 docs/zh/SystemDesign/7-Connector/2-Hive-TsFile.md | 0 docs/zh/SystemDesign/7-Connector/3-Spark-TsFile.md | 0 docs/zh/SystemDesign/7-Connector/4-Spark-IOTDB.md | 0 docs/zh/UserGuide/0-Get Started/1-QuickStart.md | 10 +- .../0-Get Started/2-Frequently asked questions.md | 8 +- docs/zh/UserGuide/0-Get Started/3-Publication.md | 0 docs/zh/UserGuide/1-Overview/1-What is IoTDB.md | 0 docs/zh/UserGuide/1-Overview/2-Architecture.md | 0 docs/zh/UserGuide/1-Overview/3-Scenario.md | 0 docs/zh/UserGuide/1-Overview/4-Features.md | 0 .../2-Concept/1-Data Model and Terminology.md | 0 docs/zh/UserGuide/2-Concept/2-Data Type.md | 0 docs/zh/UserGuide/2-Concept/3-Encoding.md | 0 docs/zh/UserGuide/2-Concept/4-Compression.md | 0 docs/zh/UserGuide/3-Server/1-Download.md | 36 +- docs/zh/UserGuide/3-Server/2-Single Node Setup.md | 0 docs/zh/UserGuide/3-Server/3-Cluster Setup.md | 0 docs/zh/UserGuide/3-Server/4-Config Manual.md | 30 +- docs/zh/UserGuide/3-Server/5-Docker Image.md | 0 .../UserGuide/4-Client/1-Command Line Interface.md | 38 +- .../4-Client/2-Programming - Native API.md | 101 ++- docs/zh/UserGuide/4-Client/3-Programming - JDBC.md | 11 +- .../4-Client/4-Programming - Other Languages.md | 0 .../4-Client/5-Programming - TsFile API.md | 152 +--- docs/zh/UserGuide/4-Client/6-Programming - MQTT.md | 2 +- docs/zh/UserGuide/4-Client/7-Status Codes.md | 11 +- .../1-DDL Data Definition Language.md | 134 ++- .../2-DML Data Manipulation Language.md | 7 +- .../3-Account Management Statements.md | 2 +- .../5-Operation Manual/4-SQL Reference.md | 88 +- docs/zh/UserGuide/6-System Tools/1-Sync Tool.md | 0 .../6-System Tools/2-Memory Estimation Tool.md | 0 docs/zh/UserGuide/6-System Tools/3-JMX Tool.md | 59 +- .../UserGuide/6-System Tools/4-Watermark Tool.md | 0 .../UserGuide/6-System Tools/5-Log Visualizer.md | 0 .../6-Query History Visualization Tool.md | 0 .../6-System Tools/7-Monitor and Log Tools.md | 0 .../6-System Tools/8-Load External Tsfile.md | 4 +- .../UserGuide/7-Ecosystem Integration/1-Grafana.md | 68 +- .../7-Ecosystem Integration/2-MapReduce TsFile.md | 0 .../7-Ecosystem Integration/3-Spark TsFile.md | 0 .../7-Ecosystem Integration/4-Spark IoTDB.md | 0 .../7-Ecosystem Integration/5-Hive TsFile.md | 0 docs/zh/UserGuide/8-Architecture/1-Files.md | 0 .../8-Architecture/2-Writing Data on HDFS.md | 0 .../8-Architecture/3-Shared Nothing Cluster.md | 0 docs/zh/UserGuide/UserGuideReadme.md | 0 example/flink/README.md | 2 + example/flink/pom.xml | 0 .../org/apache/iotdb/flink/FlinkIoTDBSink.java | 0 .../apache/iotdb/flink/FlinkTsFileBatchSink.java | 114 +++ .../apache/iotdb/flink/FlinkTsFileBatchSource.java | 0 .../apache/iotdb/flink/FlinkTsFileStreamSink.java | 115 +++ .../iotdb/flink/FlinkTsFileStreamSource.java | 0 .../java/org/apache/iotdb/flink/TsFlieUtils.java | 26 + example/hadoop/pom.xml | 0 .../org/apache/iotdb/hadoop/tsfile/Constant.java | 0 .../iotdb/hadoop/tsfile/TSFMRReadExample.java | 0 .../iotdb/hadoop/tsfile/TSMRWriteExample.java | 0 .../apache/iotdb/hadoop/tsfile/TsFileHelper.java | 50 +- .../iotdb/hadoop/tsfile/TsFileWriteToHDFS.java | 0 example/jdbc/pom.xml | 0 .../main/java/org/apache/iotdb/JDBCExample.java | 0 .../org/apache/iotdb/PrepareStatementDemo.java | 0 example/kafka/pom.xml | 0 example/kafka/readme.md | 0 .../main/java/org/apache/iotdb/kafka/Constant.java | 0 .../java/org/apache/iotdb/kafka/KafkaConsumer.java | 0 .../apache/iotdb/kafka/KafkaConsumerThread.java | 0 .../java/org/apache/iotdb/kafka/KafkaProducer.java | 0 example/mqtt/README.md | 0 example/mqtt/pom.xml | 0 .../java/org/apache/iotdb/mqtt/MQTTClient.java | 0 example/pom.xml | 0 example/rocketmq/pom.xml | 0 example/rocketmq/readme.md | 0 .../java/org/apache/iotdb/rocketmq/Constant.java | 0 .../apache/iotdb/rocketmq/RocketMQConsumer.java | 2 +- .../apache/iotdb/rocketmq/RocketMQProducer.java | 0 .../main/java/org/apache/iotdb/rocketmq/Utils.java | 0 example/session/pom.xml | 0 .../main/java/org/apache/iotdb/SessionExample.java | 245 +++-- example/tsfile/pom.xml | 0 example/tsfile/readme.md | 0 .../java/org/apache/iotdb/tsfile/Constant.java | 0 .../java/org/apache/iotdb/tsfile/TsFileRead.java | 4 +- .../apache/iotdb/tsfile/TsFileSequenceRead.java | 15 +- .../iotdb/tsfile/TsFileWriteWithTSRecord.java | 0 ...ithRowBatch.java => TsFileWriteWithTablet.java} | 76 +- flink-iotdb-connector/README.md | 0 flink-iotdb-connector/pom.xml | 0 .../iotdb/flink/DefaultIoTSerializationSchema.java | 0 .../main/java/org/apache/iotdb/flink/Event.java | 0 .../java/org/apache/iotdb/flink/IoTDBOptions.java | 0 .../java/org/apache/iotdb/flink/IoTDBSink.java | 4 +- .../apache/iotdb/flink/IoTSerializationSchema.java | 0 .../flink/DefaultIoTSerializationSchemaTest.java | 0 .../iotdb/flink/IoTDBSinkBatchInsertTest.java | 4 +- .../iotdb/flink/IoTDBSinkBatchTimerTest.java | 2 +- .../apache/iotdb/flink/IoTDBSinkInsertTest.java | 2 +- flink-tsfile-connector/README.md | 86 +- flink-tsfile-connector/pom.xml | 0 .../apache/iotdb/flink/tsfile/RowRecordParser.java | 0 .../iotdb/flink/tsfile/RowRowRecordParser.java | 0 .../iotdb/flink/tsfile/RowTSRecordConverter.java | 163 ++++ .../iotdb/flink/tsfile/TSRecordConverter.java | 61 ++ .../iotdb/flink/tsfile/TSRecordOutputFormat.java | 99 ++ .../iotdb/flink/tsfile/TsFileInputFormat.java | 0 .../iotdb/flink/tsfile/TsFileOutputFormat.java | 122 +++ .../iotdb/flink/tsfile/util/TSFileConfigUtil.java | 1 + .../tsfile/RowTSRecordOutputFormatITCase.java | 56 ++ .../flink/tsfile/RowTSRecordOutputFormatTest.java | 77 ++ .../flink/tsfile/RowTsFileConnectorTestBase.java | 87 ++ .../flink/tsfile/RowTsFileInputFormatITCase.java | 0 .../flink/tsfile/RowTsFileInputFormatTest.java | 0 .../flink/tsfile/RowTsFileInputFormatTestBase.java | 72 +- .../tsfile/RowTsFileOutputFormatTestBase.java | 117 +++ .../util/TSFileConfigUtilCompletenessTest.java | 102 +-- .../apache/iotdb/flink/util/TsFileWriteUtil.java | 2 +- grafana/img/add_data_source.png | Bin grafana/img/add_graph.png | Bin grafana/img/edit_data_source.png | Bin grafana/pom.xml | 0 grafana/readme.md | 74 +- grafana/readme_zh.md | 95 +- .../web/grafana/TsfileWebDemoApplication.java | 0 .../apache/iotdb/web/grafana/bean/TimeValues.java | 0 .../iotdb/web/grafana/conf/MyConfiguration.java | 0 .../controller/DatabaseConnectController.java | 0 .../org/apache/iotdb/web/grafana/dao/BasicDao.java | 0 .../iotdb/web/grafana/dao/impl/BasicDaoImpl.java | 147 +-- .../grafana/service/DatabaseConnectService.java | 0 .../service/impl/DatabaseConnectServiceImpl.java | 0 .../main/resources}/application.properties | 14 +- hadoop/README.md | 0 hadoop/pom.xml | 0 .../iotdb/hadoop/fileSystem/HDFSConfUtil.java | 0 .../apache/iotdb/hadoop/fileSystem/HDFSFile.java | 26 +- .../apache/iotdb/hadoop/fileSystem/HDFSInput.java | 45 +- .../apache/iotdb/hadoop/fileSystem/HDFSOutput.java | 15 +- .../org/apache/iotdb/hadoop/tsfile/IReaderSet.java | 0 .../iotdb/hadoop/tsfile/TSFHadoopException.java | 0 .../apache/iotdb/hadoop/tsfile/TSFInputFormat.java | 10 +- .../apache/iotdb/hadoop/tsfile/TSFInputSplit.java | 0 .../iotdb/hadoop/tsfile/TSFOutputFormat.java | 0 .../iotdb/hadoop/tsfile/TSFRecordReader.java | 0 .../iotdb/hadoop/tsfile/TSFRecordWriter.java | 0 .../iotdb/hadoop/tsfile/record/HDFSTSRecord.java | 0 .../apache/iotdb/hadoop/tsfile/TSFHadoopTest.java | 0 .../iotdb/hadoop/tsfile/TSFInputSplitTest.java | 0 .../iotdb/hadoop/tsfile/TsFileTestHelper.java | 40 +- .../iotdb/hadoop/tsfile/constant/TestConstant.java | 0 hadoop/src/test/resources/logback.xml | 0 hive-connector/pom.xml | 0 .../org/apache/iotdb/hive/TSFHiveInputFormat.java | 0 .../org/apache/iotdb/hive/TSFHiveOutputFormat.java | 0 .../org/apache/iotdb/hive/TSFHiveRecordReader.java | 0 .../org/apache/iotdb/hive/TSFHiveRecordWriter.java | 0 .../org/apache/iotdb/hive/TsFileDeserializer.java | 0 .../java/org/apache/iotdb/hive/TsFileSerDe.java | 0 .../apache/iotdb/hive/TsFileSerDeException.java | 0 .../apache/iotdb/hive/TSFHiveInputFormatTest.java | 0 .../apache/iotdb/hive/TSFHiveRecordReaderTest.java | 0 .../apache/iotdb/hive/TsFileDeserializerTest.java | 0 .../org/apache/iotdb/hive/TsFileSerDeTest.java | 0 .../org/apache/iotdb/hive/TsFileTestHelper.java | 41 +- .../apache/iotdb/hive/constant/TestConstant.java | 0 hive-connector/src/test/resources/logback.xml | 0 java-google-style.xml | 0 jdbc/README.md | 0 jdbc/osgi.bnd | 0 jdbc/pom.xml | 0 jdbc/src/main/feature/feature.xml | 0 ...ultSet.java => AbstractIoTDBJDBCResultSet.java} | 273 +++--- .../main/java/org/apache/iotdb/jdbc/Activator.java | 0 .../main/java/org/apache/iotdb/jdbc/Config.java | 0 .../main/java/org/apache/iotdb/jdbc/Constant.java | 0 .../org/apache/iotdb/jdbc/IoTDBConnection.java | 0 .../apache/iotdb/jdbc/IoTDBConnectionParams.java | 0 .../org/apache/iotdb/jdbc/IoTDBDataSource.java | 0 .../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 0 .../java/org/apache/iotdb/jdbc/IoTDBDriver.java | 0 .../org/apache/iotdb/jdbc/IoTDBJDBCResultSet.java | 93 ++ ...ultSet.java => IoTDBNonAlignJDBCResultSet.java} | 110 ++- .../apache/iotdb/jdbc/IoTDBPreparedStatement.java | 0 .../org/apache/iotdb/jdbc/IoTDBQueryResultSet.java | 203 ----- .../org/apache/iotdb/jdbc/IoTDBResultMetadata.java | 0 .../org/apache/iotdb/jdbc/IoTDBSQLException.java | 0 .../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 26 +- .../org/apache/iotdb/jdbc/IoTDBURLException.java | 0 .../apache/iotdb/jdbc/IoTDbDataSourceFactory.java | 0 .../src/main/java/org/apache/iotdb/jdbc/Utils.java | 0 .../resources/services/META-INF/java.sql.Driver | 0 .../test/java/org/apache/iotdb/jdbc/BatchTest.java | 0 .../org/apache/iotdb/jdbc/IoTDBConnectionTest.java | 0 ...ultSetTest.java => IoTDBJDBCResultSetTest.java} | 2 +- .../iotdb/jdbc/IoTDBPreparedStatementTest.java | 0 .../apache/iotdb/jdbc/IoTDBResultMetadataTest.java | 0 .../org/apache/iotdb/jdbc/IoTDBStatementTest.java | 0 .../test/java/org/apache/iotdb/jdbc/UtilsTest.java | 0 jenkins.pom | 0 licenses/CDDL License 1.1 | 0 licenses/EDL License 1.0 | 0 licenses/Eclipse Public License 1.0 (EPL-1.0) | 0 .../Eclipse Public License version 2.0 (EPL-2.0) | 0 licenses/The 2-Clause BSD License | 0 licenses/The 3-Clause BSD License | 0 licenses/The MIT License (QOS.ch) | 0 licenses/The MIT License (progressbar) | 0 mvnw.cmd | 0 pom.xml | 20 +- server/pom.xml | 0 server/server-changelist.md | 0 .../resources/conf/iotdb-engine.properties | 129 +-- server/src/assembly/resources/conf/iotdb-env.bat | 0 .../resources/conf/iotdb-sync-client.properties | 0 server/src/assembly/resources/conf/jmx.access | 0 server/src/assembly/resources/conf/jmx.password | 0 .../src/assembly/resources/conf/logback-tool.xml | 0 server/src/assembly/resources/conf/logback.xml | 0 .../src/assembly/resources/sbin/start-server.bat | 11 +- .../assembly/resources/tools/detect-watermark.bat | 0 .../assembly/resources/tools/detect-watermark.sh | 0 .../resources/tools/logVisualize/config.properties | 0 .../tools/logVisualize/default.log.pattern | 0 .../tools/logVisualize/log-visualizer-cmd.bat | 0 .../tools/logVisualize/log-visualizer-cmd.sh | 0 .../tools/logVisualize/log-visualizer-gui.bat | 0 .../tools/logVisualize/log-visualizer-gui.sh | 0 .../plans/closeMetadataConsumption.plan | 0 .../tools/logVisualize/plans/compressionRatio.plan | 0 .../logVisualize/plans/dynamicParameters.plan | 0 .../tools/logVisualize/plans/flushSubmits.plan | 0 .../plans/flushTimeConsumption.plan.example | 0 .../tools/logVisualize/plans/memTableWait.plan | 0 .../tools/logVisualize/plans/mergeFileNum.plan | 0 .../tools/logVisualize/plans/mergeRate.plan | 0 .../logVisualize/plans/mergeSeriesProgress.plan | 0 .../assembly/resources/tools/start-WalChecker.bat | 0 .../tools/tsfileToolSet/print-iotdb-data-dir.bat | 0 .../tools/tsfileToolSet/print-iotdb-data-dir.sh | 0 .../tsfileToolSet/print-tsfile-resource-files.bat | 0 .../tools/tsfileToolSet/print-tsfile-sketch.bat | 0 .../resources/tools/upgrade/config.properties | 0 .../resources/tools/upgrade/offline-upgrade.bat | 0 server/src/assembly/server.xml | 0 .../org/apache/iotdb/db/qp/strategy/SqlBase.g4 | 76 +- .../org/apache/iotdb/db/auth/AuthException.java | 0 .../org/apache/iotdb/db/auth/AuthorityChecker.java | 0 .../iotdb/db/auth/authorizer/BasicAuthorizer.java | 0 .../iotdb/db/auth/authorizer/IAuthorizer.java | 0 .../db/auth/authorizer/LocalFileAuthorizer.java | 0 .../apache/iotdb/db/auth/entity/PathPrivilege.java | 0 .../apache/iotdb/db/auth/entity/PrivilegeType.java | 0 .../java/org/apache/iotdb/db/auth/entity/Role.java | 0 .../java/org/apache/iotdb/db/auth/entity/User.java | 0 .../iotdb/db/auth/role/BasicRoleManager.java | 0 .../apache/iotdb/db/auth/role/IRoleAccessor.java | 0 .../apache/iotdb/db/auth/role/IRoleManager.java | 0 .../iotdb/db/auth/role/LocalFileRoleAccessor.java | 0 .../iotdb/db/auth/role/LocalFileRoleManager.java | 0 .../iotdb/db/auth/user/BasicUserManager.java | 0 .../apache/iotdb/db/auth/user/IUserAccessor.java | 0 .../apache/iotdb/db/auth/user/IUserManager.java | 0 .../iotdb/db/auth/user/LocalFileUserAccessor.java | 0 .../iotdb/db/auth/user/LocalFileUserManager.java | 0 .../org/apache/iotdb/db/concurrent/HashLock.java | 0 .../IoTDBDefaultThreadExceptionHandler.java | 0 .../db/concurrent/IoTDBThreadPoolFactory.java | 0 .../iotdb/db/concurrent/IoTThreadFactory.java | 0 .../org/apache/iotdb/db/concurrent/ThreadName.java | 0 .../iotdb/db/concurrent/WrappedRunnable.java | 1 - .../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 58 +- .../org/apache/iotdb/db/conf/IoTDBConfigCheck.java | 17 + .../org/apache/iotdb/db/conf/IoTDBConstant.java | 1 + .../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 69 +- .../iotdb/db/conf/ServerConfigConsistent.java | 0 .../db/conf/adapter/ActiveTimeSeriesCounter.java | 0 .../iotdb/db/conf/adapter/CompressionRatio.java | 0 .../db/conf/adapter/IActiveTimeSeriesCounter.java | 0 .../iotdb/db/conf/adapter/IDynamicAdapter.java | 0 .../db/conf/adapter/IoTDBConfigDynamicAdapter.java | 24 +- .../db/conf/adapter/ManageDynamicParameters.java | 0 .../conf/adapter/ManageDynamicParametersMBean.java | 0 .../db/conf/directories/DirectoryManager.java | 0 .../directories/strategy/DirectoryStrategy.java | 0 .../strategy/MaxDiskUsableSpaceFirstStrategy.java | 0 .../MinFolderOccupiedSpaceFirstStrategy.java | 0 .../strategy/RandomOnDiskUsableSpaceStrategy.java | 0 .../directories/strategy/SequenceStrategy.java | 0 .../db/cost/statistic/ConcurrentCircularArray.java | 0 .../iotdb/db/cost/statistic/Measurement.java | 0 .../iotdb/db/cost/statistic/MeasurementMBean.java | 0 .../apache/iotdb/db/cost/statistic/Operation.java | 0 .../org/apache/iotdb/db/engine/StorageEngine.java | 10 +- .../db/engine/cache/CacheHitRatioMonitor.java | 6 - .../engine/cache/CacheHitRatioMonitorMXBean.java | 2 - .../apache/iotdb/db/engine/cache/ChunkCache.java | 4 +- .../iotdb/db/engine/cache/ChunkMetadataCache.java | 11 +- .../iotdb/db/engine/cache/LRULinkedHashMap.java | 0 .../iotdb/db/engine/cache/RamUsageEstimator.java | 0 .../db/engine/cache/TimeSeriesMetadataCache.java | 83 +- .../iotdb/db/engine/cache/TsFileMetaDataCache.java | 174 ---- .../db/engine/fileSystem/SystemFileFactory.java | 0 .../apache/iotdb/db/engine/flush/FlushManager.java | 0 .../iotdb/db/engine/flush/FlushManagerMBean.java | 0 .../iotdb/db/engine/flush/MemTableFlushTask.java | 0 .../iotdb/db/engine/flush/NotifyFlushMemTable.java | 0 .../iotdb/db/engine/flush/TsFileFlushPolicy.java | 0 .../db/engine/flush/pool/AbstractPoolManager.java | 0 .../engine/flush/pool/FlushSubTaskPoolManager.java | 0 .../db/engine/flush/pool/FlushTaskPoolManager.java | 0 .../iotdb/db/engine/memtable/AbstractMemTable.java | 24 +- .../apache/iotdb/db/engine/memtable/IMemTable.java | 6 +- .../db/engine/memtable/IWritableMemChunk.java | 0 .../db/engine/memtable/PrimitiveMemTable.java | 0 .../iotdb/db/engine/memtable/WritableMemChunk.java | 0 .../iotdb/db/engine/merge/BaseFileSelector.java | 0 .../iotdb/db/engine/merge/BaseMergeSeriesTask.java | 177 +++- .../iotdb/db/engine/merge/IMergeFileSelector.java | 0 .../iotdb/db/engine/merge/IRecoverMergeTask.java | 0 .../iotdb/db/engine/merge/MergeCallback.java | 0 .../apache/iotdb/db/engine/merge/MergeLogger.java | 0 .../iotdb/db/engine/merge/manage/MergeContext.java | 0 .../iotdb/db/engine/merge/manage/MergeManager.java | 0 .../db/engine/merge/manage/MergeResource.java | 18 + .../apache/iotdb/db/engine/merge/package-info.java | 0 .../merge/seqMerge/SeqMergeFileStrategy.java | 0 .../inplace/recover/InplaceMergeLogger.java | 0 .../seqMerge/inplace/recover/LogAnalyzer.java | 0 .../inplace/selector/InplaceMaxFileSelector.java | 0 .../seqMerge/inplace/task/InplaceMergeTask.java | 0 .../merge/seqMerge/inplace/task/MergeFileTask.java | 27 +- .../seqMerge/inplace/task/MergeMultiChunkTask.java | 0 .../inplace/task/RecoverInplaceMergeTask.java | 0 .../seqMerge/squeeze/recover/LogAnalyzer.java | 10 +- .../squeeze/recover/SqueezeMergeLogger.java | 0 .../squeeze/selector/SqueezeMaxFileSelector.java | 0 .../seqMerge/squeeze/task/MergeSeriesTask.java | 184 +--- .../squeeze/task/RecoverSqueezeMergeTask.java | 0 .../seqMerge/squeeze/task/SqueezeMergeTask.java | 27 + ...FileSelector.java => BaseSizeFileSelector.java} | 92 +- .../merge/sizeMerge/MergeSizeSelectorStrategy.java | 31 + .../merge/sizeMerge/SizeMergeFileStrategy.java | 0 .../recover/IndependenceMergeLogger.java | 0 .../independence/recover/LogAnalyzer.java | 0 .../selector/IndependenceMaxFileSelector.java | 125 +-- .../task/IndependenceMergeSeriesTask.java | 116 +++ .../independence/task/IndependenceMergeTask.java | 24 +- .../independence/task/MergeSeriesTask.java | 137 --- .../task/RecoverIndependenceMergeTask.java | 0 .../regularization/recover/LogAnalyzer.java | 11 +- .../recover/RegularizationMergeLogger.java | 0 .../selector/RegularizationMaxFileSelector.java | 126 +-- .../regularization/task/MergeSeriesTask.java | 142 --- .../task/RecoverRegularizationMergeTask.java | 2 +- .../task/RegularizationMergeSeriesTask.java | 106 +++ .../task/RegularizationMergeTask.java | 30 +- .../engine/merge/utils/MergeFileSelectorUtils.java | 0 .../db/engine/merge/utils/MergeMemCalculator.java | 0 .../db/engine/merge/utils/SelectorContext.java | 0 .../iotdb/db/engine/modification/Deletion.java | 0 .../iotdb/db/engine/modification/Modification.java | 0 .../db/engine/modification/ModificationFile.java | 0 .../io/LocalTextModificationAccessor.java | 0 .../engine/modification/io/ModificationReader.java | 0 .../engine/modification/io/ModificationWriter.java | 0 .../iotdb/db/engine/modification/package-info.java | 0 .../db/engine/querycontext/QueryDataSource.java | 0 .../db/engine/querycontext/ReadOnlyMemChunk.java | 0 .../engine/storagegroup/StorageGroupProcessor.java | 201 +++-- .../db/engine/storagegroup/TsFileProcessor.java | 30 +- .../db/engine/storagegroup/TsFileResource.java | 44 +- .../db/engine/upgrade/UpgradeCheckStatus.java | 0 .../apache/iotdb/db/engine/upgrade/UpgradeLog.java | 0 .../iotdb/db/engine/upgrade/UpgradeTask.java | 0 .../version/SimpleFileVersionController.java | 0 .../engine/version/SysTimeVersionController.java | 0 .../iotdb/db/engine/version/VersionController.java | 0 .../db/exception/ConfigAdjusterException.java | 0 .../exception/DiskSpaceInsufficientException.java | 0 .../apache/iotdb/db/exception/IoTDBException.java | 0 .../db/exception/LoadConfigurationException.java | 0 .../iotdb/db/exception/LoadEmptyFileException.java | 0 .../iotdb/db/exception/LoadFileException.java | 0 .../apache/iotdb/db/exception/MergeException.java | 0 .../db/exception/PartitionViolationException.java | 0 .../exception/QueryInBatchStatementException.java | 0 .../iotdb/db/exception/StartupException.java | 0 .../iotdb/db/exception/StorageEngineException.java | 0 .../exception/StorageGroupProcessorException.java | 0 .../db/exception/SyncConnectionException.java | 0 .../SyncDeviceOwnerConflictException.java | 0 .../iotdb/db/exception/SystemCheckException.java | 0 .../db/exception/TsFileProcessorException.java | 0 .../iotdb/db/exception/WriteProcessException.java | 0 ...eption.java => AliasAlreadyExistException.java} | 12 +- ...stException.java => DeleteFailedException.java} | 17 +- .../exception/metadata/IllegalPathException.java | 0 .../db/exception/metadata/MetadataException.java | 2 +- .../metadata/PathAlreadyExistException.java | 0 .../exception/metadata/PathNotExistException.java | 0 .../metadata/StorageGroupAlreadySetException.java | 0 .../metadata/StorageGroupNotSetException.java | 0 .../exception/query/LogicalOperatorException.java | 0 .../exception/query/LogicalOptimizeException.java | 0 .../db/exception/query/OutOfTTLException.java | 0 .../iotdb/db/exception/query/PathException.java | 0 .../db/exception/query/QueryProcessException.java | 0 .../query/UnSupportedFillTypeException.java | 0 .../exception/runtime/FlushRunTimeException.java | 0 .../db/exception/runtime/RPCServiceException.java | 0 .../db/exception/runtime/SQLParserException.java | 0 .../runtime/StorageEngineFailureException.java | 0 .../org/apache/iotdb/db/metadata/MLogWriter.java | 170 ++++ .../org/apache/iotdb/db/metadata/MManager.java | 993 +++++++++++++++------ .../java/org/apache/iotdb/db/metadata/MTree.java | 241 +++-- .../org/apache/iotdb/db/metadata/MetaUtils.java | 14 +- .../org/apache/iotdb/db/metadata/Metadata.java | 0 .../apache/iotdb/db/metadata/MetadataConstant.java | 1 + .../iotdb/db/metadata/MetadataOperationType.java | 1 + .../org/apache/iotdb/db/metadata/TagLogFile.java | 159 ++++ .../iotdb/db/metadata/mnode/InternalMNode.java | 74 +- .../apache/iotdb/db/metadata/mnode/LeafMNode.java | 48 +- .../org/apache/iotdb/db/metadata/mnode/MNode.java | 23 +- .../iotdb/db/metadata/mnode/StorageGroupMNode.java | 0 .../apache/iotdb/db/metrics/server/JettyUtil.java | 0 .../iotdb/db/metrics/server/MetricsSystem.java | 0 .../iotdb/db/metrics/server/QueryServlet.java | 0 .../iotdb/db/metrics/server/ServerArgument.java | 0 .../iotdb/db/metrics/server/SqlArgument.java | 0 .../apache/iotdb/db/metrics/sink/ConsoleSink.java | 0 .../iotdb/db/metrics/sink/MetricsServletSink.java | 0 .../org/apache/iotdb/db/metrics/sink/Sink.java | 0 .../apache/iotdb/db/metrics/source/JvmSource.java | 0 .../iotdb/db/metrics/source/MetricsSource.java | 0 .../org/apache/iotdb/db/metrics/source/Source.java | 0 .../apache/iotdb/db/metrics/ui/MetricsPage.java | 0 .../apache/iotdb/db/metrics/ui/MetricsWebUI.java | 0 .../org/apache/iotdb/db/monitor/IStatistic.java | 0 .../apache/iotdb/db/monitor/MonitorConstants.java | 0 .../org/apache/iotdb/db/monitor/StatMonitor.java | 0 .../iotdb/db/monitor/collector/FileSize.java | 0 .../monitor/collector/MemTableWriteTimeCost.java | 0 .../apache/iotdb/db/mqtt/BrokerAuthenticator.java | 0 .../apache/iotdb/db/mqtt/JSONPayloadFormatter.java | 0 .../java/org/apache/iotdb/db/mqtt/Message.java | 0 .../apache/iotdb/db/mqtt/PayloadFormatManager.java | 0 .../org/apache/iotdb/db/mqtt/PayloadFormatter.java | 0 .../org/apache/iotdb/db/mqtt/PublishHandler.java | 7 +- .../main/java/org/apache/iotdb/db/qp/Planner.java | 8 +- .../apache/iotdb/db/qp/constant/DatetimeUtils.java | 0 .../apache/iotdb/db/qp/constant/SQLConstant.java | 11 +- .../apache/iotdb/db/qp/executor/IPlanExecutor.java | 8 +- .../apache/iotdb/db/qp/executor/PlanExecutor.java | 480 +++++++--- .../org/apache/iotdb/db/qp/logical/Operator.java | 3 +- .../apache/iotdb/db/qp/logical/RootOperator.java | 1 - .../db/qp/logical/crud/BasicFunctionOperator.java | 0 .../db/qp/logical/crud/BasicOperatorType.java | 0 .../db/qp/logical/crud/DeleteDataOperator.java | 0 .../iotdb/db/qp/logical/crud/FilterOperator.java | 0 .../iotdb/db/qp/logical/crud/FromOperator.java | 0 .../iotdb/db/qp/logical/crud/FunctionOperator.java | 0 .../iotdb/db/qp/logical/crud/InOperator.java | 0 .../iotdb/db/qp/logical/crud/InsertOperator.java | 0 .../iotdb/db/qp/logical/crud/QueryOperator.java | 2 +- .../iotdb/db/qp/logical/crud/SFWOperator.java | 0 .../iotdb/db/qp/logical/crud/SelectOperator.java | 0 .../iotdb/db/qp/logical/crud/UpdateOperator.java | 0 .../db/qp/logical/sys/AlterTimeSeriesOperator.java | 97 ++ .../iotdb/db/qp/logical/sys/AuthorOperator.java | 0 .../iotdb/db/qp/logical/sys/CountOperator.java | 0 .../qp/logical/sys/CreateTimeSeriesOperator.java | 31 +- .../iotdb/db/qp/logical/sys/DataAuthOperator.java | 0 .../qp/logical/sys/DeleteStorageGroupOperator.java | 0 .../qp/logical/sys/DeleteTimeSeriesOperator.java | 0 ...eTimeSeriesOperator.java => FlushOperator.java} | 36 +- .../qp/logical/sys/LoadConfigurationOperator.java | 0 .../iotdb/db/qp/logical/sys/LoadDataOperator.java | 0 .../iotdb/db/qp/logical/sys/LoadFilesOperator.java | 0 .../sys/{ShowOperator.java => MergeOperator.java} | 19 +- .../iotdb/db/qp/logical/sys/MoveFileOperator.java | 0 .../db/qp/logical/sys/RemoveFileOperator.java | 0 .../db/qp/logical/sys/SetStorageGroupOperator.java | 0 .../iotdb/db/qp/logical/sys/SetTTLOperator.java | 0 .../db/qp/logical/sys/ShowChildPathsOperator.java | 0 .../db/qp/logical/sys/ShowDevicesOperator.java | 0 .../iotdb/db/qp/logical/sys/ShowOperator.java | 0 .../iotdb/db/qp/logical/sys/ShowTTLOperator.java | 0 .../db/qp/logical/sys/ShowTimeSeriesOperator.java | 45 + .../apache/iotdb/db/qp/physical/PhysicalPlan.java | 4 +- .../iotdb/db/qp/physical/crud/AggregationPlan.java | 0 .../db/qp/physical/crud/AlignByDevicePlan.java | 0 .../iotdb/db/qp/physical/crud/DeletePlan.java | 0 .../iotdb/db/qp/physical/crud/FillQueryPlan.java | 2 +- .../iotdb/db/qp/physical/crud/GroupByFillPlan.java | 2 +- .../iotdb/db/qp/physical/crud/GroupByPlan.java | 0 .../iotdb/db/qp/physical/crud/InsertPlan.java | 0 ...{BatchInsertPlan.java => InsertTabletPlan.java} | 24 +- .../iotdb/db/qp/physical/crud/LastQueryPlan.java | 0 .../iotdb/db/qp/physical/crud/QueryPlan.java | 2 +- .../db/qp/physical/crud/RawDataQueryPlan.java | 16 +- .../iotdb/db/qp/physical/crud/UpdatePlan.java | 0 .../db/qp/physical/sys/AlterTimeSeriesPlan.java | 86 ++ .../iotdb/db/qp/physical/sys/AuthorPlan.java | 0 .../apache/iotdb/db/qp/physical/sys/CountPlan.java | 0 .../db/qp/physical/sys/CreateTimeSeriesPlan.java | 100 ++- .../iotdb/db/qp/physical/sys/DataAuthPlan.java | 0 .../db/qp/physical/sys/DeleteStorageGroupPlan.java | 0 .../db/qp/physical/sys/DeleteTimeSeriesPlan.java | 0 .../{LoadConfigurationPlan.java => FlushPlan.java} | 25 +- .../db/qp/physical/sys/LoadConfigurationPlan.java | 0 .../iotdb/db/qp/physical/sys/LoadDataPlan.java | 0 .../sys/{DataAuthPlan.java => MergePlan.java} | 14 +- .../iotdb/db/qp/physical/sys/OperateFilePlan.java | 0 .../db/qp/physical/sys/SetStorageGroupPlan.java | 0 .../iotdb/db/qp/physical/sys/SetTTLPlan.java | 0 .../db/qp/physical/sys/ShowChildPathsPlan.java | 0 .../iotdb/db/qp/physical/sys/ShowDevicesPlan.java | 0 .../apache/iotdb/db/qp/physical/sys/ShowPlan.java | 0 .../iotdb/db/qp/physical/sys/ShowTTLPlan.java | 0 .../db/qp/physical/sys/ShowTimeSeriesPlan.java | 47 +- .../iotdb/db/qp/strategy/LogicalGenerator.java | 199 ++++- .../db/qp/strategy/LogicalGeneratorError.java | 0 .../apache/iotdb/db/qp/strategy/ParseDriver.java | 0 .../iotdb/db/qp/strategy/PhysicalGenerator.java | 280 ++++-- .../qp/strategy/optimizer/ConcatPathOptimizer.java | 27 +- .../qp/strategy/optimizer/DnfFilterOptimizer.java | 0 .../db/qp/strategy/optimizer/IFilterOptimizer.java | 0 .../qp/strategy/optimizer/ILogicalOptimizer.java | 0 .../optimizer/MergeSingleFilterOptimizer.java | 0 .../qp/strategy/optimizer/RemoveNotOptimizer.java | 0 .../db/query/aggregation/AggregateResult.java | 0 .../db/query/aggregation/AggregationType.java | 0 .../db/query/aggregation/impl/AvgAggrResult.java | 0 .../db/query/aggregation/impl/CountAggrResult.java | 0 .../aggregation/impl/FirstValueAggrResult.java | 0 .../aggregation/impl/LastValueAggrResult.java | 0 .../query/aggregation/impl/MaxTimeAggrResult.java | 0 .../query/aggregation/impl/MaxValueAggrResult.java | 0 .../query/aggregation/impl/MinTimeAggrResult.java | 0 .../query/aggregation/impl/MinValueAggrResult.java | 0 .../db/query/aggregation/impl/SumAggrResult.java | 0 .../iotdb/db/query/context/QueryContext.java | 0 .../iotdb/db/query/control/FileReaderManager.java | 0 .../iotdb/db/query/control/QueryFileManager.java | 0 .../db/query/control/QueryResourceManager.java | 0 .../db/query/dataset/AlignByDeviceDataSet.java | 0 .../apache/iotdb/db/query/dataset/ListDataSet.java | 0 .../db/query/dataset/NonAlignEngineDataSet.java | 0 .../dataset/RawQueryDataSetWithValueFilter.java | 0 .../dataset/RawQueryDataSetWithoutValueFilter.java | 0 .../db/query/dataset/ShowTimeSeriesResult.java | 71 ++ .../iotdb/db/query/dataset/SingleDataSet.java | 0 .../dataset/groupby/GroupByEngineDataSet.java | 0 .../db/query/dataset/groupby/GroupByExecutor.java | 0 .../query/dataset/groupby/GroupByFillDataSet.java | 7 +- .../groupby/GroupByWithValueFilterDataSet.java | 0 .../groupby/GroupByWithoutValueFilterDataSet.java | 0 .../dataset/groupby/LocalGroupByExecutor.java | 98 +- .../db/query/executor/AggregationExecutor.java | 31 +- .../iotdb/db/query/executor/FillQueryExecutor.java | 4 +- .../iotdb/db/query/executor/IQueryRouter.java | 0 .../iotdb/db/query/executor/LastQueryExecutor.java | 28 +- .../iotdb/db/query/executor/QueryRouter.java | 2 +- .../db/query/executor/RawDataQueryExecutor.java | 0 .../iotdb/db/query/{ => executor}/fill/IFill.java | 16 +- .../fill/LastPointReader.java} | 97 +- .../db/query/{ => executor}/fill/LinearFill.java | 93 +- .../iotdb/db/query/executor/fill/PreviousFill.java | 115 +++ .../db/query/externalsort/ExternalSortJob.java | 0 .../query/externalsort/ExternalSortJobEngine.java | 0 .../db/query/externalsort/ExternalSortJobPart.java | 0 .../externalsort/ExternalSortJobScheduler.java | 0 .../iotdb/db/query/externalsort/LineMerger.java | 0 .../MultiSourceExternalSortJobPart.java | 0 .../externalsort/SimpleExternalSortEngine.java | 0 .../SingleSourceExternalSortJobPart.java | 0 .../adapter/ByTimestampReaderAdapter.java | 0 .../serialize/IExternalSortFileDeserializer.java | 0 .../serialize/IExternalSortFileSerializer.java | 0 .../FixLengthIExternalSortFileDeserializer.java | 0 .../impl/FixLengthTimeValuePairSerializer.java | 0 .../db/query/factory/AggregateResultFactory.java | 0 .../apache/iotdb/db/query/filter/TsFileFilter.java | 0 .../iotdb/db/query/pool/QueryTaskPoolManager.java | 0 .../db/query/reader/chunk/ChunkDataIterator.java | 0 .../db/query/reader/chunk/ChunkReaderWrap.java | 0 .../db/query/reader/chunk/DiskChunkLoader.java | 0 .../reader/chunk/DiskChunkReaderByTimestamp.java | 0 .../db/query/reader/chunk/MemChunkLoader.java | 0 .../db/query/reader/chunk/MemChunkReader.java | 0 .../iotdb/db/query/reader/chunk/MemPageReader.java | 5 + .../chunk/metadata/DiskChunkMetadataLoader.java | 0 .../chunk/metadata/MemChunkMetadataLoader.java | 0 .../resource/CachedUnseqResourceMergeReader.java | 0 .../db/query/reader/series/IAggregateReader.java | 0 .../db/query/reader/series/IReaderByTimestamp.java | 0 .../query/reader/series/ManagedSeriesReader.java | 0 .../query/reader/series/SeriesAggregateReader.java | 19 +- .../reader/series/SeriesRawDataBatchReader.java | 24 +- .../reader/series/SeriesRawDataPointReader.java | 0 .../iotdb/db/query/reader/series/SeriesReader.java | 164 ++-- .../reader/series/SeriesReaderByTimestamp.java | 0 .../universal/CachedPriorityMergeReader.java | 0 .../reader/universal/PriorityMergeReader.java | 0 .../query/timegenerator/ServerTimeGenerator.java | 5 +- .../org/apache/iotdb/db/rescon/MemTablePool.java | 0 .../apache/iotdb/db/rescon/PrimitiveArrayPool.java | 0 .../apache/iotdb/db/rescon/TVListAllocator.java | 0 .../iotdb/db/rescon/TVListAllocatorMBean.java | 0 .../org/apache/iotdb/db/rescon/package-info.java | 0 .../java/org/apache/iotdb/db/service/IService.java | 0 .../java/org/apache/iotdb/db/service/IoTDB.java | 0 .../org/apache/iotdb/db/service/IoTDBMBean.java | 0 .../apache/iotdb/db/service/IoTDBShutdownHook.java | 0 .../org/apache/iotdb/db/service/JMXService.java | 0 .../org/apache/iotdb/db/service/MQTTService.java | 0 .../apache/iotdb/db/service/MetricsService.java | 0 .../iotdb/db/service/MetricsServiceMBean.java | 0 .../java/org/apache/iotdb/db/service/Monitor.java | 0 .../org/apache/iotdb/db/service/MonitorMBean.java | 0 .../org/apache/iotdb/db/service/RPCService.java | 0 .../apache/iotdb/db/service/RPCServiceMBean.java | 0 .../apache/iotdb/db/service/RegisterManager.java | 0 .../org/apache/iotdb/db/service/ServiceType.java | 0 .../org/apache/iotdb/db/service/StartupCheck.java | 0 .../org/apache/iotdb/db/service/StartupChecks.java | 0 .../org/apache/iotdb/db/service/StaticResps.java | 0 .../org/apache/iotdb/db/service/TSServiceImpl.java | 382 +++++--- .../org/apache/iotdb/db/service/UpgradeSevice.java | 0 .../apache/iotdb/db/sync/conf/SyncConstant.java | 0 .../iotdb/db/sync/conf/SyncSenderConfig.java | 0 .../iotdb/db/sync/conf/SyncSenderDescriptor.java | 0 .../org/apache/iotdb/db/sync/package-info.java | 0 .../iotdb/db/sync/receiver/SyncServerManager.java | 0 .../iotdb/db/sync/receiver/load/FileLoader.java | 0 .../db/sync/receiver/load/FileLoaderManager.java | 0 .../iotdb/db/sync/receiver/load/IFileLoader.java | 0 .../iotdb/db/sync/receiver/load/ILoadLogger.java | 0 .../iotdb/db/sync/receiver/load/LoadLogger.java | 0 .../iotdb/db/sync/receiver/load/LoadType.java | 0 .../receiver/recover/ISyncReceiverLogAnalyzer.java | 0 .../sync/receiver/recover/ISyncReceiverLogger.java | 0 .../receiver/recover/SyncReceiverLogAnalyzer.java | 0 .../sync/receiver/recover/SyncReceiverLogger.java | 0 .../db/sync/receiver/transfer/SyncServiceImpl.java | 0 .../db/sync/sender/manage/ISyncFileManager.java | 0 .../db/sync/sender/manage/SyncFileManager.java | 0 .../sender/recover/ISyncSenderLogAnalyzer.java | 0 .../db/sync/sender/recover/ISyncSenderLogger.java | 0 .../sync/sender/recover/SyncSenderLogAnalyzer.java | 0 .../db/sync/sender/recover/SyncSenderLogger.java | 0 .../iotdb/db/sync/sender/transfer/ISyncClient.java | 0 .../iotdb/db/sync/sender/transfer/SyncClient.java | 0 .../apache/iotdb/db/tools/IoTDBDataDirViewer.java | 0 .../iotdb/db/tools/TsFileResourcePrinter.java | 0 .../apache/iotdb/db/tools/TsFileSketchTool.java | 142 +-- .../java/org/apache/iotdb/db/tools/WalChecker.java | 0 .../apache/iotdb/db/tools/logvisual/LogEntry.java | 0 .../apache/iotdb/db/tools/logvisual/LogFilter.java | 0 .../apache/iotdb/db/tools/logvisual/LogParser.java | 0 .../iotdb/db/tools/logvisual/LogVisualizer.java | 0 .../iotdb/db/tools/logvisual/PatternLogParser.java | 0 .../db/tools/logvisual/TimeSeriesStatistics.java | 0 .../iotdb/db/tools/logvisual/VisualUtils.java | 0 .../db/tools/logvisual/VisualizationPlan.java | 0 .../db/tools/logvisual/conf/GuiPropertyKeys.java | 0 .../exceptions/NoLogFileLoadedException.java | 0 .../logvisual/exceptions/NoSuchPlanException.java | 0 .../exceptions/UnmatchedContentException.java | 0 .../exceptions/VisualizationException.java | 0 .../db/tools/logvisual/gui/ClosableComboTab.java | 0 .../iotdb/db/tools/logvisual/gui/ClosableTab.java | 0 .../db/tools/logvisual/gui/FileSelectionBox.java | 0 .../db/tools/logvisual/gui/LabeledComboBox.java | 0 .../iotdb/db/tools/logvisual/gui/LoadLogBox.java | 0 .../tools/logvisual/gui/LogVisualizationGui.java | 0 .../iotdb/db/tools/logvisual/gui/MainPanel.java | 0 .../iotdb/db/tools/logvisual/gui/PlanBox.java | 0 .../db/tools/logvisual/gui/PlanDetailPanel.java | 0 .../db/tools/logvisual/gui/ResultPlotTab.java | 0 .../db/tools/logvisual/gui/ResultStatisticTab.java | 0 .../iotdb/db/tools/memestimation/MemEstTool.java | 0 .../db/tools/memestimation/MemEstToolCmd.java | 0 .../watermark/GroupedLSBWatermarkEncoder.java | 0 .../db/tools/watermark/WatermarkDetector.java | 0 .../iotdb/db/tools/watermark/WatermarkEncoder.java | 0 .../java/org/apache/iotdb/db/utils/AuthUtils.java | 22 +- .../org/apache/iotdb/db/utils/CommonUtils.java | 0 .../iotdb/db/utils/CopyOnReadLinkedList.java | 0 .../org/apache/iotdb/db/utils/FileLoaderUtils.java | 40 +- .../org/apache/iotdb/db/utils/FilePathUtils.java | 0 .../java/org/apache/iotdb/db/utils/FileUtils.java | 0 .../java/org/apache/iotdb/db/utils/IOUtils.java | 0 .../java/org/apache/iotdb/db/utils/MathUtils.java | 0 .../java/org/apache/iotdb/db/utils/MemUtils.java | 56 +- .../java/org/apache/iotdb/db/utils/MergeUtils.java | 45 +- .../org/apache/iotdb/db/utils/OpenFileNumUtil.java | 0 .../apache/iotdb/db/utils/QueryDataSetUtils.java | 0 .../java/org/apache/iotdb/db/utils/QueryUtils.java | 2 +- .../apache/iotdb/db/utils/RandomDeleteCache.java | 0 .../org/apache/iotdb/db/utils/SchemaUtils.java | 0 .../java/org/apache/iotdb/db/utils/SyncUtils.java | 0 .../java/org/apache/iotdb/db/utils/TestOnly.java | 0 .../apache/iotdb/db/utils/TimeValuePairUtils.java | 0 .../apache/iotdb/db/utils/TypeInferenceUtils.java | 0 .../org/apache/iotdb/db/utils/UpgradeUtils.java | 0 .../iotdb/db/utils/datastructure/BinaryTVList.java | 0 .../db/utils/datastructure/BooleanTVList.java | 0 .../iotdb/db/utils/datastructure/DoubleTVList.java | 0 .../iotdb/db/utils/datastructure/FloatTVList.java | 0 .../iotdb/db/utils/datastructure/IntTVList.java | 0 .../iotdb/db/utils/datastructure/LongTVList.java | 0 .../iotdb/db/utils/datastructure/TVList.java | 0 .../iotdb/db/writelog/io/BatchLogReader.java | 0 .../apache/iotdb/db/writelog/io/ILogReader.java | 0 .../apache/iotdb/db/writelog/io/ILogWriter.java | 0 .../org/apache/iotdb/db/writelog/io/LogWriter.java | 0 .../iotdb/db/writelog/io/MultiFileLogReader.java | 0 .../iotdb/db/writelog/io/SingleFileLogReader.java | 0 .../writelog/manager/MultiFileLogNodeManager.java | 0 .../db/writelog/manager/WriteLogNodeManager.java | 0 .../db/writelog/node/ExclusiveWriteLogNode.java | 8 +- .../iotdb/db/writelog/node/WriteLogNode.java | 0 .../iotdb/db/writelog/recover/LogReplayer.java | 31 +- .../writelog/recover/TsFileRecoverPerformer.java | 30 +- .../org.apache.iotdb.db.mqtt.PayloadFormatter | 0 .../src/main/resources/iotdb/ui/static/index.html | 0 .../main/resources/iotdb/ui/static/iotdb-logo.png | Bin .../src/main/resources/iotdb/ui/static/webui.css | 0 .../iotdb/db/auth/LocalFileAuthorizerTest.java | 0 .../iotdb/db/auth/LocalFileRoleAccessorTest.java | 0 .../iotdb/db/auth/LocalFileRoleManagerTest.java | 0 .../iotdb/db/auth/LocalFileUserAccessorTest.java | 0 .../iotdb/db/auth/LocalFileUserManagerTest.java | 0 .../IoTDBDefaultThreadExceptionHandlerTest.java | 0 .../db/concurrent/IoTDBThreadPoolFactoryTest.java | 0 .../conf/adapter/ActiveTimeSeriesCounterTest.java | 0 .../db/conf/adapter/CompressionRatioTest.java | 0 .../iotdb/db/conf/adapter/HyperLogLogTest.java | 0 .../adapter/IoTDBConfigDynamicAdapterTest.java | 0 .../strategy/DirectoryStrategyTest.java | 0 .../org/apache/iotdb/db/constant/TestConstant.java | 0 .../db/cost/statistic/PerformanceStatTest.java | 0 .../iotdb/db/engine/MetadataManagerHelper.java | 4 +- .../db/engine/cache/ChunkMetadataCacheTest.java | 0 .../db/engine/memtable/MemTableFlushTaskTest.java | 0 .../iotdb/db/engine/memtable/MemTablePoolTest.java | 0 .../db/engine/memtable/MemTableTestUtils.java | 0 .../db/engine/memtable/MemtableBenchmark.java | 0 .../db/engine/memtable/PrimitiveMemTableTest.java | 0 .../apache/iotdb/db/engine/merge/MergeTest.java | 2 - .../inplace/MaxFileMergeFileSelectorTest.java | 0 .../merge/seqMerge/inplace/MergeLogTest.java | 0 .../merge/seqMerge/inplace/MergePerfTest.java | 0 .../merge/seqMerge/inplace/MergeTaskTest.java | 0 .../squeeze/MaxFileMergeFileSelectorTest.java | 0 .../merge/seqMerge/squeeze/MergeLogTest.java | 0 .../merge/seqMerge/squeeze/MergeTaskTest.java | 3 + .../independence/MaxFileMergeFileSelectorTest.java | 10 - .../merge/sizeMerge/independence/MergeLogTest.java | 2 +- .../sizeMerge/independence/MergeTaskTest.java | 6 +- .../MaxFileMergeFileSelectorTest.java | 23 +- .../sizeMerge/regularization/MergeLogTest.java | 0 .../sizeMerge/regularization/MergeTaskTest.java | 4 +- .../engine/modification/DeletionFileNodeTest.java | 23 +- .../db/engine/modification/DeletionQueryTest.java | 36 +- .../engine/modification/ModificationFileTest.java | 0 .../io/LocalTextModificationAccessorTest.java | 0 .../storagegroup/FileNodeManagerBenchmark.java | 7 +- .../storagegroup/StorageGroupProcessorTest.java | 31 +- .../iotdb/db/engine/storagegroup/TTLTest.java | 0 .../engine/storagegroup/TsFileProcessorTest.java | 0 .../version/SimpleFileVersionControllerTest.java | 0 .../version/SysTimeVersionControllerTest.java | 0 .../iotdb/db/integration/IOTDBGroupByIT.java | 0 .../integration/IOTDBGroupByInnerIntervalIT.java | 0 .../db/integration/IoTDBAggregationDeleteIT.java | 0 .../iotdb/db/integration/IoTDBAggregationIT.java | 36 +- .../integration/IoTDBAggregationLargeDataIT.java | 0 .../integration/IoTDBAggregationSmallDataIT.java | 0 .../apache/iotdb/db/integration/IoTDBAliasIT.java | 273 ++++++ .../iotdb/db/integration/IoTDBAlignByDeviceIT.java | 0 .../iotdb/db/integration/IoTDBAuthorizationIT.java | 0 .../db/integration/IoTDBAutoCreateSchemaIT.java | 0 .../apache/iotdb/db/integration/IoTDBCloseIT.java | 0 .../iotdb/db/integration/IoTDBCompleteIT.java | 0 .../apache/iotdb/db/integration/IoTDBDaemonIT.java | 0 .../db/integration/IoTDBDeleteStorageGroupIT.java | 0 .../iotdb/db/integration/IoTDBDeletionIT.java | 3 +- .../iotdb/db/integration/IoTDBDisableAlignIT.java | 0 .../db/integration/IoTDBEngineTimeGeneratorIT.java | 37 +- .../apache/iotdb/db/integration/IoTDBFillIT.java | 52 +- .../db/integration/IoTDBFloatPrecisionIT.java | 0 .../db/integration/IoTDBFlushQueryMergeIT.java | 0 .../iotdb/db/integration/IoTDBGroupByFillIT.java | 60 +- .../iotdb/db/integration/IoTDBLargeDataIT.java | 0 .../apache/iotdb/db/integration/IoTDBLastIT.java | 8 +- .../iotdb/db/integration/IoTDBLimitSlimitIT.java | 0 .../db/integration/IoTDBLoadExternalTsfileIT.java | 27 +- .../iotdb/db/integration/IoTDBMergeTest.java | 0 .../iotdb/db/integration/IoTDBMetadataFetchIT.java | 18 +- .../IoTDBMultiOverlappedChunkInUnseqIT.java | 17 +- .../db/integration/IoTDBMultiOverlappedPageIT.java | 42 +- .../iotdb/db/integration/IoTDBMultiSeriesIT.java | 0 .../db/integration/IoTDBMultiStatementsIT.java | 0 .../iotdb/db/integration/IoTDBNumberPathIT.java | 0 .../db/integration/IoTDBOverlappedPageIT.java | 0 .../iotdb/db/integration/IoTDBQueryDemoIT.java | 0 .../iotdb/db/integration/IoTDBQuotedPathIT.java | 0 .../iotdb/db/integration/IoTDBRecoverIT.java | 0 .../iotdb/db/integration/IoTDBRestartIT.java | 0 .../IoTDBSameMeasurementsDifferentTypesIT.java | 0 .../db/integration/IoTDBSequenceDataQueryIT.java | 0 .../iotdb/db/integration/IoTDBSeriesReaderIT.java | 0 .../iotdb/db/integration/IoTDBSimpleQueryIT.java | 27 + .../iotdb/db/integration/IoTDBTagAlterIT.java | 455 ++++++++++ .../apache/iotdb/db/integration/IoTDBTagIT.java | 922 +++++++++++++++++++ .../iotdb/db/integration/IoTDBTimeZoneIT.java | 0 .../apache/iotdb/db/integration/IoTDBTtlIT.java | 0 .../iotdb/db/integration/IoTDBVersionIT.java | 0 .../iotdb/db/metadata/MManagerAdvancedTest.java | 56 +- .../iotdb/db/metadata/MManagerBasicTest.java | 0 .../iotdb/db/metadata/MManagerImproveTest.java | 30 +- .../org/apache/iotdb/db/metadata/MTreeTest.java | 147 ++- .../iotdb/db/monitor/collector/FileSizeTest.java | 0 .../iotdb/db/mqtt/BrokerAuthenticatorTest.java | 0 .../iotdb/db/mqtt/JSONPayloadFormatTest.java | 0 .../iotdb/db/mqtt/PayloadFormatManagerTest.java | 0 .../apache/iotdb/db/mqtt/PublishHandlerTest.java | 0 .../java/org/apache/iotdb/db/qp/PlannerTest.java | 0 .../iotdb/db/qp/bench/QueryParseBenchmark.java | 0 .../iotdb/db/qp/other/TSPlanContextAuthorTest.java | 0 .../iotdb/db/qp/plan/ConcatOptimizerTest.java | 0 .../iotdb/db/qp/plan/LogicalPlanSmallTest.java | 15 +- .../apache/iotdb/db/qp/plan/PhysicalPlanTest.java | 32 +- .../iotdb/db/qp/strategy/LogicalGeneratorTest.java | 0 .../db/query/aggregation/AggregateResultTest.java | 0 .../db/query/control/FileReaderManagerTest.java | 0 .../db/query/control/QueryResourceManagerTest.java | 0 .../dataset/EngineDataSetWithValueFilterTest.java | 0 .../query/executor/GroupByEngineDataSetTest.java | 0 .../query/externalsort/ExternalSortEngineTest.java | 0 .../db/query/externalsort/FakeChunkReaderWrap.java | 0 ...ExternalSortFileSerializerDeserializerTest.java | 0 .../iotdb/db/query/reader/ReaderTestHelper.java | 0 .../reader/series/SeriesAggregateReaderTest.java | 0 .../reader/series/SeriesReaderByTimestampTest.java | 0 .../db/query/reader/series/SeriesReaderTest.java | 0 .../query/reader/series/SeriesReaderTestUtil.java | 3 - .../query/reader/universal/FakedSeriesReader.java | 0 .../reader/universal/PriorityMergeReaderTest.java | 0 .../reader/universal/PriorityMergeReaderTest2.java | 0 .../org/apache/iotdb/db/script/EnvScriptIT.java | 0 .../apache/iotdb/db/sql/CheckPathValidityTest.java | 49 + .../db/sql/DatetimeQueryDataSetUtilsTest.java | 0 .../db/sync/receiver/load/FileLoaderTest.java | 22 +- .../recover/SyncReceiverLogAnalyzerTest.java | 26 +- .../receiver/recover/SyncReceiverLoggerTest.java | 0 .../db/sync/sender/manage/SyncFileManagerTest.java | 0 .../sender/recover/SyncSenderLogAnalyzerTest.java | 0 .../sync/sender/recover/SyncSenderLoggerTest.java | 0 .../db/sync/sender/transfer/SyncClientTest.java | 0 .../apache/iotdb/db/tools/IoTDBWatermarkTest.java | 0 .../org/apache/iotdb/db/tools/WalCheckerTest.java | 0 .../apache/iotdb/db/utils/EnvironmentUtils.java | 3 - .../iotdb/db/utils/MathQueryDataSetUtilsTest.java | 0 .../apache/iotdb/db/utils/OpenFileNumUtilTest.java | 0 .../java/org/apache/iotdb/db/utils/RandomNum.java | 0 .../iotdb/db/utils/TypeInferenceUtilsTest.java | 0 .../db/utils/datastructure/LongTVListTest.java | 0 .../iotdb/db/writelog/IoTDBLogFileSizeTest.java | 0 .../apache/iotdb/db/writelog/PerformanceTest.java | 21 +- .../iotdb/db/writelog/WriteLogNodeManagerTest.java | 0 .../apache/iotdb/db/writelog/WriteLogNodeTest.java | 0 .../iotdb/db/writelog/io/LogWriterReaderTest.java | 0 .../db/writelog/io/MultiFileLogReaderTest.java | 0 .../iotdb/db/writelog/recover/LogReplayerTest.java | 7 +- ...est.java => RecoverResourceFromReaderTest.java} | 88 +- .../db/writelog/recover/SeqTsFileRecoverTest.java | 8 +- .../writelog/recover/UnseqTsFileRecoverTest.java | 21 +- server/src/test/resources/iotdb-engine.properties | 0 server/src/test/resources/logback.xml | 0 server/src/test/resources/start-sync-test.sh | 0 server/src/test/resources/stop-sync-test.sh | 0 service-rpc/pom.xml | 5 + service-rpc/rpc-changelist.md | 69 +- .../apache/iotdb/rpc/BatchExecutionException.java | 0 .../apache/iotdb/rpc/IoTDBConnectionException.java | 0 .../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 406 +++++++++ .../main/java/org/apache/iotdb/rpc/RpcUtils.java | 0 .../iotdb/rpc/StatementExecutionException.java | 0 .../org/apache/iotdb/rpc/SynchronizedHandler.java | 0 .../java/org/apache/iotdb/rpc/TSStatusCode.java | 4 +- service-rpc/src/main/thrift/rpc.thrift | 48 +- service-rpc/src/pypi/README.md | 0 service-rpc/src/pypi/setup.py | 0 session/pom.xml | 0 .../main/java/org/apache/iotdb/session/Config.java | 14 - .../java/org/apache/iotdb/session/Session.java | 501 ++++++----- .../org/apache/iotdb/session/SessionDataSet.java | 298 +++---- .../org/apache/iotdb/session/SessionUtils.java | 42 +- .../iotdb/session/pool/SessionDataSetWrapper.java | 4 +- .../org/apache/iotdb/session/pool/SessionPool.java | 174 ++-- .../iotdb/session/CheckPathValidityTest.java | 2 +- .../org/apache/iotdb/session/IoTDBSessionIT.java | 313 ++++--- .../iotdb/session/IoTDBSessionIteratorIT.java | 122 +++ .../java/org/apache/iotdb/session/SessionUT.java | 92 ++ .../apache/iotdb/session/pool/SessionPoolTest.java | 17 +- session/src/test/resources/iotdb-engine.properties | 0 site/README-zh.md | 0 site/README.md | 0 site/pom.xml | 1 + site/src/main/.vuepress/config.js | 24 +- site/src/main/.vuepress/enhanceApp.js | 0 site/src/main/.vuepress/public/img/arrow.png | Bin .../public/img/contributor-avatar/jlq.png | Bin .../public/img/contributor-avatar/kfx.jpeg | Bin .../public/img/contributor-avatar/user.svg | 0 .../public/img/contributor-avatar/xdh.jpg | Bin .../.vuepress/public/img/contributor-avatar/yt.jpg | Bin .../public/img/contributor-avatar/zss.jpg | Bin site/src/main/.vuepress/public/img/home-Slide1.png | Bin site/src/main/.vuepress/public/img/home-Slide2.png | Bin site/src/main/.vuepress/public/img/home-Slide3.png | Bin site/src/main/.vuepress/public/img/home-icon1.png | Bin site/src/main/.vuepress/public/img/home-icon2.png | Bin site/src/main/.vuepress/public/img/home-icon3.png | Bin site/src/main/.vuepress/public/img/home-icon4.png | Bin site/src/main/.vuepress/public/img/home-icon5.png | Bin site/src/main/.vuepress/public/img/home-icon6.png | Bin site/src/main/.vuepress/public/img/logo.png | Bin site/src/main/.vuepress/public/img/tools.jpg | Bin site/src/main/.vuepress/styles/index.styl | 2 +- site/src/main/.vuepress/styles/palette.styl | 0 .../theme/components/AlgoliaSearchBox.vue | 0 .../.vuepress/theme/components/DropdownLink.vue | 0 .../theme/components/DropdownTransition.vue | 0 site/src/main/.vuepress/theme/components/Home.vue | 0 .../main/.vuepress/theme/components/NavLink.vue | 0 .../main/.vuepress/theme/components/NavLinks.vue | 0 .../src/main/.vuepress/theme/components/Navbar.vue | 0 site/src/main/.vuepress/theme/components/Page.vue | 0 .../main/.vuepress/theme/components/Sidebar.vue | 0 .../.vuepress/theme/components/SidebarButton.vue | 0 .../.vuepress/theme/components/SidebarGroup.vue | 0 .../.vuepress/theme/components/SidebarLink.vue | 0 .../.vuepress/theme/components/SidebarLinks.vue | 0 .../.vuepress/theme/global-components/Badge.vue | 0 .../theme/global-components/Contributor.vue | 0 .../.vuepress/theme/global-components/IoTDB.vue | 4 +- .../.vuepress/theme/global-components/IoTDBZH.vue | 0 site/src/main/.vuepress/theme/index.js | 0 site/src/main/.vuepress/theme/layouts/404.vue | 0 site/src/main/.vuepress/theme/layouts/Layout.vue | 0 site/src/main/.vuepress/theme/styles/arrow.styl | 0 site/src/main/.vuepress/theme/styles/code.styl | 0 .../main/.vuepress/theme/styles/custom-blocks.styl | 0 site/src/main/.vuepress/theme/styles/index.styl | 0 site/src/main/.vuepress/theme/styles/mobile.styl | 0 site/src/main/.vuepress/theme/styles/toc.styl | 0 site/src/main/.vuepress/theme/styles/wrapper.styl | 0 site/src/main/.vuepress/theme/util/index.js | 0 site/src/main/deploy.js | 0 site/src/main/package.json | 0 spark-iotdb-connector/Readme.md | 0 spark-iotdb-connector/pom.xml | 0 .../org/apache/iotdb/spark/db/SQLConstant.java | 0 .../org/apache/iotdb/spark/db/Converter.scala | 4 +- .../org/apache/iotdb/spark/db/DefaultSource.scala | 0 .../org/apache/iotdb/spark/db/IoTDBOptions.scala | 0 .../scala/org/apache/iotdb/spark/db/IoTDBRDD.scala | 0 .../org/apache/iotdb/spark/db/IoTDBRelation.scala | 0 .../org/apache/iotdb/spark/db/Transformer.scala | 0 .../scala/org/apache/iotdb/spark/db/package.scala | 0 .../src/test/resources/iotdb-engine.properties | 0 .../apache/iotdb/spark/db/EnvironmentUtils.java | 2 - .../org/apache/iotdb/spark/db/IoTDBTest.scala | 0 spark-tsfile/README.md | 0 spark-tsfile/pom.xml | 0 .../iotdb/spark/tsfile/io/TsFileOutputFormat.java | 0 .../iotdb/spark/tsfile/io/TsFileRecordWriter.java | 0 .../org/apache/iotdb/spark/tsfile/Converter.scala | 0 .../apache/iotdb/spark/tsfile/DefaultSource.scala | 2 +- .../iotdb/spark/tsfile/NarrowConverter.scala | 2 +- .../spark/tsfile/NarrowTsFileOutputWriter.scala | 0 .../apache/iotdb/spark/tsfile/Transformer.scala | 0 .../iotdb/spark/tsfile/TsFileWriterFactory.scala | 0 .../apache/iotdb/spark/tsfile/WideConverter.scala | 7 +- .../spark/tsfile/WideTsFileOutputWriter.scala | 0 .../apache/iotdb/spark/constant/TestConstant.java | 0 .../org/apache/iotdb/spark/tool/TsFileExample.java | 0 .../apache/iotdb/spark/tool/TsFileWriteTool.java | 0 .../apache/iotdb/spark/tsfile/ConverterTest.scala | 0 .../apache/iotdb/spark/tsfile/HDFSInputTest.java | 0 .../org/apache/iotdb/spark/tsfile/TSFileSuit.scala | 0 tools/clean-site.sh | 0 tsfile/README.md | 0 tsfile/format-changelist.md | 1 + tsfile/pom.xml | 0 .../apache/iotdb/tsfile/common/cache/Cache.java | 0 .../apache/iotdb/tsfile/common/cache/LRUCache.java | 0 .../iotdb/tsfile/common/conf/TSFileConfig.java | 12 + .../iotdb/tsfile/common/conf/TSFileDescriptor.java | 2 + .../tsfile/common/constant/JsonFormatConstant.java | 0 .../tsfile/common/constant/QueryConstant.java | 0 .../tsfile/common/constant/TsFileConstant.java | 0 .../apache/iotdb/tsfile/compress/ICompressor.java | 0 .../iotdb/tsfile/compress/IUnCompressor.java | 0 .../tsfile/encoding/bitpacking/IntPacker.java | 0 .../tsfile/encoding/bitpacking/LongPacker.java | 0 .../tsfile/encoding/common/EncodingConfig.java | 0 .../iotdb/tsfile/encoding/common/EndianType.java | 0 .../tsfile/encoding/decoder/BitmapDecoder.java | 0 .../iotdb/tsfile/encoding/decoder/Decoder.java | 0 .../encoding/decoder/DeltaBinaryDecoder.java | 0 .../encoding/decoder/DoublePrecisionDecoder.java | 0 .../tsfile/encoding/decoder/FloatDecoder.java | 0 .../tsfile/encoding/decoder/GorillaDecoder.java | 0 .../tsfile/encoding/decoder/IntRleDecoder.java | 0 .../tsfile/encoding/decoder/LongRleDecoder.java | 0 .../tsfile/encoding/decoder/PlainDecoder.java | 0 .../encoding/decoder/RegularDataDecoder.java | 0 .../iotdb/tsfile/encoding/decoder/RleDecoder.java | 0 .../encoding/decoder/SinglePrecisionDecoder.java | 0 .../tsfile/encoding/encoder/BitmapEncoder.java | 0 .../encoding/encoder/DeltaBinaryEncoder.java | 0 .../encoding/encoder/DoublePrecisionEncoder.java | 0 .../iotdb/tsfile/encoding/encoder/Encoder.java | 0 .../tsfile/encoding/encoder/FloatEncoder.java | 0 .../tsfile/encoding/encoder/GorillaEncoder.java | 0 .../tsfile/encoding/encoder/IntRleEncoder.java | 0 .../tsfile/encoding/encoder/LongRleEncoder.java | 0 .../tsfile/encoding/encoder/PlainEncoder.java | 0 .../encoding/encoder/RegularDataEncoder.java | 0 .../iotdb/tsfile/encoding/encoder/RleEncoder.java | 0 .../encoding/encoder/SinglePrecisionEncoder.java | 0 .../tsfile/encoding/encoder/TSEncodingBuilder.java | 0 .../exception/NotCompatibleTsFileException.java | 0 .../tsfile/exception/NotImplementedException.java | 0 .../NullFieldException.java} | 9 +- .../tsfile/exception/TsFileRuntimeException.java | 0 .../tsfile/exception/cache/CacheException.java | 0 .../CompressionTypeNotSupportedException.java | 0 .../encoding/TsFileDecodingException.java | 0 .../encoding/TsFileEncodingException.java | 0 .../filter/QueryFilterOptimizationException.java | 0 .../exception/filter/StatisticsClassException.java | 0 .../filter/UnSupportFilterDataTypeException.java | 0 .../exception/write/NoMeasurementException.java | 0 .../tsfile/exception/write/PageException.java | 0 .../write/TsFileNotCompleteException.java | 0 .../write/UnSupportedDataTypeException.java | 0 .../write/UnknownColumnTypeException.java | 0 .../exception/write/WriteProcessException.java | 0 .../org/apache/iotdb/tsfile/file/MetaMarker.java | 0 .../iotdb/tsfile/file/footer/ChunkGroupFooter.java | 0 .../iotdb/tsfile/file/header/ChunkHeader.java | 0 .../iotdb/tsfile/file/header/PageHeader.java | 9 + .../iotdb/tsfile/file/header/package-info.java | 0 .../tsfile/file/metadata/ChunkGroupMetadata.java | 0 .../iotdb/tsfile/file/metadata/ChunkMetadata.java | 10 + .../file/metadata/MetadataIndexConstructor.java | 151 ++++ .../tsfile/file/metadata/MetadataIndexEntry.java | 91 ++ .../tsfile/file/metadata/MetadataIndexNode.java | 125 +++ .../tsfile/file/metadata/TimeseriesMetadata.java | 21 +- .../iotdb/tsfile/file/metadata/TsFileMetadata.java | 50 +- .../file/metadata/enums/CompressionType.java | 0 ...{TSDataType.java => MetadataIndexNodeType.java} | 190 ++-- .../tsfile/file/metadata/enums/TSDataType.java | 0 .../tsfile/file/metadata/enums/TSEncoding.java | 0 .../file/metadata/statistics/BinaryStatistics.java | 2 +- .../metadata/statistics/BooleanStatistics.java | 0 .../file/metadata/statistics/DoubleStatistics.java | 0 .../file/metadata/statistics/FloatStatistics.java | 0 .../metadata/statistics/IntegerStatistics.java | 0 .../file/metadata/statistics/LongStatistics.java | 0 .../file/metadata/statistics/Statistics.java | 13 - .../iotdb/tsfile/fileSystem/FSFactoryProducer.java | 0 .../org/apache/iotdb/tsfile/fileSystem/FSType.java | 0 .../fileInputFactory/FileInputFactory.java | 0 .../fileInputFactory/HDFSInputFactory.java | 0 .../fileInputFactory/LocalFSInputFactory.java | 0 .../fileOutputFactory/FileOutputFactory.java | 0 .../fileOutputFactory/HDFSOutputFactory.java | 0 .../fileOutputFactory/LocalFSOutputFactory.java | 0 .../tsfile/fileSystem/fsFactory/FSFactory.java | 0 .../tsfile/fileSystem/fsFactory/HDFSFactory.java | 0 .../fileSystem/fsFactory/LocalFSFactory.java | 0 .../apache/iotdb/tsfile/read/ReadOnlyTsFile.java | 0 .../apache/iotdb/tsfile/read/TimeValuePair.java | 0 .../iotdb/tsfile/read/TsFileCheckStatus.java | 0 .../iotdb/tsfile/read/TsFileRestorableReader.java | 0 .../iotdb/tsfile/read/TsFileSequenceReader.java | 472 +++++++--- .../iotdb/tsfile/read/UnClosedTsFileReader.java | 0 .../apache/iotdb/tsfile/read/common/BatchData.java | 0 .../org/apache/iotdb/tsfile/read/common/Chunk.java | 0 .../tsfile/read/common/ExceptionBatchData.java | 0 .../org/apache/iotdb/tsfile/read/common/Field.java | 23 + .../org/apache/iotdb/tsfile/read/common/Path.java | 8 +- .../apache/iotdb/tsfile/read/common/RowRecord.java | 0 .../iotdb/tsfile/read/common/SignalBatchData.java | 0 .../iotdb/tsfile/read/common/TimeColumn.java | 0 .../apache/iotdb/tsfile/read/common/TimeRange.java | 0 .../read/controller/CachedChunkLoaderImpl.java | 0 .../iotdb/tsfile/read/controller/IChunkLoader.java | 0 .../read/controller/IChunkMetadataLoader.java | 0 .../tsfile/read/controller/IMetadataQuerier.java | 2 +- .../read/controller/MetadataQuerierByFileImpl.java | 37 +- .../tsfile/read/expression/ExpressionType.java | 0 .../tsfile/read/expression/IBinaryExpression.java | 0 .../iotdb/tsfile/read/expression/IExpression.java | 0 .../tsfile/read/expression/IUnaryExpression.java | 0 .../tsfile/read/expression/QueryExpression.java | 0 .../read/expression/impl/BinaryExpression.java | 0 .../read/expression/impl/GlobalTimeExpression.java | 0 .../expression/impl/SingleSeriesExpression.java | 0 .../read/expression/util/ExpressionOptimizer.java | 0 .../read/expression/util/ExpressionPrinter.java | 0 .../iotdb/tsfile/read/filter/GroupByFilter.java | 0 .../iotdb/tsfile/read/filter/TimeFilter.java | 0 .../iotdb/tsfile/read/filter/ValueFilter.java | 0 .../tsfile/read/filter/factory/FilterFactory.java | 0 .../read/filter/factory/FilterSerializeId.java | 0 .../tsfile/read/filter/factory/FilterType.java | 0 .../iotdb/tsfile/read/filter/operator/In.java | 0 .../query/dataset/DataSetWithTimeGenerator.java | 0 .../query/dataset/DataSetWithoutTimeGenerator.java | 0 .../tsfile/read/query/dataset/EmptyDataSet.java | 0 .../tsfile/read/query/dataset/QueryDataSet.java | 0 .../query/executor/ExecutorWithTimeGenerator.java | 0 .../tsfile/read/query/executor/QueryExecutor.java | 0 .../tsfile/read/query/executor/TsFileExecutor.java | 3 - .../read/query/timegenerator/TimeGenerator.java | 0 .../query/timegenerator/TsFileTimeGenerator.java | 0 .../read/query/timegenerator/node/AndNode.java | 0 .../read/query/timegenerator/node/LeafNode.java | 0 .../tsfile/read/query/timegenerator/node/Node.java | 0 .../read/query/timegenerator/node/NodeType.java | 0 .../read/query/timegenerator/node/OrNode.java | 0 .../tsfile/read/reader/BatchDataIterator.java | 0 .../iotdb/tsfile/read/reader/IBatchReader.java | 0 .../iotdb/tsfile/read/reader/IChunkReader.java | 0 .../iotdb/tsfile/read/reader/IPageReader.java | 2 + .../iotdb/tsfile/read/reader/IPointReader.java | 0 .../iotdb/tsfile/read/reader/LocalTsFileInput.java | 2 + .../iotdb/tsfile/read/reader/TsFileInput.java | 0 .../tsfile/read/reader/chunk/ChunkReader.java | 2 +- .../read/reader/chunk/ChunkReaderByTimestamp.java | 0 .../iotdb/tsfile/read/reader/page/PageReader.java | 5 + .../reader/series/AbstractFileSeriesReader.java | 0 .../read/reader/series/EmptyFileSeriesReader.java | 0 .../read/reader/series/FileSeriesReader.java | 0 .../reader/series/FileSeriesReaderByTimestamp.java | 0 .../java/org/apache/iotdb/tsfile/utils/Binary.java | 0 .../org/apache/iotdb/tsfile/utils/BloomFilter.java | 0 .../org/apache/iotdb/tsfile/utils/BytesUtils.java | 0 .../java/org/apache/iotdb/tsfile/utils/Loader.java | 0 .../apache/iotdb/tsfile/utils/Murmur128Hash.java | 0 .../java/org/apache/iotdb/tsfile/utils/Pair.java | 0 .../org/apache/iotdb/tsfile/utils/PublicBAOS.java | 0 .../tsfile/utils/ReadWriteForEncodingUtils.java | 0 .../iotdb/tsfile/utils/ReadWriteIOUtils.java | 69 +- .../apache/iotdb/tsfile/utils/StringContainer.java | 0 .../apache/iotdb/tsfile/utils/TsPrimitiveType.java | 0 .../apache/iotdb/tsfile/utils/VersionUtils.java | 0 .../apache/iotdb/tsfile/write/TsFileWriter.java | 40 +- .../tsfile/write/chunk/ChunkGroupWriterImpl.java | 24 +- .../iotdb/tsfile/write/chunk/ChunkWriterImpl.java | 0 .../tsfile/write/chunk/IChunkGroupWriter.java | 14 +- .../iotdb/tsfile/write/chunk/IChunkWriter.java | 0 .../apache/iotdb/tsfile/write/page/PageWriter.java | 0 .../apache/iotdb/tsfile/write/record/TSRecord.java | 0 .../write/record/{RowBatch.java => Tablet.java} | 100 ++- .../write/record/datapoint/BooleanDataPoint.java | 0 .../tsfile/write/record/datapoint/DataPoint.java | 0 .../write/record/datapoint/DoubleDataPoint.java | 0 .../write/record/datapoint/FloatDataPoint.java | 0 .../write/record/datapoint/IntDataPoint.java | 0 .../write/record/datapoint/LongDataPoint.java | 0 .../write/record/datapoint/StringDataPoint.java | 0 .../tsfile/write/schema/MeasurementSchema.java | 0 .../apache/iotdb/tsfile/write/schema/Schema.java | 24 +- .../write/writer/ForceAppendTsFileWriter.java | 0 .../iotdb/tsfile/write/writer/IDataWriter.java | 0 .../tsfile/write/writer/LocalTsFileOutput.java | 0 .../write/writer/RestorableTsFileIOWriter.java | 9 +- .../iotdb/tsfile/write/writer/TsFileIOWriter.java | 67 +- .../iotdb/tsfile/write/writer/TsFileOutput.java | 0 .../apache/iotdb/tsfile/common/LRUCacheTest.java | 0 .../apache/iotdb/tsfile/compress/CompressTest.java | 0 .../apache/iotdb/tsfile/compress/SnappyTest.java | 0 .../apache/iotdb/tsfile/constant/TestConstant.java | 0 .../tsfile/encoding/bitpacking/IntPackerTest.java | 0 .../tsfile/encoding/bitpacking/LongPackerTest.java | 0 .../tsfile/encoding/decoder/BitmapDecoderTest.java | 0 .../tsfile/encoding/decoder/FloatDecoderTest.java | 0 .../encoding/decoder/GorillaDecoderTest.java | 0 .../tsfile/encoding/decoder/IntRleDecoderTest.java | 0 .../encoding/decoder/LongRleDecoderTest.java | 0 .../delta/DeltaBinaryEncoderIntegerTest.java | 0 .../decoder/delta/DeltaBinaryEncoderLongTest.java | 0 .../regular/RegularDataEncoderIntegerTest.java | 0 .../regular/RegularDataEncoderLongTest.java | 0 .../iotdb/tsfile/file/header/PageHeaderTest.java | 0 .../file/metadata/MetadataIndexNodeTest.java | 46 + .../file/metadata/TimeSeriesMetadataTest.java | 0 .../tsfile/file/metadata/TsFileMetadataTest.java | 0 .../metadata/statistics/BooleanStatisticsTest.java | 0 .../metadata/statistics/DoubleStatisticsTest.java | 0 .../metadata/statistics/FloatStatisticsTest.java | 0 .../metadata/statistics/IntegerStatisticsTest.java | 0 .../metadata/statistics/LongStatisticsTest.java | 0 .../metadata/statistics/StringStatisticsTest.java | 0 .../tsfile/file/metadata/utils/TestHelper.java | 20 +- .../iotdb/tsfile/file/metadata/utils/Utils.java | 14 +- .../apache/iotdb/tsfile/read/ExpressionTest.java | 0 .../iotdb/tsfile/read/ReadInPartitionTest.java | 0 .../iotdb/tsfile/read/ReadOnlyTsFileTest.java | 0 .../tsfile/read/TsFileRestorableReaderTest.java | 0 .../tsfile/read/TsFileSequenceReaderTest.java | 0 .../iotdb/tsfile/read/common/BatchDataTest.java | 0 .../apache/iotdb/tsfile/read/common/FieldTest.java | 18 +- .../apache/iotdb/tsfile/read/common/PathTest.java | 0 .../iotdb/tsfile/read/common/TimeRangeTest.java | 0 .../tsfile/read/controller/ChunkLoaderTest.java | 0 .../controller/IMetadataQuerierByFileImplTest.java | 0 .../tsfile/read/filter/FilterSerializeTest.java | 0 .../tsfile/read/filter/GroupByFilterTest.java | 0 .../read/filter/IExpressionOptimizerTest.java | 0 .../read/filter/MinTimeMaxTimeFilterTest.java | 0 .../iotdb/tsfile/read/filter/OperatorTest.java | 0 .../tsfile/read/filter/StatisticsFilterTest.java | 0 .../read/query/executor/QueryExecutorTest.java | 0 .../tsfile/read/query/timegenerator/NodeTest.java | 0 .../read/query/timegenerator/ReadWriteTest.java | 0 .../query/timegenerator/ReaderByTimestampTest.java | 0 .../timegenerator/TimeGeneratorReadEmptyTest.java | 0 .../timegenerator/TimeGeneratorReadWriteTest.java | 0 .../query/timegenerator/TimeGeneratorTest.java | 0 .../iotdb/tsfile/read/reader/FakedBatchReader.java | 0 .../tsfile/read/reader/FakedMultiBatchReader.java | 0 .../tsfile/read/reader/FakedTimeGenerator.java | 0 .../iotdb/tsfile/read/reader/PageReaderTest.java | 0 .../iotdb/tsfile/read/reader/ReaderTest.java | 2 + .../apache/iotdb/tsfile/utils/BloomFilterTest.java | 0 .../apache/iotdb/tsfile/utils/BytesUtilsTest.java | 0 .../org/apache/iotdb/tsfile/utils/FileUtils.java | 0 .../org/apache/iotdb/tsfile/utils/PairTest.java | 0 .../tsfile/utils/ReadWriteStreamUtilsTest.java | 0 .../tsfile/utils/ReadWriteToBytesUtilsTest.java | 0 .../org/apache/iotdb/tsfile/utils/RecordUtils.java | 0 .../iotdb/tsfile/utils/TsPrimitiveTypeTest.java | 0 .../iotdb/tsfile/write/ReadPageInMemTest.java | 0 ...SameMeasurementsWithDifferentDataTypesTest.java | 0 .../iotdb/tsfile/write/TsFileIOWriterTest.java | 5 +- .../iotdb/tsfile/write/TsFileReadWriteTest.java | 0 .../iotdb/tsfile/write/TsFileWriterTest.java | 35 +- .../write/schema/converter/SchemaBuilderTest.java | 0 .../write/writer/ForceAppendTsFileWriterTest.java | 0 .../write/writer/RestorableTsFileIOWriterTest.java | 0 tsfile/src/test/resources/logback.xml | 0 1441 files changed, 14507 insertions(+), 5815 deletions(-) diff --cc server/src/main/java/org/apache/iotdb/db/engine/merge/seqMerge/inplace/selector/InplaceMaxFileSelector.java index cd2bb10,45e9a4b..cd2bb10 mode 100644,100755..100755 --- a/server/src/main/java/org/apache/iotdb/db/engine/merge/seqMerge/inplace/selector/InplaceMaxFileSelector.java +++ b/server/src/main/java/org/apache/iotdb/db/engine/merge/seqMerge/inplace/selector/InplaceMaxFileSelector.java
