You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ji...@apache.org on 2019/09/27 05:45:37 UTC
[incubator-iotdb] branch dev_TTL updated (71b2278 -> 08758fe)
This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch dev_TTL
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git.
from 71b2278 fix files in memory are not correctly removed and add tests
add e200739 Avoid creating a new ChunkGroupFooter object. (#413)
add 6c341db Fix data cannot be found when restarting server in HDFS (#412)
add fdc546a update pom (#418)
add 964f744 merge IncompleteFileTestUtil into TsFileGeneratorForTest (#414)
add c0bec96 [IOTDB-239] Add interface for showing devices (#421)
add 68264c3 fix IOTDB-235 (#419)
add 6fe298d Add JMX document (#422)
add 59f66f6 [IOTDB-188] Delete storage group (#416)
add 9bae1f3 Change javdoc to block comment. (#420)
add 39ea67d Fix initial value of minTimestamp to Long.MIN_VALUE in ChunkBuffer (#426)
add 08758fe Merge branch 'master' into dev_TTL
No new revisions were added by this update.
Summary of changes:
Jenkinsfile | 2 +-
.../org/apache/iotdb/client/AbstractClient.java | 2 +-
.../main/java/org/apache/iotdb/client/Client.java | 2 +-
.../java/org/apache/iotdb/client/WinClient.java | 2 +-
.../apache/iotdb/exception/ArgsErrorException.java | 2 +-
.../org/apache/iotdb/tool/AbstractCsvTool.java | 2 +-
.../main/java/org/apache/iotdb/tool/ExportCsv.java | 2 +-
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 2 +-
.../org/apache/iotdb/client/AbstractClientIT.java | 2 +-
.../org/apache/iotdb/client/AbstractScript.java | 2 +-
.../apache/iotdb/client/StartClientScriptIT.java | 2 +-
.../org/apache/iotdb/tool/ExportCsvTestIT.java | 2 +-
.../org/apache/iotdb/tool/ImportCsvTestIT.java | 2 +-
.../UserGuide/7-Session API/1-Session API.md | 154 +++++-------
.../UserGuide/9-System Tools/3-JMX Tool.md} | 16 +-
docs/Documentation/UserGuide/0-Content.md | 1 +
.../UserGuide/6-JDBC API/1-JDBC API.md | 11 +-
.../UserGuide/7-Session API/1-Session API.md | 154 ++++--------
.../3-JMX Tool.md} | 16 +-
.../main/java/org/apache/iotdb/JDBCExample.java | 2 +-
.../org/apache/iotdb/PrepareStatementDemo.java | 2 +-
.../main/java/org/apache/iotdb/kafka/Constant.java | 2 +-
.../java/org/apache/iotdb/kafka/KafkaConsumer.java | 2 +-
.../apache/iotdb/kafka/KafkaConsumerThread.java | 2 +-
.../java/org/apache/iotdb/kafka/KafkaProducer.java | 2 +-
.../java/org/apache/iotdb/rocketmq/Constant.java | 2 +-
.../apache/iotdb/rocketmq/RocketMQConsumer.java | 2 +-
.../apache/iotdb/rocketmq/RocketMQProducer.java | 2 +-
.../main/java/org/apache/iotdb/rocketmq/Utils.java | 2 +-
.../main/java/org/apache/iotdb/SessionExample.java | 2 +-
.../java/org/apache/iotdb/tsfile/TsFileRead.java | 2 +-
.../apache/iotdb/tsfile/TsFileSequenceRead.java | 2 +-
.../org/apache/iotdb/tsfile/TsFileSketchTool.java | 2 +-
.../iotdb/tsfile/TsFileWriteWithRowBatch.java | 2 +-
.../iotdb/tsfile/TsFileWriteWithTSRecord.java | 2 +-
.../web/grafana/TsfileWebDemoApplication.java | 2 +-
.../apache/iotdb/web/grafana/bean/TimeValues.java | 2 +-
.../iotdb/web/grafana/conf/MyConfiguration.java | 2 +-
.../controller/DatabaseConnectController.java | 2 +-
.../org/apache/iotdb/web/grafana/dao/BasicDao.java | 2 +-
.../iotdb/web/grafana/dao/impl/BasicDaoImpl.java | 2 +-
.../grafana/service/DatabaseConnectService.java | 2 +-
.../service/impl/DatabaseConnectServiceImpl.java | 2 +-
.../iotdb/tsfile/hadoop/TSFHadoopException.java | 2 +-
.../apache/iotdb/tsfile/hadoop/TSFInputFormat.java | 2 +-
.../apache/iotdb/tsfile/hadoop/TSFInputSplit.java | 2 +-
.../iotdb/tsfile/hadoop/TSFOutputFormat.java | 2 +-
.../iotdb/tsfile/hadoop/TSFRecordReader.java | 2 +-
.../iotdb/tsfile/hadoop/TSFRecordWriter.java | 2 +-
.../java/org/apache/iotdb/tsfile/hadoop/TSRow.java | 2 +-
.../tsfile/hadoop/example/TSFMRReadExample.java | 2 +-
.../iotdb/tsfile/hadoop/example/TsFileHelper.java | 2 +-
.../iotdb/tsfile/hadoop/io/HDFSInputStream.java | 2 +-
.../iotdb/tsfile/hadoop/io/HDFSOutputStream.java | 2 +-
.../thu/tsfile/hadoop/InputOutputStreamTest.java | 2 +-
.../cn/edu/thu/tsfile/hadoop/TSFHadoopTest.java | 2 +-
.../edu/thu/tsfile/hadoop/TSFInputSplitTest.java | 2 +-
.../cn/edu/thu/tsfile/hadoop/TsFileTestHelper.java | 2 +-
.../main/java/org/apache/iotdb/jdbc/Config.java | 2 +-
.../main/java/org/apache/iotdb/jdbc/Constant.java | 28 +--
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 2 +-
.../apache/iotdb/jdbc/IoTDBConnectionParams.java | 2 +-
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 274 ++++-----------------
.../java/org/apache/iotdb/jdbc/IoTDBDriver.java | 2 +-
.../iotdb/jdbc/IoTDBMetadataResultMetadata.java | 2 +-
.../apache/iotdb/jdbc/IoTDBMetadataResultSet.java | 32 ++-
.../apache/iotdb/jdbc/IoTDBPreparedStatement.java | 2 +-
.../org/apache/iotdb/jdbc/IoTDBQueryResultSet.java | 2 +-
.../org/apache/iotdb/jdbc/IoTDBResultMetadata.java | 2 +-
.../org/apache/iotdb/jdbc/IoTDBSQLException.java | 2 +-
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 12 +-
.../org/apache/iotdb/jdbc/IoTDBURLException.java | 2 +-
.../src/main/java/org/apache/iotdb/jdbc/Utils.java | 2 +-
.../test/java/org/apache/iotdb/jdbc/BatchTest.java | 2 +-
.../org/apache/iotdb/jdbc/IoTDBConnectionTest.java | 2 +-
.../iotdb/jdbc/IoTDBDatabaseMetadataTest.java | 106 +++++---
.../jdbc/IoTDBMetadataResultMetadataTest.java | 2 +-
.../iotdb/jdbc/IoTDBPreparedStatementTest.java | 2 +-
.../apache/iotdb/jdbc/IoTDBQueryResultSetTest.java | 2 +-
.../apache/iotdb/jdbc/IoTDBResultMetadataTest.java | 2 +-
.../org/apache/iotdb/jdbc/IoTDBStatementTest.java | 48 ++--
.../test/java/org/apache/iotdb/jdbc/UtilsTest.java | 2 +-
pom.xml | 31 +--
.../org/apache/iotdb/db/auth/AuthException.java | 2 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 2 +-
.../iotdb/db/auth/authorizer/BasicAuthorizer.java | 2 +-
.../iotdb/db/auth/authorizer/IAuthorizer.java | 2 +-
.../db/auth/authorizer/LocalFileAuthorizer.java | 2 +-
.../apache/iotdb/db/auth/entity/PathPrivilege.java | 2 +-
.../apache/iotdb/db/auth/entity/PrivilegeType.java | 2 +-
.../java/org/apache/iotdb/db/auth/entity/Role.java | 2 +-
.../java/org/apache/iotdb/db/auth/entity/User.java | 2 +-
.../iotdb/db/auth/role/BasicRoleManager.java | 2 +-
.../apache/iotdb/db/auth/role/IRoleAccessor.java | 2 +-
.../apache/iotdb/db/auth/role/IRoleManager.java | 2 +-
.../iotdb/db/auth/role/LocalFileRoleAccessor.java | 2 +-
.../iotdb/db/auth/role/LocalFileRoleManager.java | 2 +-
.../iotdb/db/auth/user/BasicUserManager.java | 2 +-
.../apache/iotdb/db/auth/user/IUserAccessor.java | 2 +-
.../apache/iotdb/db/auth/user/IUserManager.java | 2 +-
.../iotdb/db/auth/user/LocalFileUserAccessor.java | 2 +-
.../iotdb/db/auth/user/LocalFileUserManager.java | 2 +-
.../org/apache/iotdb/db/concurrent/HashLock.java | 2 +-
.../IoTDBDefaultThreadExceptionHandler.java | 2 +-
.../db/concurrent/IoTDBThreadPoolFactory.java | 2 +-
.../iotdb/db/concurrent/IoTThreadFactory.java | 2 +-
.../org/apache/iotdb/db/concurrent/ThreadName.java | 2 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 2 +-
.../org/apache/iotdb/db/conf/IoTDBConfigCheck.java | 2 +-
.../org/apache/iotdb/db/conf/IoTDBConstant.java | 2 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 2 +-
.../iotdb/db/conf/adapter/CompressionRatio.java | 2 +-
.../iotdb/db/conf/adapter/IDynamicAdapter.java | 2 +-
.../db/conf/adapter/IoTDBConfigDynamicAdapter.java | 5 +-
.../db/conf/adapter/ManageDynamicParameters.java | 2 +-
.../conf/adapter/ManageDynamicParametersMBean.java | 2 +-
.../db/conf/directories/DirectoryManager.java | 2 +-
.../directories/strategy/DirectoryStrategy.java | 2 +-
.../strategy/MaxDiskUsableSpaceFirstStrategy.java | 2 +-
.../MinFolderOccupiedSpaceFirstStrategy.java | 2 +-
.../directories/strategy/SequenceStrategy.java | 2 +-
.../db/cost/statistic/ConcurrentCircularArray.java | 2 +-
.../iotdb/db/cost/statistic/Measurement.java | 2 +-
.../iotdb/db/cost/statistic/MeasurementMBean.java | 2 +-
.../apache/iotdb/db/cost/statistic/Operation.java | 2 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 6 +
.../iotdb/db/engine/cache/DeviceMetaDataCache.java | 2 +-
.../iotdb/db/engine/cache/LRULinkedHashMap.java | 2 +-
.../iotdb/db/engine/cache/RamUsageEstimator.java | 2 +-
.../iotdb/db/engine/cache/TsFileMetaDataCache.java | 2 +-
.../iotdb/db/engine/cache/TsFileMetadataUtils.java | 2 +-
.../iotdb/db/engine/flush/NotifyFlushMemTable.java | 2 +-
.../db/engine/flush/pool/AbstractPoolManager.java | 2 +-
.../engine/flush/pool/FlushSubTaskPoolManager.java | 2 +-
.../db/engine/flush/pool/FlushTaskPoolManager.java | 2 +-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 2 +-
.../apache/iotdb/db/engine/memtable/IMemTable.java | 2 +-
.../db/engine/memtable/IWritableMemChunk.java | 2 +-
.../db/engine/memtable/PrimitiveMemTable.java | 2 +-
.../iotdb/db/engine/merge/manage/MergeContext.java | 2 +-
.../iotdb/db/engine/merge/manage/MergeManager.java | 2 +-
.../db/engine/merge/manage/MergeResource.java | 2 +-
.../apache/iotdb/db/engine/merge/package-info.java | 2 +-
.../iotdb/db/engine/merge/recover/LogAnalyzer.java | 2 +-
.../iotdb/db/engine/merge/recover/MergeLogger.java | 2 +-
.../merge/selector/IFileQueryMemMeasurement.java | 2 +-
.../engine/merge/selector/IMergeFileSelector.java | 2 +-
.../engine/merge/selector/IMergePathSelector.java | 2 +-
.../merge/selector/MaxFileMergeFileSelector.java | 2 +-
.../merge/selector/MaxSeriesMergeFileSelector.java | 2 +-
.../engine/merge/selector/MergeFileStrategy.java | 2 +-
.../engine/merge/selector/NaivePathSelector.java | 2 +-
.../iotdb/db/engine/merge/task/MergeCallback.java | 2 +-
.../iotdb/db/engine/merge/task/MergeFileTask.java | 2 +-
.../db/engine/merge/task/MergeMultiChunkTask.java | 2 +-
.../iotdb/db/engine/merge/task/MergeTask.java | 2 +-
.../db/engine/merge/task/RecoverMergeTask.java | 2 +-
.../iotdb/db/engine/modification/Deletion.java | 2 +-
.../iotdb/db/engine/modification/Modification.java | 2 +-
.../db/engine/modification/ModificationFile.java | 2 +-
.../io/LocalTextModificationAccessor.java | 2 +-
.../engine/modification/io/ModificationReader.java | 2 +-
.../engine/modification/io/ModificationWriter.java | 2 +-
.../iotdb/db/engine/modification/package-info.java | 2 +-
.../db/engine/querycontext/QueryDataSource.java | 2 +-
.../db/engine/querycontext/ReadOnlyMemChunk.java | 2 +-
.../engine/storagegroup/StorageGroupProcessor.java | 24 +-
.../db/engine/storagegroup/TsFileProcessor.java | 4 +-
.../version/SimpleFileVersionController.java | 2 +-
.../engine/version/SysTimeVersionController.java | 2 +-
.../iotdb/db/engine/version/VersionController.java | 2 +-
.../iotdb/db/exception/ArgsErrorException.java | 2 +-
.../db/exception/ConfigAdjusterException.java | 2 +-
.../db/exception/DeltaEngineRunningException.java | 2 +-
.../exception/DiskSpaceInsufficientException.java | 2 +-
.../iotdb/db/exception/FlushRunTimeException.java | 2 +-
.../apache/iotdb/db/exception/MergeException.java | 2 +-
.../iotdb/db/exception/MetadataErrorException.java | 2 +-
.../iotdb/db/exception/PathErrorException.java | 2 +-
.../iotdb/db/exception/ProcessorException.java | 2 +-
.../db/exception/QueryInBatchStmtException.java | 2 +-
.../iotdb/db/exception/StartupException.java | 2 +-
.../iotdb/db/exception/StorageEngineException.java | 2 +-
.../exception/StorageEngineFailureException.java | 2 +-
.../exception/StorageGroupProcessorException.java | 2 +-
.../db/exception/SyncConnectionException.java | 2 +-
.../iotdb/db/exception/SysCheckException.java | 2 +-
.../db/exception/TsFileProcessorException.java | 2 +-
.../db/exception/UnSupportedFillTypeException.java | 2 +-
.../db/exception/qp/IllegalASTFormatException.java | 2 +-
.../db/exception/qp/LogicalOperatorException.java | 2 +-
.../db/exception/qp/LogicalOptimizeException.java | 2 +-
.../db/exception/qp/QueryProcessorException.java | 2 +-
.../java/org/apache/iotdb/db/metadata/MGraph.java | 51 ++--
.../org/apache/iotdb/db/metadata/MManager.java | 117 +++++++--
.../java/org/apache/iotdb/db/metadata/MNode.java | 18 +-
.../java/org/apache/iotdb/db/metadata/MTree.java | 73 ++++--
.../org/apache/iotdb/db/metadata/Metadata.java | 2 +-
.../apache/iotdb/db/metadata/MetadataConstant.java | 2 +-
.../iotdb/db/metadata/MetadataOperationType.java | 5 +-
.../java/org/apache/iotdb/db/metadata/PNode.java | 2 +-
.../java/org/apache/iotdb/db/metadata/PTree.java | 2 +-
.../apache/iotdb/db/monitor/MonitorConstants.java | 2 +-
.../org/apache/iotdb/db/monitor/StatMonitor.java | 9 +-
.../monitor/collector/MemTableWriteTimeCost.java | 2 +-
.../org/apache/iotdb/db/qp/QueryProcessor.java | 3 +-
.../apache/iotdb/db/qp/constant/DatetimeUtils.java | 2 +-
.../apache/iotdb/db/qp/constant/SQLConstant.java | 2 +-
.../iotdb/db/qp/constant/TSParserConstant.java | 2 +-
.../db/qp/exception/DateTimeFormatException.java | 2 +-
.../qp/executor/AbstractQueryProcessExecutor.java | 2 +-
.../db/qp/executor/IQueryProcessExecutor.java | 2 +-
.../iotdb/db/qp/executor/QueryProcessExecutor.java | 11 +-
.../org/apache/iotdb/db/qp/logical/Operator.java | 4 +-
.../apache/iotdb/db/qp/logical/RootOperator.java | 2 +-
.../db/qp/logical/crud/BasicFunctionOperator.java | 2 +-
.../db/qp/logical/crud/BasicOperatorType.java | 2 +-
.../iotdb/db/qp/logical/crud/DeleteOperator.java | 2 +-
.../iotdb/db/qp/logical/crud/FilterOperator.java | 2 +-
.../iotdb/db/qp/logical/crud/FromOperator.java | 2 +-
.../iotdb/db/qp/logical/crud/FunctionOperator.java | 2 +-
.../iotdb/db/qp/logical/crud/InsertOperator.java | 2 +-
.../iotdb/db/qp/logical/crud/QueryOperator.java | 2 +-
.../iotdb/db/qp/logical/crud/SFWOperator.java | 2 +-
.../iotdb/db/qp/logical/crud/SelectOperator.java | 2 +-
.../iotdb/db/qp/logical/crud/UpdateOperator.java | 2 +-
.../iotdb/db/qp/logical/sys/AuthorOperator.java | 2 +-
.../iotdb/db/qp/logical/sys/DataAuthOperator.java | 2 +-
.../iotdb/db/qp/logical/sys/LoadDataOperator.java | 2 +-
.../iotdb/db/qp/logical/sys/MetadataOperator.java | 11 +-
.../iotdb/db/qp/logical/sys/PropertyOperator.java | 2 +-
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 2 +-
.../iotdb/db/qp/physical/crud/AggregationPlan.java | 2 +-
.../iotdb/db/qp/physical/crud/BatchInsertPlan.java | 68 ++---
.../iotdb/db/qp/physical/crud/DeletePlan.java | 2 +-
.../iotdb/db/qp/physical/crud/FillQueryPlan.java | 2 +-
.../iotdb/db/qp/physical/crud/GroupByPlan.java | 2 +-
.../iotdb/db/qp/physical/crud/InsertPlan.java | 2 +-
.../iotdb/db/qp/physical/crud/QueryPlan.java | 2 +-
.../iotdb/db/qp/physical/crud/UpdatePlan.java | 2 +-
.../iotdb/db/qp/physical/sys/AuthorPlan.java | 2 +-
.../iotdb/db/qp/physical/sys/DataAuthPlan.java | 2 +-
.../iotdb/db/qp/physical/sys/LoadDataPlan.java | 2 +-
.../iotdb/db/qp/physical/sys/MetadataPlan.java | 4 +-
.../iotdb/db/qp/physical/sys/PropertyPlan.java | 2 +-
.../iotdb/db/qp/strategy/LogicalGenerator.java | 2 +-
.../iotdb/db/qp/strategy/PhysicalGenerator.java | 2 +-
.../qp/strategy/optimizer/ConcatPathOptimizer.java | 2 +-
.../qp/strategy/optimizer/DnfFilterOptimizer.java | 2 +-
.../db/qp/strategy/optimizer/IFilterOptimizer.java | 2 +-
.../qp/strategy/optimizer/ILogicalOptimizer.java | 2 +-
.../optimizer/MergeSingleFilterOptimizer.java | 2 +-
.../qp/strategy/optimizer/RemoveNotOptimizer.java | 2 +-
.../db/query/aggregation/AggreResultData.java | 2 +-
.../db/query/aggregation/AggregateFunction.java | 2 +-
.../db/query/aggregation/impl/AvgAggrFunc.java | 2 +-
.../db/query/aggregation/impl/CountAggrFunc.java | 2 +-
.../db/query/aggregation/impl/FirstAggrFunc.java | 2 +-
.../db/query/aggregation/impl/LastAggrFunc.java | 2 +-
.../db/query/aggregation/impl/MaxTimeAggrFunc.java | 2 +-
.../query/aggregation/impl/MaxValueAggrFunc.java | 2 +-
.../db/query/aggregation/impl/MinTimeAggrFunc.java | 2 +-
.../query/aggregation/impl/MinValueAggrFunc.java | 2 +-
.../db/query/aggregation/impl/SumAggrFunc.java | 2 +-
.../iotdb/db/query/context/QueryContext.java | 2 +-
.../iotdb/db/query/control/FileReaderManager.java | 2 +-
.../iotdb/db/query/control/JobFileManager.java | 2 +-
.../db/query/control/QueryResourceManager.java | 2 +-
.../dataset/EngineDataSetWithValueFilter.java | 2 +-
.../dataset/EngineDataSetWithoutValueFilter.java | 2 +-
.../apache/iotdb/db/query/dataset/ListDataSet.java | 2 +-
.../dataset/groupby/GroupByEngineDataSet.java | 2 +-
.../groupby/GroupByWithValueFilterDataSet.java | 2 +-
.../groupby/GroupByWithoutValueFilterDataSet.java | 2 +-
.../db/query/executor/AggregateEngineExecutor.java | 2 +-
.../iotdb/db/query/executor/EngineExecutor.java | 2 +-
.../iotdb/db/query/executor/EngineQueryRouter.java | 2 +-
.../db/query/executor/FillEngineExecutor.java | 2 +-
.../db/query/executor/IEngineQueryRouter.java | 2 +-
.../iotdb/db/query/factory/AggreFuncFactory.java | 2 +-
.../java/org/apache/iotdb/db/query/fill/IFill.java | 2 +-
.../org/apache/iotdb/db/query/fill/LinearFill.java | 2 +-
.../apache/iotdb/db/query/fill/PreviousFill.java | 2 +-
.../iotdb/db/query/reader/IAggregateReader.java | 2 +-
.../apache/iotdb/db/query/reader/IBatchReader.java | 2 +-
.../apache/iotdb/db/query/reader/IPointReader.java | 2 +-
.../iotdb/db/query/reader/IReaderByTimestamp.java | 2 +-
.../reader/chunkRelated/CachedDiskChunkReader.java | 2 +-
.../query/reader/chunkRelated/DiskChunkReader.java | 2 +-
.../chunkRelated/DiskChunkReaderByTimestamp.java | 2 +-
.../query/reader/chunkRelated/MemChunkReader.java | 2 +-
.../chunkRelated/MemChunkReaderByTimestamp.java | 2 +-
.../fileRelated/FileSeriesReaderAdapter.java | 2 +-
.../FileSeriesReaderByTimestampAdapter.java | 2 +-
.../fileRelated/UnSealedTsFileIterateReader.java | 2 +-
.../UnSealedTsFileReaderByTimestamp.java | 2 +-
.../CachedUnseqResourceMergeReader.java | 2 +-
.../resourceRelated/SeqResourceIterateReader.java | 2 +-
.../SeqResourceReaderByTimestamp.java | 2 +-
.../resourceRelated/UnseqResourceMergeReader.java | 2 +-
.../UnseqResourceReaderByTimestamp.java | 2 +-
.../seriesRelated/SeriesReaderByTimestamp.java | 2 +-
.../seriesRelated/SeriesReaderWithValueFilter.java | 2 +-
.../SeriesReaderWithoutValueFilter.java | 2 +-
.../universal/CachedPriorityMergeReader.java | 2 +-
.../db/query/reader/universal/IterateReader.java | 2 +-
.../reader/universal/PriorityMergeReader.java | 2 +-
.../universal/PriorityMergeReaderByTimestamp.java | 2 +-
.../timegenerator/AbstractNodeConstructor.java | 2 +-
.../db/query/timegenerator/EngineLeafNode.java | 2 +-
.../query/timegenerator/EngineNodeConstructor.java | 2 +-
.../query/timegenerator/EngineTimeGenerator.java | 2 +-
.../apache/iotdb/db/rescon/PrimitiveArrayPool.java | 2 +-
.../apache/iotdb/db/rescon/TVListAllocator.java | 2 +-
.../iotdb/db/rescon/TVListAllocatorMBean.java | 2 +-
.../org/apache/iotdb/db/rescon/package-info.java | 2 +-
.../java/org/apache/iotdb/db/service/IService.java | 2 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 2 +-
.../org/apache/iotdb/db/service/IoTDBMBean.java | 2 +-
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 2 +-
.../org/apache/iotdb/db/service/JDBCService.java | 2 +-
.../iotdb/db/service/JDBCServiceEventHandler.java | 2 +-
.../apache/iotdb/db/service/JDBCServiceMBean.java | 2 +-
.../org/apache/iotdb/db/service/JMXService.java | 2 +-
.../java/org/apache/iotdb/db/service/Monitor.java | 2 +-
.../org/apache/iotdb/db/service/MonitorMBean.java | 2 +-
.../apache/iotdb/db/service/RegisterManager.java | 2 +-
.../org/apache/iotdb/db/service/ServiceType.java | 2 +-
.../org/apache/iotdb/db/service/StartupCheck.java | 2 +-
.../org/apache/iotdb/db/service/StartupChecks.java | 2 +-
.../org/apache/iotdb/db/service/TSServiceImpl.java | 53 ++--
.../org/apache/iotdb/db/sql/ParseGenerator.java | 2 +-
.../apache/iotdb/db/sql/parse/AstErrorNode.java | 2 +-
.../org/apache/iotdb/db/sql/parse/AstNode.java | 2 +-
.../apache/iotdb/db/sql/parse/AstNodeOrigin.java | 2 +-
.../java/org/apache/iotdb/db/sql/parse/Node.java | 2 +-
.../org/apache/iotdb/db/sql/parse/ParseDriver.java | 2 +-
.../org/apache/iotdb/db/sql/parse/ParseError.java | 2 +-
.../apache/iotdb/db/sql/parse/ParseException.java | 2 +-
.../org/apache/iotdb/db/sql/parse/ParseUtils.java | 2 +-
.../org/apache/iotdb/db/sync/conf/Constans.java | 2 +-
.../iotdb/db/sync/conf/SyncSenderConfig.java | 2 +-
.../iotdb/db/sync/conf/SyncSenderDescriptor.java | 2 +-
.../iotdb/db/sync/receiver/SyncServerManager.java | 2 +-
.../iotdb/db/sync/receiver/SyncServiceImpl.java | 15 +-
.../iotdb/db/sync/sender/SyncFileManager.java | 2 +-
.../apache/iotdb/db/sync/sender/SyncSender.java | 2 +-
.../apache/iotdb/db/tools/MemEst/MemEstTool.java | 2 +-
.../iotdb/db/tools/MemEst/MemEstToolCmd.java | 2 +-
.../iotdb/db/tools/TsFileResourcePrinter.java | 5 +-
.../java/org/apache/iotdb/db/tools/WalChecker.java | 2 +-
.../watermark/GroupedLSBWatermarkEncoder.java | 2 +-
.../db/tools/watermark/WatermarkDetector.java | 2 +-
.../iotdb/db/tools/watermark/WatermarkEncoder.java | 2 +-
.../java/org/apache/iotdb/db/utils/AuthUtils.java | 2 +-
.../org/apache/iotdb/db/utils/CommonUtils.java | 2 +-
.../iotdb/db/utils/CopyOnReadLinkedList.java | 2 +-
.../org/apache/iotdb/db/utils/FilePathUtils.java | 2 +-
.../java/org/apache/iotdb/db/utils/IOUtils.java | 2 +-
.../java/org/apache/iotdb/db/utils/MathUtils.java | 2 +-
.../java/org/apache/iotdb/db/utils/MemUtils.java | 2 +-
.../java/org/apache/iotdb/db/utils/MergeUtils.java | 2 +-
.../org/apache/iotdb/db/utils/OpenFileNumUtil.java | 2 +-
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 2 +-
.../java/org/apache/iotdb/db/utils/QueryUtils.java | 2 +-
.../apache/iotdb/db/utils/RandomDeleteCache.java | 2 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 2 +-
.../java/org/apache/iotdb/db/utils/SyncUtils.java | 2 +-
.../org/apache/iotdb/db/utils/TimeValuePair.java | 2 +-
.../apache/iotdb/db/utils/TimeValuePairUtils.java | 2 +-
.../org/apache/iotdb/db/utils/TsPrimitiveType.java | 2 +-
.../iotdb/db/utils/datastructure/BinaryTVList.java | 2 +-
.../db/utils/datastructure/BooleanTVList.java | 2 +-
.../iotdb/db/utils/datastructure/DoubleTVList.java | 2 +-
.../iotdb/db/utils/datastructure/FloatTVList.java | 2 +-
.../iotdb/db/utils/datastructure/IntTVList.java | 2 +-
.../iotdb/db/utils/datastructure/LongTVList.java | 2 +-
.../iotdb/db/utils/datastructure/TVList.java | 2 +-
.../iotdb/db/writelog/io/BatchLogReader.java | 2 +-
.../apache/iotdb/db/writelog/io/ILogReader.java | 2 +-
.../apache/iotdb/db/writelog/io/ILogWriter.java | 2 +-
.../org/apache/iotdb/db/writelog/io/LogWriter.java | 2 +-
.../iotdb/db/writelog/io/MultiFileLogReader.java | 2 +-
.../iotdb/db/writelog/io/SingleFileLogReader.java | 2 +-
.../writelog/manager/MultiFileLogNodeManager.java | 2 +-
.../db/writelog/manager/WriteLogNodeManager.java | 2 +-
.../iotdb/db/writelog/node/WriteLogNode.java | 2 +-
.../iotdb/db/writelog/recover/LogReplayer.java | 47 +++-
.../writelog/recover/TsFileRecoverPerformer.java | 2 +-
.../iotdb/db/auth/LocalFIleRoleAccessorTest.java | 2 +-
.../iotdb/db/auth/LocalFileAuthorizerTest.java | 2 +-
.../iotdb/db/auth/LocalFileRoleManagerTest.java | 2 +-
.../iotdb/db/auth/LocalFileUserAccessorTest.java | 2 +-
.../iotdb/db/auth/LocalFileUserManagerTest.java | 2 +-
.../IoTDBDefaultThreadExceptionHandlerTest.java | 2 +-
.../db/concurrent/IoTDBThreadPoolFactoryTest.java | 2 +-
.../db/conf/adapter/CompressionRatioTest.java | 2 +-
.../strategy/DirectoryStrategyTest.java | 2 +-
.../db/cost/statistic/PerformanceStatTest.java | 2 +-
.../iotdb/db/engine/MetadataManagerHelper.java | 11 +-
.../db/engine/cache/DeviceMetaDataCacheTest.java | 2 +-
.../db/engine/memtable/ChunkBufferPoolTest.java | 2 +-
.../iotdb/db/engine/memtable/MemTablePoolTest.java | 2 +-
.../db/engine/memtable/MemTableTestUtils.java | 2 +-
.../db/engine/memtable/MemtableBenchmark.java | 2 +-
.../db/engine/memtable/PrimitiveMemTableTest.java | 2 +-
.../engine/merge/MaxFileMergeFileSelectorTest.java | 2 +-
.../merge/MaxSeriesMergeFileSelectorTest.java | 2 +-
.../apache/iotdb/db/engine/merge/MergeLogTest.java | 2 +-
.../iotdb/db/engine/merge/MergePerfTest.java | 2 +-
.../iotdb/db/engine/merge/MergeTaskTest.java | 2 +-
.../apache/iotdb/db/engine/merge/MergeTest.java | 4 +-
.../engine/modification/DeletionFileNodeTest.java | 4 +-
.../db/engine/modification/DeletionQueryTest.java | 4 +-
.../engine/modification/ModificationFileTest.java | 2 +-
.../io/LocalTextModificationAccessorTest.java | 2 +-
.../storagegroup/FileNodeManagerBenchmark.java | 4 +-
.../storagegroup/StorageGroupProcessorTest.java | 2 +-
.../iotdb/db/engine/storagegroup/TTLTest.java | 4 +-
.../engine/storagegroup/TsFileProcessorTest.java | 2 +-
.../version/SimpleFileVersionControllerTest.java | 2 +-
.../version/SysTimeVersionControllerTest.java | 2 +-
.../org/apache/iotdb/db/integration/Constant.java | 2 +-
.../apache/iotdb/db/integration/IOTDBFillIT.java | 2 +-
.../iotdb/db/integration/IOTDBGroupByIT.java | 2 +-
.../iotdb/db/integration/IoTDBAggregationIT.java | 2 +-
.../integration/IoTDBAggregationLargeDataIT.java | 2 +-
.../integration/IoTDBAggregationSmallDataIT.java | 2 +-
.../iotdb/db/integration/IoTDBAuthorizationIT.java | 2 +-
.../iotdb/db/integration/IoTDBCompleteIT.java | 2 +-
.../apache/iotdb/db/integration/IoTDBDaemonIT.java | 2 +-
.../iotdb/db/integration/IoTDBDeletionIT.java | 2 +-
.../db/integration/IoTDBEngineTimeGeneratorIT.java | 2 +-
.../db/integration/IoTDBFloatPrecisionIT.java | 2 +-
.../db/integration/IoTDBFlushQueryMergeTest.java | 2 +-
.../iotdb/db/integration/IoTDBLargeDataIT.java | 2 +-
.../iotdb/db/integration/IoTDBLimitSlimitIT.java | 2 +-
.../iotdb/db/integration/IoTDBMergeTest.java | 2 +-
.../iotdb/db/integration/IoTDBMetadataFetchIT.java | 6 +-
.../iotdb/db/integration/IoTDBMultiSeriesIT.java | 2 +-
.../iotdb/db/integration/IoTDBNumberPathIT.java | 2 +-
.../iotdb/db/integration/IoTDBPreparedStmtIT.java | 2 +-
.../db/integration/IoTDBSequenceDataQueryIT.java | 2 +-
.../iotdb/db/integration/IoTDBSeriesReaderIT.java | 2 +-
.../iotdb/db/integration/IoTDBTimeZoneIT.java | 2 +-
.../iotdb/db/integration/IoTDBVersionIT.java | 2 +-
.../org/apache/iotdb/db/metadata/MGraphTest.java | 14 +-
.../iotdb/db/metadata/MManagerAdvancedTest.java | 16 +-
.../iotdb/db/metadata/MManagerBasicTest.java | 51 ++--
.../iotdb/db/metadata/MManagerImproveTest.java | 4 +-
.../org/apache/iotdb/db/metadata/MTreeTest.java | 2 +-
.../org/apache/iotdb/db/metadata/MetadataTest.java | 18 +-
.../org/apache/iotdb/db/qp/QueryProcessorTest.java | 6 +-
.../iotdb/db/qp/bench/QueryParseBenchmark.java | 2 +-
.../iotdb/db/qp/other/TSPlanContextAuthorTest.java | 2 +-
.../db/qp/other/TSPlanContextPropertyTest.java | 2 +-
.../iotdb/db/qp/plan/LogicalPlanSmallTest.java | 2 +-
.../apache/iotdb/db/qp/plan/PhysicalPlanTest.java | 2 +-
.../org/apache/iotdb/db/qp/plan/QPUpdateTest.java | 2 +-
.../iotdb/db/qp/plan/TestConcatOptimizer.java | 2 +-
.../iotdb/db/qp/strategy/LogicalGeneratorTest.java | 2 +-
.../apache/iotdb/db/qp/utils/MemIntQpExecutor.java | 2 +-
.../iotdb/db/query/component/SimpleFileWriter.java | 2 +-
.../db/query/control/FileReaderManagerTest.java | 2 +-
.../db/query/control/QueryResourceManagerTest.java | 2 +-
.../dataset/EngineDataSetWithValueFilterTest.java | 2 +-
.../query/executor/GroupByEngineDataSetTest.java | 2 +-
.../iotdb/db/query/reader/ReaderTestHelper.java | 2 +-
.../fileRelated/UnSealedTsFileReaderTest.java | 2 +-
.../resourceRelated/SeqResourceReaderTest.java | 2 +-
.../resourceRelated/UnseqResourceReaderTest.java | 2 +-
.../reader/seriesRelated/FakedIBatchPoint.java | 2 +-
.../reader/seriesRelated/FakedIPointReader.java | 2 +-
.../SeriesReaderWithValueFilterTest.java | 2 +-
.../SeriesReaderWithoutValueFilterTest.java | 2 +-
.../universal/FakedSeriesReaderByTimestamp.java | 2 +-
.../PriorityMergeReaderByTimestampTest.java | 2 +-
.../reader/universal/PriorityMergeReaderTest.java | 2 +-
.../reader/universal/PriorityMergeReaderTest2.java | 2 +-
.../org/apache/iotdb/db/script/EnvScriptIT.java | 2 +-
.../db/sql/DatetimeQueryDataSetUtilsTest.java | 2 +-
.../org/apache/iotdb/db/sql/SQLParserTest.java | 2 +-
.../db/sync/sender/MultipleClientSyncTest.java | 2 +-
.../iotdb/db/sync/sender/SingleClientSyncTest.java | 2 +-
.../iotdb/db/sync/sender/SyncFileManagerTest.java | 2 +-
.../org/apache/iotdb/db/sync/test/RandomNum.java | 2 +-
.../apache/iotdb/db/sync/test/SyncTestClient1.java | 2 +-
.../apache/iotdb/db/sync/test/SyncTestClient2.java | 2 +-
.../apache/iotdb/db/sync/test/SyncTestClient3.java | 2 +-
.../java/org/apache/iotdb/db/sync/test/Utils.java | 2 +-
.../apache/iotdb/db/tools/IoTDBWatermarkTest.java | 2 +-
.../org/apache/iotdb/db/tools/WalCheckerTest.java | 2 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 2 +-
.../iotdb/db/utils/MathQueryDataSetUtilsTest.java | 2 +-
.../apache/iotdb/db/utils/OpenFileNumUtilTest.java | 2 +-
.../db/utils/datastructure/LongTVListTest.java | 2 +-
.../iotdb/db/writelog/IoTDBLogFileSizeTest.java | 2 +-
.../apache/iotdb/db/writelog/PerformanceTest.java | 4 +-
.../iotdb/db/writelog/WriteLogNodeManagerTest.java | 2 +-
.../apache/iotdb/db/writelog/WriteLogNodeTest.java | 2 +-
.../iotdb/db/writelog/io/LogWriterReaderTest.java | 2 +-
.../db/writelog/io/MultiFileLogReaderTest.java | 2 +-
.../iotdb/db/writelog/recover/LogReplayerTest.java | 2 +-
.../db/writelog/recover/SeqTsFileRecoverTest.java | 2 +-
.../writelog/recover/UnseqTsFileRecoverTest.java | 2 +-
service-rpc/rpc-changelist.md | 2 +
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 2 +-
service-rpc/src/main/thrift/rpc.thrift | 13 +-
.../java/org/apache/iotdb/session/Session.java | 14 ++
.../org/apache/iotdb/session/IoTDBSessionIT.java | 49 ++++
.../iotdb/session/utils/EnvironmentUtils.java | 2 +-
.../org/apache/iotdb/sparkdb/EnvironmentUtils.java | 2 +-
.../apache/iotdb/tsfile/io/TsFileOutputFormat.java | 2 +-
.../apache/iotdb/tsfile/io/TsFileRecordWriter.java | 2 +-
.../java/org/apache/iotdb/tsfile/qp/Executor.java | 2 +-
.../org/apache/iotdb/tsfile/qp/QueryProcessor.java | 2 +-
.../iotdb/tsfile/qp/common/BasicOperator.java | 2 +-
.../iotdb/tsfile/qp/common/FilterOperator.java | 2 +-
.../apache/iotdb/tsfile/qp/common/Operator.java | 2 +-
.../apache/iotdb/tsfile/qp/common/SQLConstant.java | 2 +-
.../apache/iotdb/tsfile/qp/common/SingleQuery.java | 2 +-
.../apache/iotdb/tsfile/qp/common/TSQueryPlan.java | 2 +-
.../qp/exception/BasicOperatorException.java | 2 +-
.../tsfile/qp/exception/DNFOptimizeException.java | 2 +-
.../qp/exception/LogicalOptimizeException.java | 2 +-
.../tsfile/qp/exception/MergeFilterException.java | 2 +-
.../qp/exception/QueryOperatorException.java | 2 +-
.../qp/exception/QueryProcessorException.java | 2 +-
.../tsfile/qp/exception/RemoveNotException.java | 2 +-
.../tsfile/qp/optimizer/DNFFilterOptimizer.java | 2 +-
.../tsfile/qp/optimizer/IFilterOptimizer.java | 2 +-
.../qp/optimizer/MergeSingleFilterOptimizer.java | 2 +-
.../tsfile/qp/optimizer/PhysicalOptimizer.java | 2 +-
.../tsfile/qp/optimizer/RemoveNotOptimizer.java | 2 +-
.../scala/org/apache/iotdb/tool/TsFileExample.java | 2 +-
.../org/apache/iotdb/tool/TsFileWriteTool.java | 2 +-
.../org/apache/iotdb/tsfile/HDFSInputTest.java | 2 +-
.../apache/iotdb/tsfile/common/cache/Cache.java | 2 +-
.../apache/iotdb/tsfile/common/cache/LRUCache.java | 2 +-
.../iotdb/tsfile/common/conf/TSFileConfig.java | 2 +-
.../iotdb/tsfile/common/conf/TSFileDescriptor.java | 2 +-
.../tsfile/common/constant/JsonFormatConstant.java | 2 +-
.../tsfile/common/constant/QueryConstant.java | 2 +-
.../tsfile/common/constant/StatisticConstant.java | 2 +-
.../tsfile/common/constant/TsFileConstant.java | 2 +-
.../apache/iotdb/tsfile/compress/ICompressor.java | 2 +-
.../iotdb/tsfile/compress/IUnCompressor.java | 2 +-
.../tsfile/encoding/bitpacking/IntPacker.java | 2 +-
.../tsfile/encoding/bitpacking/LongPacker.java | 2 +-
.../tsfile/encoding/common/EncodingConfig.java | 2 +-
.../iotdb/tsfile/encoding/common/EndianType.java | 2 +-
.../tsfile/encoding/decoder/BitmapDecoder.java | 2 +-
.../iotdb/tsfile/encoding/decoder/Decoder.java | 2 +-
.../encoding/decoder/DeltaBinaryDecoder.java | 2 +-
.../encoding/decoder/DoublePrecisionDecoder.java | 2 +-
.../tsfile/encoding/decoder/FloatDecoder.java | 2 +-
.../tsfile/encoding/decoder/GorillaDecoder.java | 2 +-
.../tsfile/encoding/decoder/IntRleDecoder.java | 2 +-
.../tsfile/encoding/decoder/LongRleDecoder.java | 2 +-
.../tsfile/encoding/decoder/PlainDecoder.java | 2 +-
.../encoding/decoder/RegularDataDecoder.java | 2 +-
.../iotdb/tsfile/encoding/decoder/RleDecoder.java | 2 +-
.../encoding/decoder/SinglePrecisionDecoder.java | 2 +-
.../tsfile/encoding/encoder/BitmapEncoder.java | 2 +-
.../encoding/encoder/DeltaBinaryEncoder.java | 2 +-
.../encoding/encoder/DoublePrecisionEncoder.java | 2 +-
.../iotdb/tsfile/encoding/encoder/Encoder.java | 2 +-
.../tsfile/encoding/encoder/FloatEncoder.java | 2 +-
.../tsfile/encoding/encoder/GorillaEncoder.java | 2 +-
.../tsfile/encoding/encoder/IntRleEncoder.java | 2 +-
.../tsfile/encoding/encoder/LongRleEncoder.java | 2 +-
.../tsfile/encoding/encoder/PlainEncoder.java | 2 +-
.../encoding/encoder/RegularDataEncoder.java | 2 +-
.../iotdb/tsfile/encoding/encoder/RleEncoder.java | 2 +-
.../encoding/encoder/SinglePrecisionEncoder.java | 2 +-
.../tsfile/encoding/encoder/TSEncodingBuilder.java | 2 +-
.../tsfile/exception/NotImplementedException.java | 2 +-
.../tsfile/exception/TsFileRuntimeException.java | 2 +-
.../tsfile/exception/cache/CacheException.java | 2 +-
.../CompressionTypeNotSupportedException.java | 2 +-
.../encoding/TsFileDecodingException.java | 2 +-
.../encoding/TsFileEncodingException.java | 2 +-
.../filter/QueryFilterOptimizationException.java | 2 +-
.../filter/UnSupportFilterDataTypeException.java | 2 +-
.../exception/write/NoMeasurementException.java | 2 +-
.../tsfile/exception/write/PageException.java | 2 +-
.../write/TsFileNotCompleteException.java | 2 +-
.../write/UnSupportedDataTypeException.java | 2 +-
.../write/UnknownColumnTypeException.java | 2 +-
.../exception/write/WriteProcessException.java | 2 +-
.../org/apache/iotdb/tsfile/file/MetaMarker.java | 2 +-
.../iotdb/tsfile/file/footer/ChunkGroupFooter.java | 2 +-
.../iotdb/tsfile/file/header/ChunkHeader.java | 2 +-
.../iotdb/tsfile/file/header/PageHeader.java | 2 +-
.../iotdb/tsfile/file/header/package-info.java | 2 +-
.../tsfile/file/metadata/ChunkGroupMetaData.java | 2 +-
.../iotdb/tsfile/file/metadata/ChunkMetaData.java | 2 +-
.../tsfile/file/metadata/TsDeviceMetadata.java | 2 +-
.../file/metadata/TsDeviceMetadataIndex.java | 2 +-
.../iotdb/tsfile/file/metadata/TsDigest.java | 2 +-
.../file/metadata/enums/CompressionType.java | 2 +-
.../tsfile/file/metadata/enums/TSDataType.java | 2 +-
.../tsfile/file/metadata/enums/TSEncoding.java | 2 +-
.../tsfile/file/metadata/enums/TSFreqType.java | 2 +-
.../file/metadata/statistics/BinaryStatistics.java | 2 +-
.../metadata/statistics/BooleanStatistics.java | 2 +-
.../file/metadata/statistics/DoubleStatistics.java | 2 +-
.../file/metadata/statistics/FloatStatistics.java | 2 +-
.../metadata/statistics/IntegerStatistics.java | 2 +-
.../file/metadata/statistics/LongStatistics.java | 2 +-
.../file/metadata/statistics/NoStatistics.java | 2 +-
.../file/metadata/statistics/Statistics.java | 2 +-
.../statistics/StatisticsClassException.java | 2 +-
.../iotdb/tsfile/fileSystem/FileInputFactory.java | 2 +-
.../iotdb/tsfile/fileSystem/FileOutputFactory.java | 5 +-
.../apache/iotdb/tsfile/fileSystem/HDFSFile.java | 61 ++---
.../apache/iotdb/tsfile/fileSystem/HDFSInput.java | 2 +-
.../apache/iotdb/tsfile/fileSystem/HDFSOutput.java | 27 +-
.../iotdb/tsfile/fileSystem/TSFileFactory.java | 86 +++++--
.../org/apache/iotdb/tsfile/read/IDataReader.java | 2 +-
.../apache/iotdb/tsfile/read/ReadOnlyTsFile.java | 2 +-
.../iotdb/tsfile/read/TsFileCheckStatus.java | 2 +-
.../iotdb/tsfile/read/UnClosedTsFileReader.java | 2 +-
.../apache/iotdb/tsfile/read/common/BatchData.java | 2 +-
.../org/apache/iotdb/tsfile/read/common/Chunk.java | 2 +-
.../org/apache/iotdb/tsfile/read/common/Field.java | 2 +-
.../org/apache/iotdb/tsfile/read/common/Path.java | 2 +-
.../apache/iotdb/tsfile/read/common/RowRecord.java | 2 +-
.../apache/iotdb/tsfile/read/common/TimeRange.java | 2 +-
.../tsfile/read/controller/ChunkLoaderImpl.java | 2 +-
.../iotdb/tsfile/read/controller/IChunkLoader.java | 2 +-
.../tsfile/read/controller/IMetadataQuerier.java | 2 +-
.../read/controller/MetadataQuerierByFileImpl.java | 2 +-
.../tsfile/read/expression/ExpressionType.java | 2 +-
.../tsfile/read/expression/IBinaryExpression.java | 2 +-
.../iotdb/tsfile/read/expression/IExpression.java | 2 +-
.../tsfile/read/expression/IUnaryExpression.java | 2 +-
.../tsfile/read/expression/QueryExpression.java | 2 +-
.../read/expression/impl/BinaryExpression.java | 2 +-
.../read/expression/impl/GlobalTimeExpression.java | 2 +-
.../expression/impl/SingleSeriesExpression.java | 2 +-
.../read/expression/util/ExpressionOptimizer.java | 2 +-
.../read/expression/util/ExpressionPrinter.java | 2 +-
.../iotdb/tsfile/read/filter/DigestForFilter.java | 2 +-
.../iotdb/tsfile/read/filter/TimeFilter.java | 2 +-
.../iotdb/tsfile/read/filter/ValueFilter.java | 2 +-
.../tsfile/read/filter/basic/BinaryFilter.java | 2 +-
.../iotdb/tsfile/read/filter/basic/Filter.java | 2 +-
.../tsfile/read/filter/basic/UnaryFilter.java | 2 +-
.../tsfile/read/filter/factory/FilterFactory.java | 2 +-
.../tsfile/read/filter/factory/FilterType.java | 2 +-
.../tsfile/read/filter/operator/AndFilter.java | 2 +-
.../iotdb/tsfile/read/filter/operator/Eq.java | 2 +-
.../iotdb/tsfile/read/filter/operator/Gt.java | 2 +-
.../iotdb/tsfile/read/filter/operator/GtEq.java | 2 +-
.../iotdb/tsfile/read/filter/operator/Lt.java | 2 +-
.../iotdb/tsfile/read/filter/operator/LtEq.java | 2 +-
.../iotdb/tsfile/read/filter/operator/NotEq.java | 2 +-
.../tsfile/read/filter/operator/NotFilter.java | 2 +-
.../tsfile/read/filter/operator/OrFilter.java | 2 +-
.../query/dataset/DataSetWithTimeGenerator.java | 2 +-
.../query/dataset/DataSetWithoutTimeGenerator.java | 2 +-
.../tsfile/read/query/dataset/QueryDataSet.java | 2 +-
.../query/executor/ExecutorWithTimeGenerator.java | 2 +-
.../tsfile/read/query/executor/QueryExecutor.java | 2 +-
.../tsfile/read/query/executor/TsFileExecutor.java | 2 +-
.../read/query/timegenerator/TimeGenerator.java | 2 +-
.../query/timegenerator/TimeGeneratorImpl.java | 2 +-
.../read/query/timegenerator/node/AndNode.java | 2 +-
.../read/query/timegenerator/node/LeafNode.java | 2 +-
.../tsfile/read/query/timegenerator/node/Node.java | 2 +-
.../read/query/timegenerator/node/NodeType.java | 2 +-
.../read/query/timegenerator/node/OrNode.java | 2 +-
.../tsfile/read/reader/DefaultTsFileInput.java | 2 +-
.../iotdb/tsfile/read/reader/TsFileInput.java | 2 +-
.../tsfile/read/reader/chunk/ChunkReader.java | 2 +-
.../read/reader/chunk/ChunkReaderByTimestamp.java | 2 +-
.../read/reader/chunk/ChunkReaderWithFilter.java | 2 +-
.../reader/chunk/ChunkReaderWithoutFilter.java | 2 +-
.../iotdb/tsfile/read/reader/page/PageReader.java | 2 +-
.../read/reader/series/EmptyFileSeriesReader.java | 2 +-
.../read/reader/series/FileSeriesReader.java | 2 +-
.../reader/series/FileSeriesReaderByTimestamp.java | 2 +-
.../reader/series/FileSeriesReaderWithFilter.java | 2 +-
.../series/FileSeriesReaderWithoutFilter.java | 2 +-
.../java/org/apache/iotdb/tsfile/utils/Binary.java | 2 +-
.../org/apache/iotdb/tsfile/utils/BytesUtils.java | 2 +-
.../java/org/apache/iotdb/tsfile/utils/Loader.java | 2 +-
.../java/org/apache/iotdb/tsfile/utils/Pair.java | 2 +-
.../org/apache/iotdb/tsfile/utils/PublicBAOS.java | 2 +-
.../tsfile/utils/ReadWriteForEncodingUtils.java | 2 +-
.../iotdb/tsfile/utils/ReadWriteIOUtils.java | 2 +-
.../apache/iotdb/tsfile/utils/StringContainer.java | 2 +-
.../apache/iotdb/tsfile/write/TsFileWriter.java | 12 +-
.../iotdb/tsfile/write/chunk/ChunkBuffer.java | 19 +-
.../tsfile/write/chunk/ChunkGroupWriterImpl.java | 9 +-
.../iotdb/tsfile/write/chunk/ChunkWriterImpl.java | 2 +-
.../tsfile/write/chunk/IChunkGroupWriter.java | 5 +-
.../iotdb/tsfile/write/chunk/IChunkWriter.java | 2 +-
.../apache/iotdb/tsfile/write/page/PageWriter.java | 2 +-
.../apache/iotdb/tsfile/write/record/RowBatch.java | 2 +-
.../apache/iotdb/tsfile/write/record/TSRecord.java | 2 +-
.../write/record/datapoint/BooleanDataPoint.java | 2 +-
.../tsfile/write/record/datapoint/DataPoint.java | 2 +-
.../write/record/datapoint/DoubleDataPoint.java | 2 +-
.../write/record/datapoint/FloatDataPoint.java | 2 +-
.../write/record/datapoint/IntDataPoint.java | 2 +-
.../write/record/datapoint/LongDataPoint.java | 2 +-
.../write/record/datapoint/StringDataPoint.java | 2 +-
.../tsfile/write/schema/MeasurementSchema.java | 2 +-
.../apache/iotdb/tsfile/write/schema/Schema.java | 2 +-
.../iotdb/tsfile/write/schema/SchemaBuilder.java | 2 +-
.../tsfile/write/writer/DefaultTsFileOutput.java | 2 +-
.../write/writer/ForceAppendTsFileWriter.java | 2 +-
.../iotdb/tsfile/write/writer/IDataWriter.java | 2 +-
.../write/writer/RestorableTsFileIOWriter.java | 2 +-
.../iotdb/tsfile/write/writer/TsFileIOWriter.java | 2 +-
.../iotdb/tsfile/write/writer/TsFileOutput.java | 2 +-
.../apache/iotdb/tsfile/common/LRUCacheTest.java | 2 +-
.../apache/iotdb/tsfile/compress/CompressTest.java | 2 +-
.../apache/iotdb/tsfile/compress/SnappyTest.java | 2 +-
.../tsfile/constant/TimeseriesTestConstant.java | 2 +-
.../tsfile/encoding/bitpacking/IntPackerTest.java | 2 +-
.../tsfile/encoding/bitpacking/LongPackerTest.java | 2 +-
.../tsfile/encoding/decoder/BitmapDecoderTest.java | 2 +-
.../tsfile/encoding/decoder/FloatDecoderTest.java | 2 +-
.../encoding/decoder/GorillaDecoderTest.java | 2 +-
.../tsfile/encoding/decoder/IntRleDecoderTest.java | 2 +-
.../encoding/decoder/LongRleDecoderTest.java | 2 +-
.../delta/DeltaBinaryEncoderIntegerTest.java | 2 +-
.../decoder/delta/DeltaBinaryEncoderLongTest.java | 2 +-
.../regular/RegularDataEncoderIntegerTest.java | 2 +-
.../regular/RegularDataEncoderLongTest.java | 2 +-
.../file/metadata/ChunkGroupMetaDataTest.java | 2 +-
.../tsfile/file/metadata/ChunkMetaDataTest.java | 2 +-
.../file/metadata/TimeSeriesMetadataTest.java | 2 +-
.../file/metadata/TsDeviceMetadataIndexTest.java | 2 +-
.../tsfile/file/metadata/TsDeviceMetadataTest.java | 2 +-
.../tsfile/file/metadata/TsFileMetaDataTest.java | 2 +-
.../metadata/statistics/BooleanStatisticsTest.java | 2 +-
.../metadata/statistics/DoubleStatisticsTest.java | 2 +-
.../metadata/statistics/FloatStatisticsTest.java | 2 +-
.../metadata/statistics/IntegerStatisticsTest.java | 2 +-
.../metadata/statistics/LongStatisticsTest.java | 2 +-
.../metadata/statistics/StringStatisticsTest.java | 2 +-
.../tsfile/file/metadata/utils/TestHelper.java | 2 +-
.../iotdb/tsfile/file/metadata/utils/Utils.java | 2 +-
.../iotdb/tsfile/read/ReadInPartitionTest.java | 2 +-
.../iotdb/tsfile/read/ReadOnlyTsFileTest.java | 2 +-
.../org/apache/iotdb/tsfile/read/ReadTest.java | 2 +-
.../iotdb/tsfile/read/TimePlainEncodeReadTest.java | 2 +-
.../tsfile/read/TsFileRestorableReaderTest.java | 5 +-
.../apache/iotdb/tsfile/read/common/PathTest.java | 2 +-
.../iotdb/tsfile/read/common/TimeRangeTest.java | 2 +-
.../tsfile/read/controller/ChunkLoaderTest.java | 2 +-
.../controller/IMetadataQuerierByFileImplTest.java | 2 +-
.../iotdb/tsfile/read/filter/DigestFilterTest.java | 2 +-
.../read/filter/IExpressionOptimizerTest.java | 2 +-
.../read/filter/MinTimeMaxTimeFilterTest.java | 2 +-
.../iotdb/tsfile/read/filter/OperatorTest.java | 2 +-
.../read/query/executor/QueryExecutorTest.java | 2 +-
.../tsfile/read/query/timegenerator/NodeTest.java | 2 +-
.../query/timegenerator/ReaderByTimestampTest.java | 2 +-
.../query/timegenerator/TimeGeneratorTest.java | 2 +-
.../TsFileGeneratorForSeriesReaderByTimestamp.java | 2 +-
.../iotdb/tsfile/read/reader/PageReaderTest.java | 2 +-
.../iotdb/tsfile/read/reader/ReaderTest.java | 2 +-
.../apache/iotdb/tsfile/utils/BytesUtilsTest.java | 2 +-
.../iotdb/tsfile/utils/CommonTestConstant.java | 2 +-
.../apache/iotdb/tsfile/utils/FileGenerator.java | 2 +-
.../org/apache/iotdb/tsfile/utils/FileUtils.java | 2 +-
.../apache/iotdb/tsfile/utils/FileUtilsTest.java | 2 +-
.../iotdb/tsfile/utils/IncompleteFileTestUtil.java | 61 -----
.../org/apache/iotdb/tsfile/utils/PairTest.java | 2 +-
.../tsfile/utils/ReadWriteStreamUtilsTest.java | 2 +-
.../tsfile/utils/ReadWriteToBytesUtilsTest.java | 2 +-
.../org/apache/iotdb/tsfile/utils/RecordUtils.java | 2 +-
.../apache/iotdb/tsfile/utils/RecordUtilsTest.java | 2 +-
.../iotdb/tsfile/utils/StringContainerTest.java | 2 +-
.../iotdb/tsfile/utils/TsFileGeneratorForTest.java | 23 +-
.../org/apache/iotdb/tsfile/write/PerfTest.java | 2 +-
.../iotdb/tsfile/write/ReadPageInMemTest.java | 2 +-
.../iotdb/tsfile/write/TsFileIOWriterTest.java | 2 +-
.../iotdb/tsfile/write/TsFileReadWriteTest.java | 2 +-
.../org/apache/iotdb/tsfile/write/WriteTest.java | 2 +-
.../write/schema/converter/SchemaBuilderTest.java | 2 +-
.../iotdb/tsfile/write/series/PageWriterTest.java | 2 +-
.../write/writer/RestorableTsFileIOWriterTest.java | 6 +-
788 files changed, 1741 insertions(+), 1672 deletions(-)
copy docs/{Documentation/UserGuide/9-Tools-Hadoop.md => Documentation-CHN/UserGuide/9-System Tools/3-JMX Tool.md} (60%)
copy docs/Documentation/UserGuide/{9-Tools-Hadoop.md => 9-System Tools/3-JMX Tool.md} (56%)
delete mode 100644 tsfile/src/test/java/org/apache/iotdb/tsfile/utils/IncompleteFileTestUtil.java