You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ge...@apache.org on 2020/11/03 02:39:27 UTC
[iotdb] branch http_v2 updated (36f3b31 -> b362400)
This is an automated email from the ASF dual-hosted git repository.
geniuspig pushed a change to branch http_v2
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from 36f3b31 update according to review
add a1adaf2 [Sonar] Fix Codesmell blocker and critical issue (#1750)
add 844b4e6 Supplement the document (#1710)
add e77d26a fix LOCAL_JMX to JMX_LOCAL
add a224edc update start-cli bash (#1829)
add 102bd16 [IOTDB-829] Accelerate delete timeseries (#1732)
add ae766b0 [IOTDB-947] Fix error when counting node with wildcard (#1832)
add b323b78 [IOTDB-921] Solve the statement twice call bug (#1784)
add f72064d [IOTDB-928] Make ENCODING optional in create time series sentence (#1785)
add 1c1ccb6 rm update in md (#1835)
add 90ff56a IOTDB-932 Removed (wrong and redundant) Verification of Paths in Session API.
add df48add IOTDB-932 Removed unnecessary Constant PATH_PATTERN and related Test.
add 8ba9284 Trigger
add 6ba9889 Merge pull request #1793 from apache/bugfix/932-wrong-verification
add 48f01b7 [IOTDB-926] Support reconnection of Session (#1821)
add c889776 [IOTDB-845]Enable to stop iotdb server by iotdb.IoTDB (#1633)
add 7755ffc [IOTDB-912] Implement wasNull method in AbstractIoTDBJDBCResultSet (#1791)
add 6511a88 [IOTDB-908] Implement ResultSetMetadata interface for JDBC (#1768)
add b67f669 Add readChunksInDevice method to TsFileSequenceReader (#1765)
add f352932 [IOTDB-942] Optimization of query with long time unsequence page (#1824)
add 74eedae add device chunk point cache (#1758)
add e5f213c [IOTDB-949] fix align by device bug (#1837)
add 64dc16b [IOTDB-927] Remove fastjson introduced by rocketmq (#1782)
add 0964b95 [IOTDB-902] Optimize max_time aggregation and fix order by time desc aggregation bug (#1751)
add 2600bf8 [IOTDB-749] Handle select * from root OOM (#1367)
add bcd8990 [IOTDB-931] update start-cli bash (#1847)
add 8253181 add expression in group by align by device (#1853)
add 4a1dc2d [IOTDB-886]fix float loss precision (#1796)
add ac0af88 Remove duplicate declaration of plugin org.apache.maven.plugins:maven-assembly-plugin in tsfile model (#1852)
add c1fcaa4 add more tracing log
add 0496d75 fix typo
add d40fbcb remove tracing dir reInitial
add efbe467 merge master and fix review comments
add c924847 Merge pull request #1845 from Alima777/addMoreTracing
add 78954ea fix tsfilemanage concurrent bug (#1849)
add c2b6c5a Revert "[IOTDB-955] Add more tracing log" (#1858)
add 3053112 IOTDB-889 (#1857)
add 6fef74a [IOTDB-951] Fix auto-creating schema in parallel may write unrecognizable timeseries in mlog.txt (#1851)
add b52b2e1 update comment of VersionController (#1848)
add 03d37b0 [IOTDB-958] Fix MLog bug and add switch for MTree snapshot (#1863)
add 0c85956 [IOTDB-716] add lz4 doc and support compression=lz4 statement (#1860)
add 35e9d9f minor correction of the "Comparison" documentation (#1871)
add 263b783 Update docs/Documentation-CHN/UserGuide/5-Operation Manual/4-SQL Reference.md
add 63d5b09 Update docs/Documentation/UserGuide/5-Operation Manual/4-SQL Reference.md
add e705465 Merge branch 'master' of https://github.com/apache/iotdb
add 4771a8d Merge pull request #2 from apache/master
add 7dc521a Merge branch 'master' of https://github.com/apache/iotdb
add 145801b Merge branch 'master' of https://github.com/apache/iotdb
add d1daf27 tracing log
add 2b3de88 Merge pull request #1867 from Alima777/tracingLog
add a79f252 add plan index and flush/close listeners (#1850)
add 908e2db [IOTDB-716] add lz4 to cpp and python client (#1870)
add d19de4e upgrade spring boot from 1.5.4 to 1.5.15 (#1861)
add df6dddc fix hot compaction read bug (#1876)
add ea7f6bd fixSeriesReader
add 68901b1 update currentPageEndPointTime
add a132614 fix typo
add 2e6c093 fix typo, add bracket
add 4740090 Merge pull request #1879 from Alima777/fixSeriesReader
add 0698da6 [IOTDB-963] Redo deleteStorageGroupPlan failed when recovering (#1880)
add 0cedde0 A fix for delete that use incorrect way to match partial path (#1882)
add aecbd40 Fix mlog recover log level (#1883)
add 4c8f5fb Temporarily disable website checker (#1887)
add b30b550 Cluster premerge (#1736)
add e1edeb7 fix count timeseries bug (#1891)
add 699998f [IOTDB-872] Use system timezone in CLI (Session) (#1846)
add dc3d9f1 [IOTDB-749] Handle select * from root OOM (#1884)
add 654662f fix a sonar bug (#1897)
add 1b433c1 add more logs in LocalTsFileInput (#1899)
add 8f6f210 fix a sonar bug (#1900)
add 67d6100 [IOTDB-970] Change logback rollingPolicy and triggeringPolicy (#1895)
add 8bacba5 Synchronize the English and Chinese version of "Grafana" doc (#1901)
add bfd5af6 [IOTDB-968] Support time predicate in select last (#1898)
add 6ccb5a0 Update start-cli.sh (#1906)
add 172db70 [IOTDB-938] Re-implement Gorilla encoding algorithm (#1856)
add e897267 Fix open session bug (#1905)
add 26a70b1 correct errors in English documents (#1904)
add 3215d5e support
add ce4a471 fix format
add f25cbd1 remove doller chars in markdown, add latex template for exporting docs to pdf
add 4362188 add apache-rat
add fc0f3f7 [IOTDB-962] Improve the chunk metadata cache process (#1874)
add d1f6357 update hot compaction config name (#1859)
add ebf63b1 [IOTDB-975] Improve readTimeseriesMetadata (#1909)
add 913f0b7 Stop iotdb instance when RPC ip address or port is unavailable (#1868)
add 539b8f1 add debug SQL log (#1912)
add 597d7ce update vue to 1.7.1 and fix shell render name in markdowns (#1911)
add 0cf358c Add restrictions for LAST query filter (#1917)
add b362400 Merge branch 'master' into http_v2
No new revisions were added by this update.
Summary of changes:
.travis.yml | 50 +-
LICENSE | 27 +-
.../org/apache/iotdb/db/qp/strategy/SqlBase.g4 | 7 +-
cli/pom.xml | 13 +
cli/src/assembly/resources/sbin/start-cli.bat | 10 +-
cli/src/assembly/resources/sbin/start-cli.sh | 59 +-
.../java/org/apache/iotdb/cli/AbstractCli.java | 16 +-
.../org/apache/iotdb/cli/StartClientScriptIT.java | 26 +-
cli/src/test/resources/logback.xml | 52 +-
client-cpp/src/main/IOTDBSession.h | 12 +-
client-py/src/utils/IoTDBConstants.py | 4 +-
.../tests/tools/importCsv/AbstractScript.java | 29 +-
.../tests/tools/importCsv/ImportCsvTestIT.java | 65 +--
docs/Development/ContributeGuide.md | 2 +
docs/SystemDesign/TsFile/Format.md | 15 +-
docs/UserGuide/Architecture/Files.md | 12 +-
.../UserGuide/Architecture/Writing Data on HDFS.md | 4 +-
docs/UserGuide/Client/Command Line Interface.md | 4 +-
docs/UserGuide/Client/Programming - JDBC.md | 6 +-
docs/UserGuide/Client/Programming - MQTT.md | 4 +-
docs/UserGuide/Client/Programming - Native API.md | 10 +-
.../Client/Programming - Other Languages.md | 6 +-
docs/UserGuide/Client/Programming - TsFile API.md | 22 +-
docs/UserGuide/Client/Status Codes.md | 2 +-
docs/UserGuide/Comparison/TSDB-Comparison.md | 57 +-
docs/UserGuide/Concept/Compression.md | 6 +-
.../Concept/Data Model and Terminology.md | 6 +-
docs/UserGuide/Concept/Data Type.md | 4 +-
docs/UserGuide/Concept/Encoding.md | 16 +-
docs/UserGuide/Ecosystem Integration/Grafana.md | 21 +-
.../UserGuide/Ecosystem Integration/Hive TsFile.md | 26 +-
.../Ecosystem Integration/MapReduce TsFile.md | 4 +-
.../UserGuide/Ecosystem Integration/Spark IoTDB.md | 2 +-
.../Ecosystem Integration/Spark TsFile.md | 24 +-
.../Get Started/Frequently asked questions.md | 6 +-
docs/UserGuide/Get Started/Publication.md | 6 +-
docs/UserGuide/Get Started/QuickStart.md | 12 +-
docs/UserGuide/Operation Manual/Administration.md | 9 +-
.../DDL Data Definition Language.md | 38 +-
.../DML Data Manipulation Language.md | 42 +-
docs/UserGuide/Operation Manual/SQL Reference.md | 43 +-
docs/UserGuide/Server/Cluster Setup.md | 207 ++++++-
docs/UserGuide/Server/Config Manual.md | 2 +-
docs/UserGuide/Server/ServerFileList.md | 157 ++++++
docs/UserGuide/System Tools/NodeTool.md | 289 ++++++++++
.../System Tools/Performance Tracing Tool.md | 18 +-
docs/zh/SystemDesign/TsFile/Format.md | 12 +-
docs/zh/UserGuide/Concept/Compression.md | 3 +-
docs/zh/UserGuide/Concept/Encoding.md | 14 +-
docs/zh/UserGuide/Ecosystem Integration/Grafana.md | 3 +-
.../UserGuide/Ecosystem Integration/Hive TsFile.md | 2 +-
.../UserGuide/Operation Manual/Administration.md | 1 -
.../DDL Data Definition Language.md | 14 +-
.../DML Data Manipulation Language.md | 8 +-
.../zh/UserGuide/Operation Manual/SQL Reference.md | 39 +-
docs/zh/UserGuide/Server/Cluster Setup.md | 197 ++++++-
docs/zh/UserGuide/Server/Config Manual.md | 4 +-
docs/zh/UserGuide/Server/Docker Image.md | 2 +-
docs/zh/UserGuide/Server/ServerFileList.md | 153 ++++++
docs/zh/UserGuide/System Tools/NodeTool.md | 294 ++++++++++
.../System Tools/Performance Tracing Tool.md | 16 +-
docs/zh/chinese-render-template.latex | 220 ++++++++
.../iotdb/hadoop/tsfile/TSFMRReadExample.java | 1 -
.../iotdb/hadoop/tsfile/TSMRWriteExample.java | 6 +-
example/rocketmq/pom.xml | 6 +
.../java/org/apache/iotdb/rocketmq/Constant.java | 17 +-
.../main/java/org/apache/iotdb/SessionExample.java | 58 +-
.../apache/iotdb/tsfile/TsFileWriteWithTablet.java | 6 +-
grafana/pom.xml | 6 +-
.../apache/iotdb/hadoop/fileSystem/HDFSFile.java | 59 +-
.../org/apache/iotdb/hive/TsFileDeserializer.java | 17 +-
.../iotdb/jdbc/AbstractIoTDBJDBCResultSet.java | 19 +-
.../main/java/org/apache/iotdb/jdbc/Config.java | 2 +-
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 35 +-
.../org/apache/iotdb/jdbc/IoTDBDataSource.java | 12 +-
.../iotdb/jdbc/IoTDBNonAlignJDBCResultSet.java | 8 +-
.../org/apache/iotdb/jdbc/IoTDBResultMetadata.java | 46 +-
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 78 ++-
.../apache/iotdb/jdbc/IoTDBJDBCResultSetTest.java | 28 +-
.../apache/iotdb/jdbc/IoTDBResultMetadataTest.java | 4 +-
.../resources/conf/iotdb-engine.properties | 59 +-
server/src/assembly/resources/conf/iotdb-env.bat | 70 ++-
server/src/assembly/resources/conf/logback.xml | 104 ++--
.../src/assembly/resources/sbin/start-server.bat | 3 +-
server/src/assembly/resources/sbin/stop-server.bat | 17 +-
server/src/assembly/resources/sbin/stop-server.sh | 11 +-
.../iotdb/db/auth/authorizer/BasicAuthorizer.java | 1 -
.../iotdb/db/auth/authorizer/OpenIdAuthorizer.java | 23 +-
.../iotdb/db/auth/user/BasicUserManager.java | 4 +-
.../iotdb/db/auth/user/LocalFileUserAccessor.java | 21 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 223 ++++++--
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 119 ++--
.../iotdb/db/cost/statistic/Measurement.java | 29 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 156 ++++--
.../iotdb/db/engine/cache/ChunkMetadataCache.java | 33 +-
.../db/engine/fileSystem/SystemFileFactory.java | 15 +-
.../flush/CloseFileListener.java} | 11 +-
.../flush/FlushListener.java} | 30 +-
.../iotdb/db/engine/flush/TsFileFlushPolicy.java | 2 +-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 62 ++-
.../apache/iotdb/db/engine/memtable/IMemTable.java | 16 +-
.../db/engine/memtable/PrimitiveMemTable.java | 1 -
.../iotdb/db/engine/merge/manage/MergeManager.java | 33 +-
.../db/engine/merge/manage/MergeResource.java | 8 +-
.../iotdb/db/engine/merge/task/MergeFileTask.java | 9 +
.../engine/modification/io/ModificationReader.java | 1 -
.../engine/modification/io/ModificationWriter.java | 1 -
.../db/engine/querycontext/ReadOnlyMemChunk.java | 5 +-
.../engine/storagegroup/StorageGroupProcessor.java | 472 ++++++----------
.../db/engine/storagegroup/TsFileProcessor.java | 91 +++-
.../db/engine/storagegroup/TsFileResource.java | 50 +-
.../HotCompactionMergeTaskPoolManager.java | 9 +-
.../engine/tsfilemanagement/TsFileManagement.java | 247 +++++++++
.../level/LevelTsFileManagement.java | 192 +++----
.../tsfilemanagement/utils/HotCompactionUtils.java | 268 +++++----
.../apache/iotdb/db/engine/upgrade/UpgradeLog.java | 9 +-
.../iotdb/db/engine/upgrade/UpgradeTask.java | 2 +-
.../version/SimpleFileVersionController.java | 4 +-
.../iotdb/db/engine/version/VersionController.java | 8 +-
...ception.java => DataTypeMismatchException.java} | 18 +-
.../exception/metadata/PathNotExistException.java | 14 +-
...ception.java => PathNumOverLimitException.java} | 23 +-
.../db/exception/runtime/SQLParserException.java | 5 +-
.../org/apache/iotdb/db/metadata/MLogWriter.java | 107 ++--
.../org/apache/iotdb/db/metadata/MManager.java | 141 +++--
.../java/org/apache/iotdb/db/metadata/MTree.java | 110 +++-
.../org/apache/iotdb/db/metadata/MetaUtils.java | 2 +-
.../org/apache/iotdb/db/metadata/PartialPath.java | 63 ++-
.../org/apache/iotdb/db/metadata/TagLogFile.java | 15 +-
.../org/apache/iotdb/db/metadata/mnode/MNode.java | 2 +-
.../apache/iotdb/db/metrics/server/JettyUtil.java | 4 +-
.../iotdb/db/metrics/server/MetricsSystem.java | 2 +-
.../iotdb/db/metrics/server/ServerArgument.java | 2 +-
.../apache/iotdb/db/metrics/sink/ConsoleSink.java | 2 +-
.../iotdb/db/metrics/sink/MetricsServletSink.java | 6 +-
.../apache/iotdb/db/metrics/source/JvmSource.java | 14 +-
.../iotdb/db/metrics/source/MetricsSource.java | 26 +-
.../apache/iotdb/db/metrics/ui/MetricsPage.java | 2 +-
.../apache/iotdb/db/metrics/ui/MetricsWebUI.java | 2 +-
.../org/apache/iotdb/db/monitor/IStatistic.java | 1 -
.../org/apache/iotdb/db/monitor/StatMonitor.java | 19 +-
.../apache/iotdb/db/mqtt/BrokerAuthenticator.java | 2 +-
.../apache/iotdb/db/mqtt/JSONPayloadFormatter.java | 1 -
.../apache/iotdb/db/mqtt/PayloadFormatManager.java | 1 -
.../org/apache/iotdb/db/mqtt/PayloadFormatter.java | 1 -
.../main/java/org/apache/iotdb/db/qp/Planner.java | 39 +-
.../apache/iotdb/db/qp/constant/DatetimeUtils.java | 3 +-
.../apache/iotdb/db/qp/constant/SQLConstant.java | 3 -
.../apache/iotdb/db/qp/executor/IPlanExecutor.java | 3 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 168 +++---
.../db/qp/logical/crud/BasicOperatorType.java | 3 +-
.../iotdb/db/qp/logical/crud/QueryOperator.java | 3 +-
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 26 +-
.../db/qp/physical/crud/DeletePartitionPlan.java | 3 +-
.../iotdb/db/qp/physical/crud/DeletePlan.java | 9 +-
.../db/qp/physical/crud/GroupByTimeFillPlan.java | 3 +-
.../iotdb/db/qp/physical/crud/InsertPlan.java | 53 +-
.../iotdb/db/qp/physical/crud/InsertRowPlan.java | 51 +-
.../db/qp/physical/crud/InsertTabletPlan.java | 177 +++++-
.../iotdb/db/qp/physical/crud/LastQueryPlan.java | 25 +
.../iotdb/db/qp/physical/crud/QueryPlan.java | 1 +
.../db/qp/physical/crud/RawDataQueryPlan.java | 3 +-
.../iotdb/db/qp/physical/crud/UpdatePlan.java | 17 +-
.../db/qp/physical/sys/AlterTimeSeriesPlan.java | 144 ++++-
.../iotdb/db/qp/physical/sys/AuthorPlan.java | 15 +-
.../iotdb/db/qp/physical/sys/ClearCachePlan.java | 4 +-
.../apache/iotdb/db/qp/physical/sys/CountPlan.java | 1 -
.../qp/physical/sys/CreateMultiTimeSeriesPlan.java | 21 +-
.../db/qp/physical/sys/CreateSnapshotPlan.java | 5 +-
.../db/qp/physical/sys/CreateTimeSeriesPlan.java | 12 +-
.../iotdb/db/qp/physical/sys/DataAuthPlan.java | 7 +-
.../db/qp/physical/sys/DeleteStorageGroupPlan.java | 6 +
.../db/qp/physical/sys/DeleteTimeSeriesPlan.java | 11 +
.../apache/iotdb/db/qp/physical/sys/FlushPlan.java | 209 +++++++-
.../db/qp/physical/sys/LoadConfigurationPlan.java | 6 +-
.../iotdb/db/qp/physical/sys/LoadDataPlan.java | 10 +-
.../apache/iotdb/db/qp/physical/sys/MergePlan.java | 5 +-
.../iotdb/db/qp/physical/sys/OperateFilePlan.java | 3 +-
.../db/qp/physical/sys/SetStorageGroupPlan.java | 15 +-
.../iotdb/db/qp/physical/sys/SetTTLPlan.java | 9 +-
.../apache/iotdb/db/qp/physical/sys/ShowPlan.java | 3 +-
.../db/qp/physical/sys/ShowTimeSeriesPlan.java | 4 +
.../iotdb/db/qp/physical/sys/TracingPlan.java | 4 +-
.../iotdb/db/qp/strategy/LogicalGenerator.java | 30 +-
.../iotdb/db/qp/strategy/PhysicalGenerator.java | 57 +-
.../qp/strategy/optimizer/ConcatPathOptimizer.java | 120 ++---
.../qp/strategy/optimizer/ILogicalOptimizer.java | 4 +-
.../optimizer/MergeSingleFilterOptimizer.java | 7 +-
.../db/query/aggregation/AggregateResult.java | 38 +-
.../db/query/aggregation/impl/AvgAggrResult.java | 6 +-
.../db/query/aggregation/impl/CountAggrResult.java | 2 +-
.../aggregation/impl/FirstValueAggrResult.java | 20 +-
...grResult.java => FirstValueDescAggrResult.java} | 66 +--
.../aggregation/impl/LastValueAggrResult.java | 12 +-
...ggrResult.java => LastValueDescAggrResult.java} | 70 +--
.../query/aggregation/impl/MaxTimeAggrResult.java | 25 +-
...eAggrResult.java => MaxTimeDescAggrResult.java} | 75 +--
.../query/aggregation/impl/MaxValueAggrResult.java | 9 +-
.../query/aggregation/impl/MinTimeAggrResult.java | 23 +-
...tAggrResult.java => MinTimeDescAggrResult.java} | 63 +--
.../query/aggregation/impl/MinValueAggrResult.java | 6 +-
.../db/query/aggregation/impl/SumAggrResult.java | 2 +-
.../iotdb/db/query/context/QueryContext.java | 7 +-
.../iotdb/db/query/control/FileReaderManager.java | 15 +-
.../iotdb/db/query/control/QueryFileManager.java | 9 +-
.../db/query/control/QueryResourceManager.java | 52 +-
.../iotdb/db/query/control/TracingManager.java | 85 ++-
.../db/query/dataset/AlignByDeviceDataSet.java | 3 +-
.../db/query/dataset/ShowTimeseriesDataSet.java | 6 +-
.../dataset/groupby/GroupByEngineDataSet.java | 3 +-
.../db/query/dataset/groupby/GroupByExecutor.java | 5 +-
.../query/dataset/groupby/GroupByFillDataSet.java | 90 ++--
.../groupby/GroupByWithValueFilterDataSet.java | 13 +-
.../groupby/GroupByWithoutValueFilterDataSet.java | 2 +-
.../dataset/groupby/LocalGroupByExecutor.java | 19 +-
.../db/query/executor/AggregationExecutor.java | 89 +--
.../iotdb/db/query/executor/IQueryRouter.java | 10 +-
.../iotdb/db/query/executor/LastQueryExecutor.java | 119 ++--
.../db/query/executor/RawDataQueryExecutor.java | 11 +-
.../db/query/executor/fill/LastPointReader.java | 3 +
.../iotdb/db/query/executor/fill/LinearFill.java | 12 +-
.../query/externalsort/ExternalSortJobEngine.java | 7 +-
.../iotdb/db/query/externalsort/LineMerger.java | 2 +-
.../externalsort/SimpleExternalSortEngine.java | 11 +-
.../SingleSourceExternalSortJobPart.java | 2 +-
.../adapter/ByTimestampReaderAdapter.java | 2 +-
.../serialize/IExternalSortFileDeserializer.java | 2 +-
.../FixLengthIExternalSortFileDeserializer.java | 4 +-
.../impl/FixLengthTimeValuePairSerializer.java | 2 +-
.../db/query/factory/AggregateResultFactory.java | 54 +-
.../db/query/reader/chunk/ChunkDataIterator.java | 5 +-
.../db/query/reader/chunk/ChunkReaderWrap.java | 3 +-
.../reader/chunk/DiskChunkReaderByTimestamp.java | 3 +-
.../db/query/reader/chunk/MemChunkLoader.java | 3 +-
.../db/query/reader/chunk/MemChunkReader.java | 7 +-
.../chunk/metadata/DiskChunkMetadataLoader.java | 30 +-
.../chunk/metadata/MemChunkMetadataLoader.java | 3 +-
.../resource/CachedUnseqResourceMergeReader.java | 5 +-
.../reader/series/DescSeriesReaderByTimestamp.java | 53 --
.../db/query/reader/series/IAggregateReader.java | 4 +-
.../query/reader/series/SeriesAggregateReader.java | 4 +
.../reader/series/SeriesRawDataPointReader.java | 3 +-
.../iotdb/db/query/reader/series/SeriesReader.java | 265 +++++++--
.../reader/series/SeriesReaderByTimestamp.java | 25 +-
.../universal/CachedPriorityMergeReader.java | 2 +-
.../reader/universal/PriorityMergeReader.java | 4 +-
.../org/apache/iotdb/db/rescon/MemTablePool.java | 5 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 4 +
.../org/apache/iotdb/db/service/MQTTService.java | 5 +-
.../org/apache/iotdb/db/service/RPCService.java | 21 +-
.../apache/iotdb/db/service/RegisterManager.java | 1 -
.../org/apache/iotdb/db/service/StaticResps.java | 1 +
.../org/apache/iotdb/db/service/TSServiceImpl.java | 144 ++---
.../iotdb/db/service/thrift/ThriftService.java | 3 +-
.../db/service/thrift/ThriftServiceThread.java | 10 +-
.../receiver/recover/SyncReceiverLogAnalyzer.java | 2 +-
.../db/sync/receiver/transfer/SyncServiceImpl.java | 19 +-
.../db/sync/sender/manage/SyncFileManager.java | 22 +-
.../apache/iotdb/db/tools/TsFileSketchTool.java | 1 -
.../java/org/apache/iotdb/db/tools/WalChecker.java | 1 -
.../iotdb/db/tools/memestimation/MemEstTool.java | 1 -
.../org/apache/iotdb/db/utils/CommonUtils.java | 16 +-
.../iotdb/db/utils/EncodingInferenceUtils.java | 57 ++
.../org/apache/iotdb/db/utils/FileLoaderUtils.java | 2 +-
.../java/org/apache/iotdb/db/utils/MathUtils.java | 1 -
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 13 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 88 ++-
.../org/apache/iotdb/db/utils/SerializeUtils.java | 2 +-
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 9 +
.../iotdb/db/utils/datastructure/TVList.java | 2 +-
.../WALFlushListener.java} | 35 +-
.../iotdb/db/writelog/recover/LogReplayer.java | 23 +-
.../db/engine/cache/ChunkMetadataCacheTest.java | 6 +-
.../db/engine/memtable/PrimitiveMemTableTest.java | 9 +-
.../iotdb/db/engine/merge/MergeManagerTest.java | 6 +-
.../apache/iotdb/db/engine/merge/MergeTest.java | 19 +-
.../engine/modification/DeletionFileNodeTest.java | 40 +-
.../db/engine/modification/DeletionQueryTest.java | 71 ++-
.../storagegroup/StorageGroupProcessorTest.java | 108 ++--
.../iotdb/db/engine/storagegroup/TTLTest.java | 6 +-
.../engine/storagegroup/TsFileProcessorTest.java | 9 +-
.../iotdb/db/integration/IOTDBGroupByIT.java | 200 ++++++-
.../integration/IOTDBGroupByInnerIntervalIT.java | 262 +++++----
.../iotdb/db/integration/IoTDBAddSubDeviceIT.java | 11 +-
.../IoTDBAggregationAlignByDeviceIT.java | 113 ----
.../iotdb/db/integration/IoTDBAggregationIT.java | 199 ++++++-
.../integration/IoTDBAggregationLargeDataIT.java | 398 ++++++++++----
.../apache/iotdb/db/integration/IoTDBAliasIT.java | 10 +-
.../iotdb/db/integration/IoTDBAlignByDeviceIT.java | 102 ++++
.../db/integration/IoTDBDeleteStorageGroupIT.java | 90 +++-
.../iotdb/db/integration/IoTDBDeletionIT.java | 29 +
.../iotdb/db/integration/IoTDBGroupByFillIT.java | 596 +++++++++++++--------
.../integration/IoTDBGroupByFillWithRangeIT.java | 21 +-
.../apache/iotdb/db/integration/IoTDBLastIT.java | 103 +++-
.../db/integration/IoTDBLoadExternalTsfileIT.java | 1 +
.../iotdb/db/integration/IoTDBMergeTest.java | 15 +-
.../iotdb/db/integration/IoTDBMultiSeriesIT.java | 34 ++
.../db/integration/IoTDBQueryMemoryControlIT.java | 219 ++++++++
.../db/integration/IoTDBSequenceDataQueryIT.java | 9 +-
.../iotdb/db/integration/IoTDBSeriesReaderIT.java | 11 +-
.../iotdb/db/integration/IoTDBSimpleQueryIT.java | 76 ++-
.../integration/IoTDBSortedShowTimeseriesIT.java | 11 +-
.../iotdb/db/integration/IoTDBTracingTest.java | 6 +-
.../apache/iotdb/db/integration/IoTDBTtlIT.java | 4 +-
.../iotdb/db/metadata/MManagerBasicTest.java | 70 ++-
.../org/apache/iotdb/db/metadata/MTreeTest.java | 31 +-
.../apache/iotdb/db/metadata/PartialPathTest.java | 27 +-
.../iotdb/db/qp/plan/LogicalPlanSmallTest.java | 69 +--
.../apache/iotdb/db/qp/plan/PhysicalPlanTest.java | 38 +-
.../apache/iotdb/db/qp/plan/SerializationTest.java | 68 ++-
.../db/query/aggregation/AggregateResultTest.java | 94 ++--
.../query/executor/GroupByEngineDataSetTest.java | 2 +
.../reader/series/SeriesAggregateReaderTest.java | 19 +-
.../reader/series/SeriesReaderByTimestampTest.java | 19 +-
.../db/query/reader/series/SeriesReaderTest.java | 17 +-
.../query/reader/series/SeriesReaderTestUtil.java | 21 +-
.../apache/iotdb/db/sql/CheckPathValidityTest.java | 53 --
.../db/sync/receiver/load/FileLoaderTest.java | 3 +
.../apache/iotdb/db/utils/EnvironmentUtils.java | 101 ++--
.../iotdb/db/utils/TypeInferenceUtilsTest.java | 4 +-
.../apache/iotdb/db/writelog/WriteLogNodeTest.java | 3 +-
.../iotdb/db/writelog/recover/LogReplayerTest.java | 2 +-
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 23 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 2 +
.../main/java/org/apache/iotdb/session/Config.java | 3 +-
.../java/org/apache/iotdb/session/Session.java | 189 +++++--
.../org/apache/iotdb/session/SessionDataSet.java | 6 +-
.../org/apache/iotdb/session/pool/SessionPool.java | 28 +-
.../iotdb/session/IoTDBSessionComplexIT.java | 54 +-
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 554 ++++++++++---------
.../java/org/apache/iotdb/session/SessionUT.java | 266 ++++-----
.../apache/iotdb/session/pool/SessionPoolTest.java | 6 +-
site/src/main/package.json | 5 +-
.../scala/org/apache/iotdb/spark/db/IoTDBRDD.scala | 4 +-
.../apache/iotdb/spark/db/EnvironmentUtils.java | 14 +-
thrift/rpc-changelist.md | 4 +-
thrift/src/main/thrift/cluster.thrift | 17 +
thrift/src/main/thrift/rpc.thrift | 7 +-
tsfile/pom.xml | 20 -
.../iotdb/tsfile/common/conf/TSFileConfig.java | 32 +-
.../iotdb/tsfile/compress/IUnCompressor.java | 9 +-
.../tsfile/encoding/common/EncodingConfig.java | 42 --
.../iotdb/tsfile/encoding/decoder/Decoder.java | 142 ++---
...nDecoder.java => DoublePrecisionDecoderV1.java} | 20 +-
.../encoding/decoder/DoublePrecisionDecoderV2.java | 51 ++
.../{GorillaDecoder.java => GorillaDecoderV1.java} | 15 +-
.../tsfile/encoding/decoder/GorillaDecoderV2.java | 120 +++++
.../tsfile/encoding/decoder/IntGorillaDecoder.java | 88 +++
.../encoding/decoder/LongGorillaDecoder.java | 87 +++
...nDecoder.java => SinglePrecisionDecoderV1.java} | 21 +-
.../encoding/decoder/SinglePrecisionDecoderV2.java | 51 ++
...nEncoder.java => DoublePrecisionEncoderV1.java} | 17 +-
.../encoding/encoder/DoublePrecisionEncoderV2.java | 53 ++
.../{GorillaEncoder.java => GorillaEncoderV1.java} | 18 +-
.../tsfile/encoding/encoder/GorillaEncoderV2.java | 106 ++++
.../tsfile/encoding/encoder/IntGorillaEncoder.java | 152 ++++++
.../encoding/encoder/LongGorillaEncoder.java | 152 ++++++
...nEncoder.java => SinglePrecisionEncoderV1.java} | 16 +-
.../encoding/encoder/SinglePrecisionEncoderV2.java | 53 ++
.../tsfile/encoding/encoder/TSEncodingBuilder.java | 61 ++-
.../iotdb/tsfile/file/metadata/ChunkMetadata.java | 14 +
.../tsfile/file/metadata/TimeseriesMetadata.java | 13 +-
.../tsfile/file/metadata/enums/TSEncoding.java | 14 +-
.../file/metadata/statistics/BinaryStatistics.java | 22 +-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 71 ++-
.../apache/iotdb/tsfile/read/common/BatchData.java | 30 +-
.../iotdb/tsfile/read/common/DescBatchData.java | 13 +-
.../read/controller/IChunkMetadataLoader.java | 4 +-
.../iotdb/tsfile/read/filter/GroupByFilter.java | 6 +-
.../iotdb/tsfile/read/filter/TimeFilter.java | 2 +-
.../iotdb/tsfile/read/reader/LocalTsFileInput.java | 60 ++-
.../org/apache/iotdb/tsfile/utils/PublicBAOS.java | 5 +-
.../iotdb/tsfile/utils/ReadWriteIOUtils.java | 133 ++---
.../apache/iotdb/tsfile/write/page/PageWriter.java | 4 +-
.../apache/iotdb/tsfile/write/record/Tablet.java | 126 +++--
.../tsfile/write/schema/MeasurementSchema.java | 5 +
...aDecoderTest.java => GorillaDecoderV1Test.java} | 34 +-
.../encoding/decoder/GorillaDecoderV2Test.java | 592 ++++++++++++++++++++
.../tsfile/read/TsFileSequenceReaderTest.java | 40 +-
.../tsfile/read/filter/GroupByFilterTest.java | 2 +-
.../iotdb/tsfile/read/reader/PageReaderTest.java | 24 +-
.../iotdb/tsfile/utils/ReadWriteIOUtilsTest.java | 140 +++++
.../apache/iotdb/tsfile/utils/RecordUtilsTest.java | 100 ++--
.../iotdb/tsfile/utils/TsFileGeneratorForTest.java | 2 +-
.../iotdb/tsfile/write/TsFileReadWriteTest.java | 55 +-
tsfile/src/test/resources/logback.xml | 52 +-
386 files changed, 11728 insertions(+), 4889 deletions(-)
create mode 100644 docs/UserGuide/Server/ServerFileList.md
create mode 100644 docs/UserGuide/System Tools/NodeTool.md
create mode 100644 docs/zh/UserGuide/Server/ServerFileList.md
create mode 100644 docs/zh/UserGuide/System Tools/NodeTool.md
create mode 100644 docs/zh/chinese-render-template.latex
copy server/src/main/java/org/apache/iotdb/db/{service/IoTDBMBean.java => engine/flush/CloseFileListener.java} (74%)
copy server/src/main/java/org/apache/iotdb/db/{query/externalsort/ExternalSortJobPart.java => engine/flush/FlushListener.java} (61%)
copy server/src/main/java/org/apache/iotdb/db/exception/metadata/{AliasAlreadyExistException.java => DataTypeMismatchException.java} (67%)
copy server/src/main/java/org/apache/iotdb/db/exception/query/{QueryProcessException.java => PathNumOverLimitException.java} (50%)
copy server/src/main/java/org/apache/iotdb/db/query/aggregation/impl/{CountAggrResult.java => FirstValueDescAggrResult.java} (53%)
copy server/src/main/java/org/apache/iotdb/db/query/aggregation/impl/{LastValueAggrResult.java => LastValueDescAggrResult.java} (60%)
copy server/src/main/java/org/apache/iotdb/db/query/aggregation/impl/{MaxTimeAggrResult.java => MaxTimeDescAggrResult.java} (53%)
copy server/src/main/java/org/apache/iotdb/db/query/aggregation/impl/{CountAggrResult.java => MinTimeDescAggrResult.java} (51%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/reader/series/DescSeriesReaderByTimestamp.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/utils/EncodingInferenceUtils.java
copy server/src/main/java/org/apache/iotdb/db/{engine/flush/NotifyFlushMemTable.java => writelog/WALFlushListener.java} (53%)
delete mode 100644 server/src/test/java/org/apache/iotdb/db/integration/IoTDBAggregationAlignByDeviceIT.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/integration/IoTDBQueryMemoryControlIT.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/sql/CheckPathValidityTest.java
delete mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/common/EncodingConfig.java
rename tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/decoder/{DoublePrecisionDecoder.java => DoublePrecisionDecoderV1.java} (81%)
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/decoder/DoublePrecisionDecoderV2.java
rename tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/decoder/{GorillaDecoder.java => GorillaDecoderV1.java} (92%)
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/decoder/GorillaDecoderV2.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/decoder/IntGorillaDecoder.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/decoder/LongGorillaDecoder.java
rename tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/decoder/{SinglePrecisionDecoder.java => SinglePrecisionDecoderV1.java} (81%)
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/decoder/SinglePrecisionDecoderV2.java
rename tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/encoder/{DoublePrecisionEncoder.java => DoublePrecisionEncoderV1.java} (83%)
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/encoder/DoublePrecisionEncoderV2.java
rename tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/encoder/{GorillaEncoder.java => GorillaEncoderV1.java} (88%)
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/encoder/GorillaEncoderV2.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/encoder/IntGorillaEncoder.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/encoder/LongGorillaEncoder.java
rename tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/encoder/{SinglePrecisionEncoder.java => SinglePrecisionEncoderV1.java} (84%)
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/encoder/SinglePrecisionEncoderV2.java
rename tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/{GorillaDecoderTest.java => GorillaDecoderV1Test.java} (89%)
create mode 100644 tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/GorillaDecoderV2Test.java
create mode 100644 tsfile/src/test/java/org/apache/iotdb/tsfile/utils/ReadWriteIOUtilsTest.java