You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by xu...@apache.org on 2020/04/23 05:45:31 UTC
[incubator-iotdb] 01/02: Merge branch 'master' of
https://github.com/apache/incubator-iotdb
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 <15...@smail.nju.edu.cn>
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(-)