This is an automated email from the ASF dual-hosted git repository. xuekaifeng pushed a commit to branch IOTDB-615-Use-binary-rather-than-string-in-insert-plan in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
commit 275fe1816f1a7fa88f439af7ee3960730abd3a56 Merge: 693832e e92f24e Author: 151250176 <[email protected]> AuthorDate: Thu Apr 23 10:37:13 2020 +0800 Merge branch 'master' of https://github.com/apache/incubator-iotdb .gitignore | 1 + .travis.yml | 140 +- Jenkinsfile | 25 +- LICENSE | 13 - LICENSE-binary | 4 +- README.md | 18 +- README_ZH.md | 383 + .../src/assembly/resources/sbin/start-client.bat | 6 +- .../org/apache/iotdb/client/AbstractClient.java | 83 +- .../main/java/org/apache/iotdb/client/Client.java | 2 +- .../java/org/apache/iotdb/client/WinClient.java | 3 + client/src/test/resources/logback.xml | 12 +- distribution/pom.xml | 13 + docs/Community/Community-Powered By.md | 15 +- docs/Community/Community-Project Committers.md | 33 +- docs/Community/Feedback.md | 48 + docs/Community/Materials.md | 100 + docs/Development/Committer.md | 77 + docs/Development/ContributeGuide.md | 109 + docs/Development/Development-Contributing.md | 214 - docs/Development/Development-Document.md | 51 - docs/Development/Development-IDE.md | 65 - docs/Development/HowToCommit.md | 139 + .../{Development-VoteRelease.md => VoteRelease.md} | 80 +- docs/Documentation/OtherMaterial-Sample Data.txt | 60509 ------------------- docs/Documentation/SystemDesign/0-Content.md | 54 - docs/Documentation/SystemDesign/release.adoc | 519 - docs/Download/README.md | 65 + .../3-Server/3-Cluster Setup.md => README.md} | 5 +- .../SystemDesign/0-Architecture/1-Architecture.md | 14 +- .../SystemDesign/1-TsFile/1-TsFile.md | 6 +- .../SystemDesign/1-TsFile/2-Format.md | 24 +- .../SystemDesign/1-TsFile/3-Write.md | 0 .../SystemDesign/1-TsFile/4-Read.md | 0 .../SystemDesign/2-QueryEngine/1-QueryEngine.md | 4 +- .../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 | 8 +- .../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 | 19 +- .../SystemDesign/5-DataQuery/1-DataQuery.md | 16 +- .../5-DataQuery/10-GroupByFillQuery.md | 177 + .../SystemDesign/5-DataQuery/2-SeriesReader.md | 0 .../5-DataQuery/3-ModificationHandle.md | 73 + .../5-DataQuery/4-RawDataQuery.md} | 0 .../5-DataQuery/5-AggregationQuery.md} | 0 .../5-DataQuery/6-GroupByQuery.md} | 0 .../5-DataQuery/7-LastQuery.md} | 0 .../5-DataQuery/8-AlignByDeviceQuery.md} | 21 +- docs/SystemDesign/5-DataQuery/9-FillFunction.md | 149 + .../SystemDesign/6-Tools/1-Sync.md | 0 .../SystemDesign/7-Connector/2-Hive-TsFile.md | 0 .../SystemDesign/7-Connector/3-Spark-TsFile.md | 0 .../SystemDesign/7-Connector/4-Spark-IOTDB.md | 0 .../UserGuide/0-Get Started/1-QuickStart.md | 25 +- .../0-Get Started/2-Frequently asked questions.md | 0 .../UserGuide/0-Get Started/3-Publication.md | 0 .../UserGuide/1-Overview/1-What is IoTDB.md | 0 .../UserGuide/1-Overview/2-Architecture.md | 0 .../UserGuide/1-Overview/3-Scenario.md | 0 .../UserGuide/1-Overview/4-Features.md | 0 .../2-Concept/1-Data Model and Terminology.md | 6 +- .../UserGuide/2-Concept/2-Data Type.md | 2 +- .../UserGuide/2-Concept/3-Encoding.md | 2 +- .../UserGuide/2-Concept/4-Compression.md | 2 +- .../UserGuide/3-Server/1-Download.md | 6 +- .../UserGuide/3-Server/2-Single Node Setup.md | 10 +- .../UserGuide/3-Server/3-Cluster Setup.md | 0 .../UserGuide/3-Server/4-Config Manual.md | 56 +- .../UserGuide/3-Server/5-Docker Image.md | 0 .../UserGuide/4-Client/1-Command Line Interface.md | 10 +- .../4-Client/2-Programming - Native API.md | 0 .../UserGuide/4-Client/3-Programming - JDBC.md | 0 .../4-Client/4-Programming - Other Languages.md | 0 .../4-Client/5-Programming - TsFile API.md | 16 +- docs/UserGuide/4-Client/6-Programming - MQTT.md | 100 + .../4-Client/7-Status Codes.md} | 0 .../1-DDL Data Definition Language.md | 33 +- .../2-DML Data Manipulation Language.md | 126 +- .../3-Account Management Statements.md | 2 +- .../5-Operation Manual/4-SQL Reference.md | 88 +- .../UserGuide/6-System Tools/1-Sync Tool.md | 0 .../6-System Tools/2-Memory Estimation Tool.md | 0 .../UserGuide/6-System Tools/3-JMX Tool.md | 22 + .../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 | 4 +- .../6-System Tools/8-Load External Tsfile.md | 0 .../UserGuide/7-Ecosystem Integration/1-Grafana.md | 70 +- .../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 .../UserGuide/8-Architecture/1-Files.md | 8 +- .../8-Architecture/2-Writing Data on HDFS.md | 4 +- .../8-Architecture/3-Shared Nothing Cluster.md | 0 .../1-TsFile.md => UserGuide/UserGuideReadme.md} | 13 +- docs/zh/Community/Community-Powered By.md | 36 + .../Community/Community-Project Committers.md} | 8 +- docs/zh/Community/Feedback.md | 44 + docs/zh/Community/Materials.md | 95 + docs/zh/Development/Committer.md | 78 + .../Development/ContributeGuide.md} | 60 +- docs/zh/Development/HowToCommit.md | 139 + .../Development/VoteRelease.md} | 2 +- docs/zh/Download/README.md | 64 + .../3-Server/3-Cluster Setup.md => zh/README.md} | 5 +- .../SystemDesign/0-Architecture/1-Architecture.md | 0 .../SystemDesign/1-TsFile/1-TsFile.md | 0 .../SystemDesign/1-TsFile/2-Format.md | 26 +- .../SystemDesign/1-TsFile/3-Write.md | 0 .../SystemDesign/1-TsFile/4-Read.md | 0 .../SystemDesign/2-QueryEngine/1-QueryEngine.md | 4 +- .../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 | 8 +- .../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 | 18 +- .../SystemDesign/5-DataQuery/1-DataQuery.md | 16 +- .../5-DataQuery/10-GroupByFillQuery.md | 176 + .../SystemDesign/5-DataQuery/2-SeriesReader.md | 0 .../5-DataQuery/3-ModificationHandle.md | 73 + .../SystemDesign/5-DataQuery/4-RawDataQuery.md} | 0 .../5-DataQuery/5-AggregationQuery.md} | 0 .../SystemDesign/5-DataQuery/6-GroupByQuery.md} | 0 .../SystemDesign/5-DataQuery/7-LastQuery.md} | 0 .../5-DataQuery/8-AlignByDeviceQuery.md} | 13 +- docs/zh/SystemDesign/5-DataQuery/9-FillFunction.md | 148 + .../SystemDesign/6-Tools/1-Sync.md | 0 .../SystemDesign/7-Connector/2-Hive-TsFile.md | 0 .../SystemDesign/7-Connector/3-Spark-TsFile.md | 48 +- .../SystemDesign/7-Connector/4-Spark-IOTDB.md | 0 .../UserGuide/0-Get Started/1-QuickStart.md | 18 +- .../0-Get Started/2-Frequently asked questions.md | 0 .../UserGuide/0-Get Started/3-Publication.md | 0 .../UserGuide/1-Overview/1-What is IoTDB.md | 0 .../UserGuide/1-Overview/2-Architecture.md | 0 .../UserGuide/1-Overview/3-Scenario.md | 0 .../UserGuide/1-Overview/4-Features.md | 0 .../2-Concept/1-Data Model and Terminology.md | 6 +- .../UserGuide/2-Concept/2-Data Type.md | 2 +- .../UserGuide/2-Concept/3-Encoding.md | 2 +- .../UserGuide/2-Concept/4-Compression.md | 2 +- .../UserGuide/3-Server/1-Download.md | 8 +- .../UserGuide/3-Server/2-Single Node Setup.md | 11 +- .../UserGuide/3-Server/3-Cluster Setup.md | 0 .../UserGuide/3-Server/4-Config Manual.md | 17 +- .../UserGuide/3-Server/5-Docker Image.md | 0 .../UserGuide/4-Client/1-Command Line Interface.md | 10 +- .../4-Client/2-Programming - Native API.md | 0 .../UserGuide/4-Client/3-Programming - JDBC.md | 0 .../4-Client/4-Programming - Other Languages.md | 0 .../4-Client/5-Programming - TsFile API.md | 16 +- docs/zh/UserGuide/4-Client/6-Programming - MQTT.md | 101 + .../UserGuide/4-Client/7-Status Codes.md} | 0 .../1-DDL Data Definition Language.md | 33 +- .../2-DML Data Manipulation Language.md | 115 +- .../3-Account Management Statements.md | 4 +- .../5-Operation Manual/4-SQL Reference.md | 93 +- .../UserGuide/6-System Tools/1-Sync Tool.md | 0 .../6-System Tools/2-Memory Estimation Tool.md | 0 .../UserGuide/6-System Tools/3-JMX Tool.md | 22 + .../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 | 6 +- .../6-System Tools/8-Load External Tsfile.md | 0 .../UserGuide/7-Ecosystem Integration/1-Grafana.md | 65 +- .../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 .../UserGuide/8-Architecture/1-Files.md | 8 +- .../8-Architecture/2-Writing Data on HDFS.md | 4 +- .../8-Architecture/3-Shared Nothing Cluster.md | 0 .../UserGuide/UserGuideReadme.md} | 13 +- example/flink/README.md | 10 +- example/flink/pom.xml | 7 +- .../org/apache/iotdb/flink/FlinkIoTDBSink.java | 6 - .../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 | 17 +- .../iotdb/hadoop/tsfile/TSMRWriteExample.java | 259 +- .../apache/iotdb/hadoop/tsfile/TsFileHelper.java | 20 +- .../iotdb/hadoop/tsfile/TsFileWriteToHDFS.java | 73 + .../main/java/org/apache/iotdb/JDBCExample.java | 19 +- example/kafka/readme.md | 2 +- .../main/java/org/apache/iotdb/kafka/Constant.java | 11 +- .../apache/iotdb/kafka/KafkaConsumerThread.java | 2 +- example/{flink => mqtt}/README.md | 8 +- example/{flink => mqtt}/pom.xml | 14 +- .../java/org/apache/iotdb/mqtt/MQTTClient.java | 50 + example/pom.xml | 1 + example/rocketmq/readme.md | 8 +- .../apache/iotdb/rocketmq/RocketMQConsumer.java | 2 +- .../main/java/org/apache/iotdb/SessionExample.java | 136 +- .../java/org/apache/iotdb/tsfile/Constant.java | 17 +- .../apache/iotdb/tsfile/TsFileSequenceRead.java | 39 +- .../iotdb/tsfile/TsFileWriteWithRowBatch.java | 9 +- .../iotdb/tsfile/TsFileWriteWithTSRecord.java | 33 +- .../java/org/apache/iotdb/flink/IoTDBSink.java | 32 +- .../iotdb/flink/IoTDBSinkBatchInsertTest.java | 22 +- .../iotdb/flink/IoTDBSinkBatchTimerTest.java | 14 +- .../apache/iotdb/flink/IoTDBSinkInsertTest.java | 12 +- flink-tsfile-connector/README.md | 93 + {example/flink => flink-tsfile-connector}/pom.xml | 19 +- .../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 + grafana/readme.md | 74 +- grafana/readme_zh.md | 95 +- .../iotdb/web/grafana/dao/impl/BasicDaoImpl.java | 70 +- .../main/resources}/application.properties | 10 +- hadoop/README.md | 2 +- hadoop/pom.xml | 55 + .../apache/iotdb/hadoop/fileSystem/HDFSFile.java | 2 +- .../apache/iotdb/hadoop/fileSystem/HDFSOutput.java | 7 +- .../apache/iotdb/hadoop/tsfile/TSFInputFormat.java | 94 +- .../apache/iotdb/hadoop/tsfile/TSFInputSplit.java | 251 +- .../iotdb/hadoop/tsfile/TSFRecordReader.java | 69 +- .../iotdb/hadoop/tsfile/TSFRecordWriter.java | 1 - .../iotdb/hadoop/tsfile/TSFInputSplitTest.java | 21 +- .../iotdb/hadoop/tsfile/TsFileTestHelper.java | 7 +- .../apache/iotdb/hive/TSFHiveInputFormatTest.java | 29 +- .../apache/iotdb/hive/TSFHiveRecordReaderTest.java | 30 +- .../org/apache/iotdb/hive/TsFileTestHelper.java | 3 +- jdbc/README.md | 23 + jdbc/osgi.bnd | 31 + jdbc/pom.xml | 97 + jdbc/src/main/feature/feature.xml | 35 + .../apache/iotdb/jdbc/AbstractIoTDBResultSet.java | 35 +- .../main/java/org/apache/iotdb/jdbc/Activator.java | 40 + .../org/apache/iotdb/jdbc/IoTDBDataSource.java | 146 + .../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 11 +- .../java/org/apache/iotdb/jdbc/IoTDBDriver.java | 4 +- .../iotdb/jdbc/IoTDBNonAlignQueryResultSet.java | 21 +- .../apache/iotdb/jdbc/IoTDBPreparedStatement.java | 92 +- .../org/apache/iotdb/jdbc/IoTDBQueryResultSet.java | 10 +- .../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 8 +- .../apache/iotdb/jdbc/IoTDbDataSourceFactory.java | 79 + .../resources/services/META-INF/java.sql.Driver | 9 +- pom.xml | 70 +- server/pom.xml | 28 +- .../resources/conf/iotdb-engine.properties | 121 +- server/src/assembly/resources/conf/iotdb-env.bat | 30 +- server/src/assembly/resources/conf/iotdb-env.sh | 30 +- .../src/assembly/resources/conf/jmx.access | 11 +- .../src/assembly/resources/conf/jmx.password | 11 +- server/src/assembly/resources/conf/logback.xml | 21 +- .../src/assembly/resources/sbin/start-server.bat | 27 +- server/src/assembly/resources/sbin/start-server.sh | 20 +- .../org/apache/iotdb/db/qp/strategy/SqlBase.g4 | 73 +- .../db/concurrent/IoTDBThreadPoolFactory.java | 6 +- .../org/apache/iotdb/db/concurrent/ThreadName.java | 4 +- .../iotdb/db/concurrent/WrappedRunnable.java | 31 +- .../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 145 +- .../org/apache/iotdb/db/conf/IoTDBConfigCheck.java | 17 + .../org/apache/iotdb/db/conf/IoTDBConstant.java | 17 +- .../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 76 +- .../db/conf/adapter/IoTDBConfigDynamicAdapter.java | 33 +- .../iotdb/db/cost/statistic/Measurement.java | 9 +- .../org/apache/iotdb/db/engine/StorageEngine.java | 71 +- .../db/engine/cache/CacheHitRatioMonitor.java | 9 +- .../engine/cache/CacheHitRatioMonitorMXBean.java | 2 + .../apache/iotdb/db/engine/cache/ChunkCache.java | 29 +- .../iotdb/db/engine/cache/ChunkMetadataCache.java | 198 + .../iotdb/db/engine/cache/DeviceMetaDataCache.java | 231 - .../db/engine/cache/TimeSeriesMetadataCache.java | 223 + .../iotdb/db/engine/cache/TsFileMetaDataCache.java | 103 +- .../iotdb/db/engine/cache/TsFileMetadataUtils.java | 122 - .../apache/iotdb/db/engine/flush/FlushManager.java | 6 +- .../iotdb/db/engine/flush/MemTableFlushTask.java | 109 +- .../iotdb/db/engine/flush/NotifyFlushMemTable.java | 4 +- .../iotdb/db/engine/memtable/AbstractMemTable.java | 25 +- .../apache/iotdb/db/engine/memtable/IMemTable.java | 3 +- .../db/engine/memtable/IWritableMemChunk.java | 3 +- .../db/engine/memtable/PrimitiveMemTable.java | 6 +- .../iotdb/db/engine/memtable/WritableMemChunk.java | 17 +- .../db/engine/merge/manage/MergeResource.java | 36 +- .../iotdb/db/engine/merge/recover/LogAnalyzer.java | 2 +- .../merge/selector/MaxFileMergeFileSelector.java | 62 +- .../iotdb/db/engine/merge/task/MergeFileTask.java | 96 +- .../db/engine/merge/task/MergeMultiChunkTask.java | 88 +- .../iotdb/db/engine/merge/task/MergeTask.java | 26 +- .../db/engine/merge/task/RecoverMergeTask.java | 10 +- .../db/engine/querycontext/ReadOnlyMemChunk.java | 19 +- .../engine/storagegroup/StorageGroupProcessor.java | 324 +- .../db/engine/storagegroup/TsFileProcessor.java | 71 +- .../db/engine/storagegroup/TsFileResource.java | 142 +- .../iotdb/db/engine/upgrade/UpgradeTask.java | 18 +- .../metadata/AliasAlreadyExistException.java} | 17 +- .../db/exception/metadata/MetadataException.java | 2 +- ...viceException.java => RPCServiceException.java} | 6 +- .../org/apache/iotdb/db/metadata/MLogWriter.java | 164 + .../org/apache/iotdb/db/metadata/MManager.java | 572 +- .../java/org/apache/iotdb/db/metadata/MTree.java | 145 +- .../org/apache/iotdb/db/metadata/MetaUtils.java | 8 +- .../apache/iotdb/db/metadata/MetadataConstant.java | 1 + .../org/apache/iotdb/db/metadata/TagLogFile.java | 143 + .../iotdb/db/metadata/mnode/InternalMNode.java | 22 +- .../apache/iotdb/db/metadata/mnode/LeafMNode.java | 49 +- .../org/apache/iotdb/db/metadata/mnode/MNode.java | 20 +- .../iotdb/db/metadata/mnode/StorageGroupMNode.java | 15 +- .../org/apache/iotdb/db/monitor/StatMonitor.java | 5 +- .../iotdb/db/monitor/collector/FileSize.java | 17 - .../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 + .../apache/iotdb/db/qp/constant/SQLConstant.java | 2 + .../apache/iotdb/db/qp/executor/PlanExecutor.java | 295 +- .../org/apache/iotdb/db/qp/logical/Operator.java | 2 +- .../iotdb/db/qp/logical/crud/QueryOperator.java | 10 + .../iotdb/db/qp/logical/crud/SelectOperator.java | 5 +- .../qp/logical/sys/CreateTimeSeriesOperator.java | 31 +- .../db/qp/logical/sys/ShowTimeSeriesOperator.java | 45 + .../iotdb/db/qp/physical/crud/BatchInsertPlan.java | 13 +- .../iotdb/db/qp/physical/crud/GroupByFillPlan.java | 29 +- .../iotdb/db/qp/physical/crud/GroupByPlan.java | 11 + .../iotdb/db/qp/physical/crud/InsertPlan.java | 37 +- .../iotdb/db/qp/physical/crud/QueryPlan.java | 16 +- .../db/qp/physical/crud/RawDataQueryPlan.java | 20 +- .../db/qp/physical/sys/CreateTimeSeriesPlan.java | 100 +- .../db/qp/physical/sys/ShowTimeSeriesPlan.java | 40 +- .../iotdb/db/qp/strategy/LogicalGenerator.java | 295 +- .../iotdb/db/qp/strategy/PhysicalGenerator.java | 146 +- .../db/query/aggregation/AggregateResult.java | 7 +- .../iotdb/db/query/context/QueryContext.java | 4 +- .../iotdb/db/query/control/FileReaderManager.java | 71 +- .../db/query/control/QueryResourceManager.java | 6 +- .../db/query/dataset/NonAlignEngineDataSet.java | 5 +- .../dataset/RawQueryDataSetWithValueFilter.java | 22 +- .../dataset/RawQueryDataSetWithoutValueFilter.java | 5 +- .../db/query/dataset/ShowTimeSeriesResult.java | 71 + .../dataset/groupby/GroupByEngineDataSet.java | 20 +- .../db/query/dataset/groupby/GroupByExecutor.java | 5 +- .../query/dataset/groupby/GroupByFillDataSet.java | 119 + .../groupby/GroupByWithValueFilterDataSet.java | 35 +- .../groupby/GroupByWithoutValueFilterDataSet.java | 38 +- .../dataset/groupby/LocalGroupByExecutor.java | 54 +- .../db/query/executor/AggregationExecutor.java | 71 +- .../iotdb/db/query/executor/FillQueryExecutor.java | 17 +- .../iotdb/db/query/executor/IQueryRouter.java | 19 +- .../iotdb/db/query/executor/LastQueryExecutor.java | 98 +- .../iotdb/db/query/executor/QueryRouter.java | 45 +- .../db/query/executor/RawDataQueryExecutor.java | 47 +- .../adapter/ByTimestampReaderAdapter.java | 46 +- .../java/org/apache/iotdb/db/query/fill/IFill.java | 21 +- .../org/apache/iotdb/db/query/fill/LinearFill.java | 27 +- .../apache/iotdb/db/query/fill/PreviousFill.java | 231 +- .../db/query/reader/chunk/ChunkReaderWrap.java | 10 +- .../db/query/reader/chunk/DiskChunkLoader.java | 7 +- .../reader/chunk/DiskChunkReaderByTimestamp.java | 55 +- .../db/query/reader/chunk/MemChunkLoader.java | 7 +- .../db/query/reader/chunk/MemChunkReader.java | 3 +- .../iotdb/db/query/reader/chunk/MemPageReader.java | 5 + .../chunk/metadata/DiskChunkMetadataLoader.java | 82 + .../chunk/metadata/MemChunkMetadataLoader.java | 68 + .../db/query/reader/series/IAggregateReader.java | 8 + .../db/query/reader/series/IReaderByTimestamp.java | 14 +- .../query/reader/series/SeriesAggregateReader.java | 39 +- .../reader/series/SeriesRawDataBatchReader.java | 33 +- .../iotdb/db/query/reader/series/SeriesReader.java | 450 +- .../reader/series/SeriesReaderByTimestamp.java | 53 +- .../query/timegenerator/ServerTimeGenerator.java | 12 +- .../java/org/apache/iotdb/db/service/IoTDB.java | 18 +- .../apache/iotdb/db/service/IoTDBShutdownHook.java | 2 +- .../iotdb/db/service/JDBCServiceEventHandler.java | 59 - .../org/apache/iotdb/db/service/JMXService.java | 56 +- .../org/apache/iotdb/db/service/MQTTService.java | 103 + .../apache/iotdb/db/service/MetricsService.java | 5 +- .../service/{JDBCService.java => RPCService.java} | 109 +- ...{JDBCServiceMBean.java => RPCServiceMBean.java} | 4 +- .../org/apache/iotdb/db/service/ServiceType.java | 3 +- .../org/apache/iotdb/db/service/StartupChecks.java | 9 +- .../org/apache/iotdb/db/service/TSServiceImpl.java | 203 +- .../iotdb/db/sync/receiver/SyncServerManager.java | 29 +- .../db/sync/thrift/SyncServiceEventHandler.java | 56 - .../apache/iotdb/db/tools/TsFileSketchTool.java | 140 +- .../db/tools/memestimation/MemEstToolCmd.java | 5 +- .../iotdb/db/tools/upgrade/OfflineUpgradeTool.java | 68 - .../org/apache/iotdb/db/utils/FileLoaderUtils.java | 169 +- .../org/apache/iotdb/db/utils/FilePathUtils.java | 1 + .../java/org/apache/iotdb/db/utils/MemUtils.java | 48 +- .../java/org/apache/iotdb/db/utils/MergeUtils.java | 57 +- .../java/org/apache/iotdb/db/utils/QueryUtils.java | 22 +- .../org/apache/iotdb/db/utils/SchemaUtils.java | 45 +- .../db/writelog/node/ExclusiveWriteLogNode.java | 8 +- .../iotdb/db/writelog/recover/LogReplayer.java | 46 +- .../writelog/recover/TsFileRecoverPerformer.java | 128 +- .../org.apache.iotdb.db.mqtt.PayloadFormatter | 9 +- ...sorTest.java => LocalFileRoleAccessorTest.java} | 2 +- .../db/concurrent/IoTDBThreadPoolFactoryTest.java | 36 +- .../conf/adapter/ActiveTimeSeriesCounterTest.java | 19 +- .../iotdb/db/engine/MetadataManagerHelper.java | 42 +- ...aCacheTest.java => ChunkMetadataCacheTest.java} | 22 +- .../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 | 9 +- .../engine/merge/MaxFileMergeFileSelectorTest.java | 6 +- .../merge/MaxSeriesMergeFileSelectorTest.java | 21 +- .../apache/iotdb/db/engine/merge/MergeLogTest.java | 2 + .../iotdb/db/engine/merge/MergeOverLapTest.java | 9 +- .../apache/iotdb/db/engine/merge/MergeTest.java | 14 +- .../iotdb/db/engine/merge/MergeUpgradeTest.java | 13 +- .../engine/modification/DeletionFileNodeTest.java | 48 +- .../db/engine/modification/DeletionQueryTest.java | 44 +- .../storagegroup/FileNodeManagerBenchmark.java | 7 +- .../storagegroup/StorageGroupProcessorTest.java | 24 +- .../iotdb/db/engine/storagegroup/TTLTest.java | 36 +- .../engine/storagegroup/TsFileProcessorTest.java | 67 +- .../iotdb/db/integration/IOTDBGroupByIT.java | 35 +- .../db/integration/IoTDBAggregationDeleteIT.java | 98 + .../iotdb/db/integration/IoTDBAggregationIT.java | 12 +- .../integration/IoTDBAggregationLargeDataIT.java | 58 +- .../iotdb/db/integration/IoTDBAlignByDeviceIT.java | 2 +- .../db/integration/IoTDBAutoCreateSchemaIT.java | 2 - .../iotdb/db/integration/IoTDBCompleteIT.java | 9 +- .../apache/iotdb/db/integration/IoTDBDaemonIT.java | 38 +- .../iotdb/db/integration/IoTDBDeletionIT.java | 21 +- .../db/integration/IoTDBEngineTimeGeneratorIT.java | 26 +- .../apache/iotdb/db/integration/IoTDBFillIT.java | 393 +- ...yMergeTest.java => IoTDBFlushQueryMergeIT.java} | 5 +- .../iotdb/db/integration/IoTDBGroupByFillIT.java | 545 + .../apache/iotdb/db/integration/IoTDBLastIT.java | 80 +- ...ileTest.java => IoTDBLoadExternalTsfileIT.java} | 49 +- .../iotdb/db/integration/IoTDBMergeTest.java | 3 +- .../iotdb/db/integration/IoTDBMetadataFetchIT.java | 18 +- .../IoTDBMultiOverlappedChunkInUnseqIT.java | 109 + .../db/integration/IoTDBMultiOverlappedPageIT.java | 146 + .../iotdb/db/integration/IoTDBMultiSeriesIT.java | 7 +- .../db/integration/IoTDBOverlappedPageIT.java | 131 + .../iotdb/db/integration/IoTDBRestartIT.java | 145 + .../IoTDBSameMeasurementsDifferentTypesIT.java | 190 + .../db/integration/IoTDBSequenceDataQueryIT.java | 17 +- .../iotdb/db/integration/IoTDBSeriesReaderIT.java | 26 +- ...impleQueryTest.java => IoTDBSimpleQueryIT.java} | 27 +- .../apache/iotdb/db/integration/IoTDBTagIT.java | 835 + .../iotdb/db/metadata/MManagerAdvancedTest.java | 65 +- .../iotdb/db/metadata/MManagerBasicTest.java | 23 +- .../iotdb/db/metadata/MManagerImproveTest.java | 29 +- .../org/apache/iotdb/db/metadata/MTreeTest.java | 136 +- .../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 + .../iotdb/db/qp/plan/LogicalPlanSmallTest.java | 15 +- .../apache/iotdb/db/qp/plan/PhysicalPlanTest.java | 201 +- .../db/query/control/FileReaderManagerTest.java | 4 +- .../iotdb/db/query/reader/ReaderTestHelper.java | 2 +- .../reader/series/SeriesAggregateReaderTest.java | 76 +- .../reader/series/SeriesReaderByTimestampTest.java | 10 +- .../db/query/reader/series/SeriesReaderTest.java | 25 +- .../query/reader/series/SeriesReaderTestUtil.java | 18 +- .../apache/iotdb/db/sql/CheckPathValidityTest.java | 49 + .../db/sync/receiver/load/FileLoaderTest.java | 22 +- .../recover/SyncReceiverLogAnalyzerTest.java | 26 +- .../apache/iotdb/db/utils/EnvironmentUtils.java | 10 +- .../apache/iotdb/db/writelog/PerformanceTest.java | 21 +- .../iotdb/db/writelog/recover/LogReplayerTest.java | 53 +- .../db/writelog/recover/SeqTsFileRecoverTest.java | 89 +- .../writelog/recover/UnseqTsFileRecoverTest.java | 77 +- server/src/test/resources/logback.xml | 4 + service-rpc/pom.xml | 55 + service-rpc/rpc-changelist.md | 3 + .../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 + service-rpc/src/main/thrift/rpc.thrift | 19 + session/pom.xml | 1 + .../main/java/org/apache/iotdb/session/Config.java | 13 - .../java/org/apache/iotdb/session/Session.java | 93 +- .../org/apache/iotdb/session/SessionUtils.java | 4 +- .../org/apache/iotdb/session/pool/SessionPool.java | 119 +- .../iotdb/session/CheckPathValidityTest.java | 49 - .../org/apache/iotdb/session/IoTDBSessionIT.java | 159 +- .../apache/iotdb/session/pool/SessionPoolTest.java | 4 +- site/README-zh.md | 206 + site/README.md | 207 + site/pom.xml | 389 + site/src/main/.vuepress/config.js | 901 + 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 | 303 + .../.vuepress/theme/global-components/IoTDBZH.vue | 295 + 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/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 +- .../apache/iotdb/spark/db/EnvironmentUtils.java | 5 +- spark-tsfile/README.md | 2 +- .../tsfile/qp/optimizer/PhysicalOptimizer.java | 39 +- .../apache/iotdb/spark/tsfile/DefaultSource.scala | 6 +- .../iotdb/spark/tsfile/NarrowConverter.scala | 24 +- .../apache/iotdb/spark/tsfile/WideConverter.scala | 36 +- .../org/apache/iotdb/spark/tsfile/package.scala | 10 +- .../org/apache/iotdb/spark/tool/TsFileExample.java | 13 +- .../apache/iotdb/spark/tool/TsFileWriteTool.java | 39 +- .../apache/iotdb/spark/tsfile/ConverterTest.scala | 6 +- .../org/apache/iotdb/spark/tsfile/TSFileSuit.scala | 78 +- tsfile/format-changelist.md | 13 +- tsfile/pom.xml | 55 + .../apache/iotdb/tsfile/common/cache/Cache.java | 1 + .../iotdb/tsfile/common/conf/TSFileConfig.java | 37 +- .../iotdb/tsfile/common/conf/TSFileDescriptor.java | 39 +- .../tsfile/common/constant/JsonFormatConstant.java | 6 +- .../tsfile/common/constant/QueryConstant.java | 3 +- .../tsfile/common/constant/TsFileConstant.java | 3 +- .../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 +- ...tion.java => NotCompatibleTsFileException.java} | 5 +- .../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 | 37 +- .../iotdb/tsfile/file/header/PageHeader.java | 10 + .../iotdb/tsfile/file/header/package-info.java | 9 +- .../tsfile/file/metadata/ChunkGroupMetaData.java | 178 - .../metadata/ChunkGroupMetadata.java} | 29 +- .../{ChunkMetaData.java => ChunkMetadata.java} | 30 +- .../tsfile/file/metadata/TimeseriesMetadata.java | 128 + .../tsfile/file/metadata/TsDeviceMetadata.java | 142 - .../file/metadata/TsDeviceMetadataIndex.java | 163 - .../iotdb/tsfile/file/metadata/TsFileMetaData.java | 423 - .../iotdb/tsfile/file/metadata/TsFileMetadata.java | 226 + .../tsfile/file/metadata/enums/TSDataType.java | 18 +- .../tsfile/file/metadata/enums/TSFreqType.java | 61 - .../file/metadata/statistics/BinaryStatistics.java | 28 +- .../metadata/statistics/BooleanStatistics.java | 25 +- .../file/metadata/statistics/DoubleStatistics.java | 41 +- .../file/metadata/statistics/FloatStatistics.java | 33 +- .../metadata/statistics/IntegerStatistics.java | 33 +- .../file/metadata/statistics/LongStatistics.java | 33 +- .../file/metadata/statistics/Statistics.java | 56 +- .../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 + .../iotdb/tsfile/read/TsFileRestorableReader.java | 18 +- .../iotdb/tsfile/read/TsFileSequenceReader.java | 553 +- .../iotdb/tsfile/read/UnClosedTsFileReader.java | 16 +- .../apache/iotdb/tsfile/read/common/BatchData.java | 12 + .../org/apache/iotdb/tsfile/read/common/Chunk.java | 4 +- .../org/apache/iotdb/tsfile/read/common/Field.java | 5 +- .../org/apache/iotdb/tsfile/read/common/Path.java | 37 +- .../apache/iotdb/tsfile/read/common/TimeRange.java | 18 +- .../read/controller/CachedChunkLoaderImpl.java | 15 +- .../iotdb/tsfile/read/controller/IChunkLoader.java | 4 +- ...IChunkLoader.java => IChunkMetadataLoader.java} | 14 +- .../tsfile/read/controller/IMetadataQuerier.java | 18 +- .../read/controller/MetadataQuerierByFileImpl.java | 190 +- .../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 | 13 +- .../query/executor/ExecutorWithTimeGenerator.java | 35 +- .../tsfile/read/query/executor/TsFileExecutor.java | 16 +- .../read/query/timegenerator/TimeGenerator.java | 44 +- .../query/timegenerator/TsFileTimeGenerator.java | 6 +- .../read/query/timegenerator/node/AndNode.java | 99 +- .../read/query/timegenerator/node/LeafNode.java | 65 +- .../tsfile/read/query/timegenerator/node/Node.java | 5 +- .../read/query/timegenerator/node/OrNode.java | 119 +- .../iotdb/tsfile/read/reader/IChunkReader.java | 2 +- .../iotdb/tsfile/read/reader/IPageReader.java | 2 + ...faultTsFileInput.java => LocalTsFileInput.java} | 4 +- .../iotdb/tsfile/read/reader/TsFileInput.java | 71 +- .../tsfile/read/reader/chunk/ChunkReader.java | 4 +- .../iotdb/tsfile/read/reader/page/PageReader.java | 5 + .../reader/series/AbstractFileSeriesReader.java | 20 +- .../read/reader/series/EmptyFileSeriesReader.java | 6 +- .../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 +- .../java/org/apache/iotdb/tsfile/utils/Pair.java | 4 +- .../org/apache/iotdb/tsfile/utils/PublicBAOS.java | 13 +- .../tsfile/utils/ReadWriteForEncodingUtils.java | 65 +- .../iotdb/tsfile/utils/ReadWriteIOUtils.java | 86 +- .../apache/iotdb/tsfile/utils/StringContainer.java | 63 +- .../apache/iotdb/tsfile/utils/VersionUtils.java | 37 +- .../apache/iotdb/tsfile/write/TsFileWriter.java | 139 +- .../tsfile/write/chunk/ChunkGroupWriterImpl.java | 9 +- .../iotdb/tsfile/write/chunk/ChunkWriterImpl.java | 2 +- .../tsfile/write/chunk/IChunkGroupWriter.java | 1 - .../apache/iotdb/tsfile/write/page/PageWriter.java | 30 +- .../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 | 49 +- .../apache/iotdb/tsfile/write/schema/Schema.java | 139 +- .../iotdb/tsfile/write/schema/SchemaBuilder.java | 93 - .../write/writer/ForceAppendTsFileWriter.java | 39 +- ...ultTsFileOutput.java => LocalTsFileOutput.java} | 16 +- .../write/writer/RestorableTsFileIOWriter.java | 191 +- .../iotdb/tsfile/write/writer/TsFileIOWriter.java | 330 +- .../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 | 24 +- .../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 - ...leMetaDataTest.java => TsFileMetadataTest.java} | 27 +- .../metadata/statistics/BooleanStatisticsTest.java | 27 +- .../metadata/statistics/DoubleStatisticsTest.java | 29 +- .../metadata/statistics/FloatStatisticsTest.java | 35 +- .../metadata/statistics/IntegerStatisticsTest.java | 29 +- .../metadata/statistics/LongStatisticsTest.java | 32 +- .../metadata/statistics/StringStatisticsTest.java | 33 +- .../tsfile/file/metadata/utils/TestHelper.java | 62 +- .../iotdb/tsfile/file/metadata/utils/Utils.java | 100 +- .../iotdb/tsfile/read/ReadInPartitionTest.java | 112 +- .../iotdb/tsfile/read/ReadOnlyTsFileTest.java | 36 +- .../org/apache/iotdb/tsfile/read/ReadTest.java | 48 +- .../iotdb/tsfile/read/TimePlainEncodeReadTest.java | 67 +- .../tsfile/read/TsFileRestorableReaderTest.java | 8 +- .../tsfile/read/TsFileSequenceReaderTest.java | 57 +- .../apache/iotdb/tsfile/read/common/PathTest.java | 2 - .../iotdb/tsfile/read/common/TimeRangeTest.java | 35 +- .../tsfile/read/controller/ChunkLoaderTest.java | 19 +- .../controller/IMetadataQuerierByFileImplTest.java | 97 +- .../read/filter/IExpressionOptimizerTest.java | 109 +- .../read/filter/MinTimeMaxTimeFilterTest.java | 4 +- .../iotdb/tsfile/read/filter/OperatorTest.java | 12 +- .../tsfile/read/filter/StatisticsFilterTest.java | 8 +- .../read/query/executor/QueryExecutorTest.java | 39 +- .../tsfile/read/query/timegenerator/NodeTest.java | 30 +- .../query/timegenerator}/ReadWriteTest.java | 11 +- .../query/timegenerator/ReaderByTimestampTest.java | 8 +- .../timegenerator}/TimeGeneratorReadEmptyTest.java | 8 +- .../timegenerator}/TimeGeneratorReadWriteTest.java | 8 +- .../TsFileGeneratorForSeriesReaderByTimestamp.java | 52 +- .../tsfile/read/reader/FakedMultiBatchReader.java} | 42 +- .../tsfile/read/reader/FakedTimeGenerator.java | 73 + .../iotdb/tsfile/read/reader/ReaderTest.java | 14 +- .../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 | 79 +- .../org/apache/iotdb/tsfile/write/PerfTest.java | 53 +- .../iotdb/tsfile/write/ReadPageInMemTest.java | 37 +- ...ameMeasurementsWithDifferentDataTypesTest.java} | 105 +- .../iotdb/tsfile/write/TsFileIOWriterTest.java | 33 +- .../iotdb/tsfile/write/TsFileReadWriteTest.java | 83 +- .../iotdb/tsfile/write/TsFileWriterTest.java | 23 +- .../org/apache/iotdb/tsfile/write/WriteTest.java | 77 +- .../write/schema/converter/SchemaBuilderTest.java | 80 +- .../write/writer/ForceAppendTsFileWriterTest.java | 61 + .../iotdb/tsfile/write/writer/PageWriterTest.java | 20 +- .../write/writer/RestorableTsFileIOWriterTest.java | 161 +- tsfile/src/test/resources/logback.xml | 12 +- 786 files changed, 26065 insertions(+), 72104 deletions(-)
