You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ea...@apache.org on 2019/07/10 04:08:43 UTC
[incubator-iotdb] branch mult_dir_add_ut updated (af35d3f ->
45408b2)
This is an automated email from the ASF dual-hosted git repository.
east pushed a change to branch mult_dir_add_ut
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git.
from af35d3f Merge remote-tracking branch 'origin/master' into mult_dir_add_ut
add b88fa61 fix system memory check in iotdb-env.sh
add 35fc676 set the hadoop-module logback level as info
add 368e4c1 Update .travis.yml
add cec4167 Update .travis.yml
add 5f9d539 update travis config
add bf272d6 Merge pull request #213 from apache/xingtanzjr_update_travis
add 044fcce Merge branch 'master' into fix_memorycheck_in_startsh
add 10e4b4e Merge pull request #211 from apache/fix_memorycheck_in_startsh
add b15ebc5 a small grammar mistake
add fe39d33 Merge pull request #218 from Genius-pig/master
add 3a16bd5 New Storage Engine (#217)
add a62d329 Separate documents into different chapter folders
add a294b48 Merge pull request #204 from samperson1997/master
add 0fbda87 add IOTDB_HOME prefix to dir (#220)
add 77da29b fix unclosed broken file (#223)
add 92c46cb Tsfile write example revised (#224)
add 2df04b1 rename a class and modify some comments (#221)
add d5c7f55 Package name added for example TsFileWrite (#225)
add d7a9e35 [IOTDB-123] Add documents in Chinese and fix links in English documents (#219)
add 6674815 Merge branch 'master' into mult_dir_add_ut
add 45408b2 Merge remote-tracking branch 'origin/master' into mult_dir_add_ut
No new revisions were added by this update.
Summary of changes:
.gitignore | 6 +-
.mvn/wrapper/MavenWrapperDownloader.java | 4 -
.mvn/wrapper/maven-wrapper.properties | 2 +-
.travis.yml | 4 +-
docs/Development.md | 12 +
.../Frequently asked questions.md} | 7 +-
.../OtherMaterial-Examples.md | 7 +-
.../OtherMaterial-Reference.md | 7 +-
.../OtherMaterial-ReleaseNotesV0.7.0.md} | 4 +-
docs/Documentation-CHN/QuickStart.md | 290 +++
.../UserGuideV0.7.0/1-Overview/1-What is IoTDB.md} | 9 +-
.../UserGuideV0.7.0/1-Overview/2-Architecture.md | 36 +
.../UserGuideV0.7.0/1-Overview/3-Scenario.md | 78 +
.../UserGuideV0.7.0/1-Overview/4-Features.md | 51 +
.../1-Key Concepts and Terminology.md | 179 ++
.../2-Data Type.md | 34 +
.../3-Encoding.md | 63 +
.../4-Compression.md | 28 +
.../3-Operation Manual/1-Sample Data.md} | 9 +-
.../3-Operation Manual/2-Data Model Selection.md | 118 ++
.../3-Operation Manual/3-Data Import.md | 85 +
.../3-Operation Manual/4-Data Query.md | 508 +++++
.../3-Operation Manual/5-Data Maintenance.md | 83 +
.../3-Operation Manual/6-Priviledge Management.md | 134 ++
.../4-Deployment and Management/1-Deployment.md | 99 +
.../4-Deployment and Management/2-Configuration.md | 414 ++++
.../3-System Monitor.md | 152 ++
.../4-Deployment and Management/4-System log.md | 64 +
.../5-Data Management.md | 74 +
.../6-Build and use IoTDB by Dockerfile.md} | 4 +-
.../1-IoTDB Query Statement.md} | 233 +--
.../5-IoTDB SQL Documentation/2-Reference.md | 137 ++
.../UserGuideV0.7.0/6-JDBC API/1-JDBC API.md} | 4 +-
.../UserGuideV0.7.0/7-Tools-Cli.md | 77 +
.../UserGuideV0.7.0/7-Tools-Grafana.md | 118 ++
.../UserGuideV0.7.0/7-Tools-Hadoop.md} | 4 +-
.../UserGuideV0.7.0/7-Tools-spark.md} | 4 +-
.../Documentation/UserGuideV0.7.0/0-Content.md | 30 +-
.../1-What is IoTDB.md} | 7 +-
.../UserGuideV0.7.0/1-Overview/2-Architecture.md | 36 +
.../{1-Overview.md => 1-Overview/3-Scenario.md} | 42 -
.../UserGuideV0.7.0/1-Overview/4-Features.md | 33 +
.../1-Key Concepts and Terminology.md} | 75 +-
.../2-Data Type.md | 38 +
.../3-Encoding.md | 62 +
.../4-Compression.md | 28 +
.../1-Sample Data.md} | 9 +-
.../3-Operation Manual/2-Data Model Selection.md | 115 ++
.../3-Operation Manual/3-Data Import.md | 87 +
.../4-Data Query.md} | 395 +---
.../3-Operation Manual/5-Data Maintenance.md | 82 +
.../3-Operation Manual/6-Priviledge Management.md | 124 ++
.../UserGuideV0.7.0/4-Deployment and Management.md | 1113 -----------
.../4-Deployment and Management/1-Deployment.md | 169 ++
.../4-Deployment and Management/2-Configuration.md | 329 ++++
.../3-System Monitor.md | 359 ++++
.../4-Deployment and Management/4-System log.md | 66 +
.../5-Data Management.md | 77 +
.../6-Build and use IoTDB by Dockerfile.md | 92 +
.../1-IoTDB Query Statement.md} | 129 --
.../5-IoTDB SQL Documentation/2-Reference.md | 137 ++
.../UserGuideV0.7.0/6-JDBC API/1-JDBC API.md} | 4 +-
.../apache/iotdb/kafka/KafkaConsumerThread.java | 8 +-
.../java/org/apache/iotdb/kafka/KafkaProducer.java | 4 +-
.../org/apache/iotdb/example/RocketMQConsumer.java | 6 +-
.../org/apache/iotdb/example/RocketMQProducer.java | 4 +-
.../apache/iotdb/tsfile/hadoop/TSFInputFormat.java | 27 +-
.../iotdb/tsfile/hadoop/TSFOutputFormat.java | 8 +-
.../iotdb/tsfile/hadoop/TSFRecordReader.java | 16 +-
.../iotdb/tsfile/hadoop/TSFRecordWriter.java | 4 +-
.../iotdb/tsfile/hadoop/example/TsFileHelper.java | 6 +-
{iotdb => hadoop}/src/test/resources/logback.xml | 0
.../org/apache/iotdb/cli/tool/ImportCsvTestIT.java | 1 -
iotdb/iotdb/conf/iotdb-engine.properties | 146 +-
iotdb/iotdb/conf/iotdb-env.sh | 6 +-
iotdb/iotdb/conf/tsfile-format.properties | 14 +-
iotdb/pom.xml | 26 +
.../iotdb/db/auth/authorizer/BasicAuthorizer.java | 77 +-
.../iotdb/db/auth/authorizer/IAuthorizer.java | 59 +-
.../db/auth/authorizer/LocalFileAuthorizer.java | 4 +-
.../iotdb/db/auth/role/LocalFileRoleAccessor.java | 6 +-
.../iotdb/db/auth/user/BasicUserManager.java | 2 +-
.../iotdb/db/auth/user/LocalFileUserAccessor.java | 18 +-
.../IoTDBDefaultThreadExceptionHandler.java | 4 +-
.../org/apache/iotdb/db/concurrent/ThreadName.java | 1 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 598 ++----
.../org/apache/iotdb/db/conf/IoTDBConstant.java | 7 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 182 +-
.../iotdb/db/conf/directories/Directories.java | 110 --
.../db/conf/directories/DirectoryManager.java | 156 ++
.../directories/strategy/DirectoryStrategy.java | 6 +-
.../strategy/MaxDiskUsableSpaceFirstStrategy.java | 6 +-
.../MinFolderOccupiedSpaceFirstStrategy.java | 2 +-
.../java/org/apache/iotdb/db/engine/Processor.java | 191 --
.../org/apache/iotdb/db/engine/StorageEngine.java | 356 ++++
.../apache/iotdb/db/engine/bufferwrite/Action.java | 28 -
.../db/engine/bufferwrite/ActionException.java | 30 -
.../engine/bufferwrite/BufferWriteProcessor.java | 561 ------
.../db/engine/bufferwrite/FileNodeConstants.java | 44 -
.../bufferwrite/RestorableTsFileIOWriter.java | 326 ---
...MetaDataCache.java => DeviceMetaDataCache.java} | 24 +-
.../iotdb/db/engine/cache/TsFileMetaDataCache.java | 10 +-
.../iotdb/db/engine/cache/TsFileMetadataUtils.java | 16 +-
.../db/engine/filenode/FileNodeFlushFuture.java | 91 -
.../iotdb/db/engine/filenode/FileNodeManager.java | 1252 ------------
.../db/engine/filenode/FileNodeProcessor.java | 2066 --------------------
.../engine/filenode/FileNodeProcessorStatus.java | 51 -
.../db/engine/filenode/FileNodeProcessorStore.java | 165 --
.../db/engine/filenode/OverflowChangeType.java | 57 -
.../iotdb/db/engine/filenode/TsFileResource.java | 390 ----
.../db/engine/memcontrol/BasicMemController.java | 186 --
.../engine/memcontrol/DisabledMemController.java | 56 -
.../db/engine/memcontrol/FlushPartialPolicy.java | 72 -
.../db/engine/memcontrol/ForceFLushAllPolicy.java | 61 -
.../db/engine/memcontrol/JVMMemController.java | 100 -
.../db/engine/memcontrol/MemMonitorThread.java | 88 -
.../db/engine/memcontrol/MemStatisticThread.java | 102 -
.../iotdb/db/engine/memcontrol/NoActPolicy.java | 38 -
.../apache/iotdb/db/engine/memcontrol/Policy.java | 28 -
.../db/engine/memcontrol/RecordMemController.java | 177 --
.../iotdb/db/engine/memtable/AbstractMemTable.java | 106 +-
.../iotdb/db/engine/memtable/ChunkBufferPool.java | 117 ++
.../apache/iotdb/db/engine/memtable/IMemTable.java | 42 +-
.../db/engine/memtable/IWritableMemChunk.java | 26 +-
.../db/engine/memtable/MemSeriesLazyMerger.java | 11 -
.../db/engine/memtable/MemTableFlushTask.java | 244 +++
.../db/engine/memtable/MemTableFlushUtil.java | 110 --
...itiveMemTable.java => NotifyFlushMemTable.java} | 26 +-
.../db/engine/memtable/PrimitiveMemTable.java | 17 +-
.../db/engine/memtable/TimeValuePairSorter.java | 3 +-
.../iotdb/db/engine/memtable/WritableMemChunk.java | 118 +-
.../iotdb/db/engine/modification/Deletion.java | 3 +-
.../iotdb/db/engine/modification/Modification.java | 21 +-
.../db/engine/modification/ModificationFile.java | 6 +-
.../io/LocalTextModificationAccessor.java | 37 +-
.../engine/modification/io/ModificationReader.java | 2 +-
.../iotdb/db/engine/overflow/io/OverflowIO.java | 173 --
.../db/engine/overflow/io/OverflowMemtable.java | 116 --
.../db/engine/overflow/io/OverflowProcessor.java | 737 -------
.../db/engine/overflow/io/OverflowResource.java | 329 ----
.../overflow/io/OverflowedTsFileIOWriter.java | 36 -
.../engine/overflow/metadata/OFFileMetadata.java | 107 -
.../overflow/metadata/OFRowGroupListMetadata.java | 109 --
.../overflow/metadata/OFSeriesListMetadata.java | 107 -
.../db/engine/overflow/utils/MergeStatus.java | 29 -
.../db/engine/overflow/utils/OverflowOpType.java | 29 -
.../{FlushManager.java => FlushPoolManager.java} | 61 +-
.../db/engine/pool/FlushSubTaskPoolManager.java | 95 +
.../apache/iotdb/db/engine/pool/MergeManager.java | 126 --
.../querycontext/GlobalSortedSeriesDataSource.java | 92 -
.../engine/querycontext/MergeSeriesDataSource.java | 33 -
.../db/engine/querycontext/OverflowInsertFile.java | 51 -
.../querycontext/OverflowSeriesDataSource.java | 78 -
.../querycontext/OverflowUpdateDeleteFile.java | 42 -
.../db/engine/querycontext/QueryDataSource.java | 33 +-
.../db/engine/querycontext/ReadOnlyMemChunk.java | 54 +-
.../db/engine/querycontext/UnsealedTsFile.java | 44 -
.../iotdb/db/engine/storagegroup/FlushManager.java | 76 +
.../engine/storagegroup/StorageGroupProcessor.java | 645 ++++++
.../db/engine/storagegroup/TsFileProcessor.java | 532 +++++
.../db/engine/storagegroup/TsFileResource.java | 227 +++
.../version/SimpleFileVersionController.java | 6 +-
.../exception/DiskSpaceInsufficientException.java | 2 +-
.../db/exception/FileNodeNotExistException.java | 33 -
...erException.java => FlushRunTimeException.java} | 14 +-
.../iotdb/db/exception/NotConsistentException.java | 29 -
.../db/exception/OverflowProcessorException.java | 41 -
.../exception/OverflowWrongParameterException.java | 42 -
.../db/exception/ProcessorRuntimException.java | 41 -
...ception.java => QueryInBatchStmtException.java} | 10 +-
...rException.java => StorageEngineException.java} | 10 +-
...ion.java => StorageEngineFailureException.java} | 10 +-
...on.java => StorageGroupProcessorException.java} | 12 +-
...xception.java => TsFileProcessorException.java} | 15 +-
.../db/exception/builder/ExceptionBuilder.java | 8 +-
.../codebased/InvalidParameterException.java | 4 +-
.../java/org/apache/iotdb/db/metadata/MGraph.java | 97 +-
.../org/apache/iotdb/db/metadata/MManager.java | 420 ++--
.../java/org/apache/iotdb/db/metadata/MNode.java | 6 +-
.../java/org/apache/iotdb/db/metadata/MTree.java | 198 +-
.../apache/iotdb/db/metadata/MetadataConstant.java | 3 -
.../apache/iotdb/db/monitor/MonitorConstants.java | 10 +-
.../org/apache/iotdb/db/monitor/StatMonitor.java | 69 +-
.../iotdb/db/monitor/collector/FileSize.java | 61 +-
.../monitor/collector/MemTableWriteTimeCost.java | 85 +
.../org/apache/iotdb/db/qp/QueryProcessor.java | 6 +-
.../apache/iotdb/db/qp/constant/DatetimeUtils.java | 8 +-
.../apache/iotdb/db/qp/constant/SQLConstant.java | 13 +-
.../iotdb/db/qp/constant/TSParserConstant.java | 12 +-
...utor.java => AbstractQueryProcessExecutor.java} | 37 +-
.../db/qp/executor/IQueryProcessExecutor.java | 34 +-
.../iotdb/db/qp/executor/OverflowQPExecutor.java | 649 ------
.../iotdb/db/qp/executor/QueryProcessExecutor.java | 622 +++++-
.../db/qp/logical/crud/BasicFunctionOperator.java | 24 +-
.../iotdb/db/qp/logical/crud/FilterOperator.java | 15 +-
.../iotdb/db/qp/logical/crud/FromOperator.java | 3 +-
.../iotdb/db/qp/logical/crud/FunctionOperator.java | 4 +-
.../iotdb/db/qp/logical/crud/InsertOperator.java | 2 -
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 81 +-
.../iotdb/db/qp/physical/crud/AggregationPlan.java | 1 -
.../iotdb/db/qp/physical/crud/DeletePlan.java | 21 +-
.../iotdb/db/qp/physical/crud/FillQueryPlan.java | 1 -
.../iotdb/db/qp/physical/crud/GroupByPlan.java | 1 -
.../iotdb/db/qp/physical/crud/InsertPlan.java | 100 +-
.../iotdb/db/qp/physical/crud/QueryPlan.java | 1 -
.../iotdb/db/qp/physical/crud/UpdatePlan.java | 17 +-
.../iotdb/db/qp/physical/sys/AuthorPlan.java | 1 -
.../iotdb/db/qp/physical/sys/LoadDataPlan.java | 1 -
.../iotdb/db/qp/physical/sys/MetadataPlan.java | 4 +-
.../iotdb/db/qp/physical/sys/PropertyPlan.java | 1 -
.../iotdb/db/qp/physical/transfer/Codec.java | 29 -
.../db/qp/physical/transfer/CodecInstances.java | 472 -----
.../db/qp/physical/transfer/PhysicalPlanCodec.java | 57 -
.../physical/transfer/PhysicalPlanLogTransfer.java | 90 -
.../db/qp/physical/transfer/SystemLogOperator.java | 35 -
.../iotdb/db/qp/strategy/LogicalGenerator.java | 163 +-
.../iotdb/db/qp/strategy/PhysicalGenerator.java | 24 +-
.../qp/strategy/optimizer/ConcatPathOptimizer.java | 2 -
.../optimizer/MergeSingleFilterOptimizer.java | 34 +-
.../db/query/aggregation/AggregateFunction.java | 4 +-
.../db/query/aggregation/impl/CountAggrFunc.java | 10 +-
.../db/query/aggregation/impl/FirstAggrFunc.java | 4 +-
.../db/query/aggregation/impl/LastAggrFunc.java | 4 +-
.../db/query/aggregation/impl/MaxTimeAggrFunc.java | 6 +-
.../query/aggregation/impl/MaxValueAggrFunc.java | 4 +-
.../db/query/aggregation/impl/MeanAggrFunc.java | 4 +-
.../db/query/aggregation/impl/MinTimeAggrFunc.java | 4 +-
.../query/aggregation/impl/MinValueAggrFunc.java | 4 +-
.../iotdb/db/query/context/QueryContext.java | 9 +-
.../iotdb/db/query/control/FileReaderManager.java | 15 +-
.../iotdb/db/query/control/JobFileManager.java | 24 +-
.../db/query/control/QueryResourceManager.java | 64 +-
.../apache/iotdb/db/query/dataset/AuthDataSet.java | 6 +-
...ator.java => EngineDataSetWithValueFilter.java} | 26 +-
...r.java => EngineDataSetWithoutValueFilter.java} | 28 +-
.../groupby/GroupByWithValueFilterDataSet.java | 20 +-
....java => GroupByWithoutValueFilterDataSet.java} | 44 +-
.../AbstractExecutorWithoutTimeGenerator.java | 84 -
.../db/query/executor/AggregateEngineExecutor.java | 67 +-
.../iotdb/db/query/executor/EngineExecutor.java | 127 ++
.../executor/EngineExecutorWithTimeGenerator.java | 89 -
.../EngineExecutorWithoutTimeGenerator.java | 77 -
.../iotdb/db/query/executor/EngineQueryRouter.java | 45 +-
.../db/query/executor/FillEngineExecutor.java | 15 +-
.../db/query/executor/IEngineQueryRouter.java | 10 +-
.../db/query/factory/ISeriesReaderFactory.java | 90 +
.../db/query/factory/SeriesReaderFactory.java | 275 ---
.../db/query/factory/SeriesReaderFactoryImpl.java | 286 +++
.../java/org/apache/iotdb/db/query/fill/IFill.java | 26 +-
.../org/apache/iotdb/db/query/fill/LinearFill.java | 8 +-
.../apache/iotdb/db/query/fill/PreviousFill.java | 8 +-
.../apache/iotdb/db/query/reader/IPointReader.java | 8 +-
.../org/apache/iotdb/db/query/reader/IReader.java | 36 -
...derByTimeStamp.java => IReaderByTimeStamp.java} | 7 +-
.../query/reader/SeriesReaderWithValueFilter.java | 75 +
...er.java => SeriesReaderWithoutValueFilter.java} | 43 +-
.../iotdb/db/query/reader/mem/MemChunkReader.java | 6 +-
.../reader/mem/MemChunkReaderByTimestamp.java | 4 +-
...Timestamp.java => SeriesReaderByTimestamp.java} | 15 +-
.../db/query/reader/sequence/IterateReader.java | 84 +
.../query/reader/sequence/SequenceDataReader.java | 148 --
.../sequence/SequenceDataReaderByTimestamp.java | 108 -
...sFilesReader.java => SequenceSeriesReader.java} | 142 +-
...p.java => SequenceSeriesReaderByTimestamp.java} | 78 +-
.../reader/sequence/UnSealedTsFileReader.java | 65 +-
.../sequence/UnSealedTsFileReaderByTimestamp.java | 93 +
.../sequence/UnSealedTsFilesReaderByTimestamp.java | 64 -
.../sequence/adapter/FileSeriesReaderAdapter.java} | 49 +-
.../FileSeriesReaderByTimestampAdapter.java} | 35 +-
...EngineChunkReader.java => DiskChunkReader.java} | 21 +-
...estamp.java => DiskChunkReaderByTimestamp.java} | 14 +-
.../UnsequenceSeriesReader.java} | 26 +-
.../timegenerator/AbstractNodeConstructor.java | 44 +-
.../db/query/timegenerator/EngineLeafNode.java | 6 +-
.../query/timegenerator/EngineNodeConstructor.java | 22 +-
.../query/timegenerator/EngineTimeGenerator.java | 6 +-
.../org/apache/iotdb/db/rescon/MemTablePool.java | 105 +
.../apache/iotdb/db/rescon/PrimitiveArrayPool.java | 162 ++
.../apache/iotdb/db/rescon/TVListAllocator.java | 113 ++
.../TVListAllocatorMBean.java} | 9 +-
.../apache/iotdb/db/service/CloseMergeService.java | 211 --
.../java/org/apache/iotdb/db/service/IService.java | 2 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 91 +-
.../org/apache/iotdb/db/service/IoTDBMBean.java | 4 +-
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 9 +-
.../org/apache/iotdb/db/service/JDBCService.java | 45 +-
.../iotdb/db/service/JDBCServiceEventHandler.java | 4 +-
.../org/apache/iotdb/db/service/JMXService.java | 16 +-
.../java/org/apache/iotdb/db/service/Monitor.java | 47 +-
.../org/apache/iotdb/db/service/MonitorMBean.java | 8 -
.../apache/iotdb/db/service/RegisterManager.java | 8 +-
.../org/apache/iotdb/db/service/ServiceType.java | 5 +-
.../org/apache/iotdb/db/service/StartupChecks.java | 59 +-
.../org/apache/iotdb/db/service/TSServiceImpl.java | 523 +++--
.../org/apache/iotdb/db/sql/parse/AstNode.java | 82 +-
.../org/apache/iotdb/db/sql/parse/ParseDriver.java | 42 +-
.../iotdb/db/sync/conf/SyncSenderConfig.java | 28 +-
.../iotdb/db/sync/conf/SyncSenderDescriptor.java | 26 +-
...cServiceManager.java => SyncServerManager.java} | 77 +-
.../db/sync/receiver/SyncServiceEventHandler.java | 55 -
.../iotdb/db/sync/receiver/SyncServiceImpl.java | 68 +-
.../iotdb/db/sync/sender/SyncFileManager.java | 44 +-
.../iotdb/db/sync/sender/SyncSenderImpl.java | 50 +-
.../java/org/apache/iotdb/db/tools/WalChecker.java | 76 +-
.../java/org/apache/iotdb/db/utils/AuthUtils.java | 12 +-
.../org/apache/iotdb/db/utils/CommonUtils.java | 46 +-
.../iotdb/db/utils/CopyOnReadLinkedList.java | 73 +
.../org/apache/iotdb/db/utils/FilePathUtils.java | 4 +
.../org/apache/iotdb/db/utils/FileSchemaUtils.java | 12 +-
.../java/org/apache/iotdb/db/utils/FileUtils.java | 105 -
.../java/org/apache/iotdb/db/utils/IOUtils.java | 6 +-
.../org/apache/iotdb/db/utils/ImmediateFuture.java | 58 -
.../org/apache/iotdb/db/utils/LoadDataUtils.java | 246 ---
.../java/org/apache/iotdb/db/utils/MemUtils.java | 76 +-
.../org/apache/iotdb/db/utils/OpenFileNumUtil.java | 72 +-
.../apache/iotdb/db/utils/PrimitiveArrayList.java | 135 --
.../iotdb/db/utils/PrimitiveArrayListFactory.java | 47 -
.../Utils.java => utils/QueryDataSetUtils.java} | 14 +-
.../org/apache/iotdb/db/utils/RecordUtils.java | 115 --
.../org/apache/iotdb/db/utils/TsPrimitiveType.java | 12 +-
.../iotdb/db/utils/datastructure/BinaryTVList.java | 176 ++
.../db/utils/datastructure/BooleanTVList.java | 175 ++
.../iotdb/db/utils/datastructure/DoubleTVList.java | 175 ++
.../iotdb/db/utils/datastructure/FloatTVList.java | 175 ++
.../iotdb/db/utils/datastructure/IntTVList.java | 175 ++
.../iotdb/db/utils/datastructure/LongTVList.java | 175 ++
.../iotdb/db/utils/datastructure/TVList.java | 396 ++++
.../org/apache/iotdb/db/writelog/RecoverStage.java | 50 -
.../iotdb/db/writelog/io/BatchLogReader.java | 81 +
.../apache/iotdb/db/writelog/io/ILogReader.java | 25 +-
.../apache/iotdb/db/writelog/io/ILogWriter.java | 24 +-
.../org/apache/iotdb/db/writelog/io/LogWriter.java | 66 +-
.../iotdb/db/writelog/io/MultiFileLogReader.java | 75 +
.../apache/iotdb/db/writelog/io/RAFLogReader.java | 104 -
.../iotdb/db/writelog/io/SingleFileLogReader.java | 133 ++
.../writelog/manager/MultiFileLogNodeManager.java | 114 +-
.../db/writelog/manager/WriteLogNodeManager.java | 30 +-
.../db/writelog/node/ExclusiveWriteLogNode.java | 282 ++-
.../iotdb/db/writelog/node/WriteLogNode.java | 49 +-
.../recover/ExclusiveLogRecoverPerformer.java | 366 ----
.../writelog/recover/FileNodeRecoverPerformer.java | 55 -
.../iotdb/db/writelog/recover/LogReplayer.java | 146 ++
.../db/writelog/recover/RecoverPerformer.java | 32 -
.../writelog/recover/TsFileRecoverPerformer.java | 140 ++
.../db/writelog/replay/ConcreteLogReplayer.java | 102 -
.../iotdb/db/writelog/replay/LogReplayer.java | 27 -
.../iotdb/db/auth/LocalFileAuthorizerTest.java | 95 +-
.../strategy/DirectoryStrategyTest.java | 22 +-
.../java/org/apache/iotdb/db/engine/PathUtils.java | 64 -
.../org/apache/iotdb/db/engine/ProcessorTest.java | 152 --
.../engine/bufferwrite/BufferWriteBenchmark.java | 127 --
.../bufferwrite/BufferWriteProcessorNewTest.java | 172 --
.../bufferwrite/BufferWriteProcessorTest.java | 257 ---
.../bufferwrite/RestorableTsFileIOWriterTest.java | 266 ---
.../filenode/FileNodeProcessorStoreTest.java | 91 -
.../db/engine/filenode/TsFileResourceTest.java | 98 -
.../memcontrol/BufferwriteFileSizeControlTest.java | 164 --
.../memcontrol/BufferwriteMetaSizeControlTest.java | 165 --
.../db/engine/memcontrol/IoTDBMemControlTest.java | 195 --
.../db/engine/memcontrol/MemControllerTest.java | 95 -
.../memcontrol/OverflowFileSizeControlTest.java | 143 --
.../memcontrol/OverflowMetaSizeControlTest.java | 144 --
.../db/engine/memtable/ChunkBufferPoolTest.java | 84 +
.../db/engine/memtable/MemTableFlushTaskTest.java | 81 +
.../iotdb/db/engine/memtable/MemTablePoolTest.java | 95 +
.../db/engine/memtable/PrimitiveMemTableTest.java | 6 +-
.../engine/modification/DeletionFileNodeTest.java | 107 +-
.../db/engine/modification/DeletionQueryTest.java | 106 +-
.../engine/modification/ModificationFileTest.java | 17 +-
.../io/LocalTextModificationAccessorTest.java | 9 +-
.../db/engine/overflow/io/OverflowIOTest.java | 65 -
.../engine/overflow/io/OverflowMemtableTest.java | 100 -
.../overflow/io/OverflowProcessorBenchmark.java | 123 --
.../engine/overflow/io/OverflowProcessorTest.java | 211 --
.../engine/overflow/io/OverflowResourceTest.java | 92 -
.../db/engine/overflow/io/OverflowTestUtils.java | 77 -
.../overflow/metadata/OFFileMetadataTest.java | 90 -
.../metadata/OFRowGroupListMetadataTest.java | 93 -
.../metadata/OFSeriesListMetadataTest.java | 88 -
.../overflow/metadata/OverflowTestHelper.java | 84 -
.../db/engine/overflow/metadata/OverflowUtils.java | 138 --
.../FileNodeManagerBenchmark.java | 18 +-
.../storagegroup/StorageGroupProcessorTest.java | 110 ++
.../engine/storagegroup/TsFileProcessorTest.java | 208 ++
.../apache/iotdb/db/integration/IOTDBFillIT.java | 1 -
.../iotdb/db/integration/IOTDBGroupByIT.java | 1 -
.../iotdb/db/integration/IoTDBAggregationIT.java | 3 +-
.../integration/IoTDBAggregationLargeDataIT.java | 3 +-
.../integration/IoTDBAggregationSmallDataIT.java | 1 -
.../iotdb/db/integration/IoTDBAuthorizationIT.java | 1 -
.../iotdb/db/integration/IoTDBCompleteIT.java | 35 +-
.../apache/iotdb/db/integration/IoTDBDaemonIT.java | 1 -
.../iotdb/db/integration/IoTDBDeletionIT.java | 10 +-
.../db/integration/IoTDBEngineTimeGeneratorIT.java | 11 +-
.../db/integration/IoTDBFloatPrecisionIT.java | 1 -
.../db/integration/IoTDBFlushQueryMergeTest.java | 11 +-
.../iotdb/db/integration/IoTDBLargeDataIT.java | 6 +-
.../iotdb/db/integration/IoTDBLimitSlimitIT.java | 1 -
.../iotdb/db/integration/IoTDBMetadataFetchIT.java | 1 -
.../iotdb/db/integration/IoTDBMultiSeriesIT.java | 6 +-
.../iotdb/db/integration/IoTDBPreparedStmtIT.java | 223 +++
.../db/integration/IoTDBSequenceDataQueryIT.java | 10 +-
.../iotdb/db/integration/IoTDBSeriesReaderIT.java | 24 +-
.../iotdb/db/integration/IoTDBTimeZoneIT.java | 1 -
.../iotdb/db/integration/IoTDBVersionIT.java | 7 +-
.../iotdb/db/metadata/MManagerAdvancedTest.java | 13 +-
.../iotdb/db/metadata/MManagerBasicTest.java | 95 +-
.../iotdb/db/metadata/MManagerEfficiencyTest.java | 155 --
.../iotdb/db/metadata/MManagerImproveTest.java | 5 +-
.../org/apache/iotdb/db/metadata/MTreeTest.java | 53 +-
.../org/apache/iotdb/db/monitor/MonitorTest.java | 147 --
.../iotdb/db/monitor/collector/FileSizeTest.java | 10 +-
.../org/apache/iotdb/db/qp/QueryProcessorTest.java | 4 +-
.../transfer/PhysicalPlanLogTransferTest.java | 162 --
.../iotdb/db/qp/plan/LogicalPlanSmallTest.java | 15 +-
.../apache/iotdb/db/qp/plan/PhysicalPlanTest.java | 13 +-
.../org/apache/iotdb/db/qp/plan/QPUpdateTest.java | 10 +-
.../apache/iotdb/db/qp/utils/MemIntQpExecutor.java | 47 +-
....java => EngineDataSetWithValueFilterTest.java} | 6 +-
.../query/reader/FakedSeriesReaderByTimestamp.java | 4 +-
.../iotdb/db/query/reader/ReaderTestHelper.java | 63 +
...ava => SeriesReaderWithoutValueFilterTest.java} | 10 +-
.../reader/merge/SeriesMergeSortReaderTest.java | 3 +-
...pTest.java => SeriesReaderByTimestampTest.java} | 7 +-
...erTest.java => UnsequenceSeriesReaderTest.java} | 17 +-
.../query/reader/sequence/SeqDataReaderTest.java | 98 +
.../SequenceDataReaderByTimestampTest.java | 91 -
.../reader/sequence/UnsealedSeqReaderTest.java | 93 +
.../UnseqSeriesReaderByTimestampTest.java | 97 +
.../unsequence/UnsequenceSeriesReaderTest.java | 95 +
...est.java => DatetimeQueryDataSetUtilsTest.java} | 2 +-
.../db/sync/sender/MultipleClientSyncTest.java | 18 +-
.../iotdb/db/sync/sender/SingleClientSyncTest.java | 18 +-
.../iotdb/db/sync/sender/SyncFileManagerTest.java | 24 +-
.../org/apache/iotdb/db/sync/test/RandomNum.java | 2 +-
.../apache/iotdb/db/sync/test/SyncTestClient2.java | 12 +-
.../apache/iotdb/db/sync/test/SyncTestClient3.java | 12 +-
.../org/apache/iotdb/db/tools/WalCheckerTest.java | 19 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 124 +-
...ilsTest.java => MathQueryDataSetUtilsTest.java} | 2 +-
.../apache/iotdb/db/utils/OpenFileNumUtilTest.java | 70 +-
.../iotdb/db/utils/PrimitiveArrayListTest.java | 53 -
.../db/utils/datastructure/LongTVListTest.java | 93 +
.../iotdb/db/writelog/IoTDBLogFileSizeTest.java | 63 +-
.../apache/iotdb/db/writelog/PerformanceTest.java | 83 +-
.../org/apache/iotdb/db/writelog/RecoverTest.java | 310 ---
.../iotdb/db/writelog/WriteLogNodeManagerTest.java | 79 +-
.../apache/iotdb/db/writelog/WriteLogNodeTest.java | 182 +-
.../iotdb/db/writelog/io/LogWriterReaderTest.java | 33 +-
.../db/writelog/io/MultiFileLogReaderTest.java | 82 +
.../iotdb/db/writelog/recover/LogReplayerTest.java | 124 ++
.../db/writelog/recover/SeqTsFileRecoverTest.java | 149 ++
.../writelog/recover/UnseqTsFileRecoverTest.java | 160 ++
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 5 +-
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 14 +-
.../java/org/apache/iotdb/jdbc/IoTDBDriver.java | 4 +-
.../jdbc/IoTDBPreparedInsertionStatement.java | 73 +
...eStatement.java => IoTDBPreparedStatement.java} | 12 +-
.../org/apache/iotdb/jdbc/IoTDBQueryResultSet.java | 4 +-
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 14 +-
...ntTest.java => IoTDBPreparedStatementTest.java} | 32 +-
service-rpc/src/main/thrift/rpc.thrift | 13 +
service-rpc/src/main/thrift/sync.thrift | 2 +-
tsfile/example/readme.md | 39 +-
.../apache/iotdb/tsfile/TsFileSequenceRead.java | 2 +-
.../java/org/apache/iotdb/tsfile/TsFileWrite.java | 236 ++-
.../iotdb/tsfile/common/conf/TSFileConfig.java | 9 +-
.../iotdb/tsfile/common/conf/TSFileDescriptor.java | 26 +-
.../tsfile/common/constant/SystemConstant.java | 1 +
.../iotdb/tsfile/compress/IUnCompressor.java | 6 +-
.../tsfile/encoding/decoder/BitmapDecoder.java | 8 +-
.../encoding/decoder/DoublePrecisionDecoder.java | 6 +-
.../tsfile/encoding/decoder/FloatDecoder.java | 10 +-
.../tsfile/encoding/decoder/GorillaDecoder.java | 4 +-
.../tsfile/encoding/decoder/IntRleDecoder.java | 4 +-
.../tsfile/encoding/decoder/LongRleDecoder.java | 4 +-
.../tsfile/encoding/decoder/PlainDecoder.java | 6 +-
.../encoding/decoder/SinglePrecisionDecoder.java | 6 +-
.../tsfile/encoding/encoder/BitmapEncoder.java | 6 +-
.../encoding/encoder/DeltaBinaryEncoder.java | 4 +-
.../encoding/encoder/DoublePrecisionEncoder.java | 8 +-
.../iotdb/tsfile/encoding/encoder/Encoder.java | 16 +-
.../tsfile/encoding/encoder/FloatEncoder.java | 6 +-
.../tsfile/encoding/encoder/PlainEncoder.java | 17 +-
.../iotdb/tsfile/encoding/encoder/RleEncoder.java | 10 +-
.../encoding/encoder/SinglePrecisionEncoder.java | 2 +-
.../tsfile/encoding/encoder/TSEncodingBuilder.java | 8 +-
.../iotdb/tsfile/file/metadata/TsFileMetaData.java | 2 +-
.../file/metadata/statistics/Statistics.java | 2 +-
.../iotdb/tsfile/read/TsFileRestorableReader.java | 10 +-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 82 +-
.../apache/iotdb/tsfile/read/common/BatchData.java | 4 +-
.../query/dataset/DataSetWithTimeGenerator.java | 16 +-
.../query/dataset/DataSetWithoutTimeGenerator.java | 2 +-
.../query/executor/ExecutorWithTimeGenerator.java | 6 +-
.../tsfile/read/reader/DefaultTsFileInput.java | 7 +-
.../tsfile/read/reader/chunk/ChunkReader.java | 2 +-
...stamp.java => FileSeriesReaderByTimestamp.java} | 4 +-
.../tsfile/utils/ReadWriteForEncodingUtils.java | 4 +-
.../iotdb/tsfile/utils/ReadWriteIOUtils.java | 36 +-
.../apache/iotdb/tsfile/write/TsFileWriter.java | 40 +-
.../iotdb/tsfile/write/chunk/ChunkBuffer.java | 22 +-
.../iotdb/tsfile/write/chunk/ChunkWriterImpl.java | 18 +-
.../iotdb/tsfile/write/chunk/IChunkWriter.java | 14 +-
.../apache/iotdb/tsfile/write/page/PageWriter.java | 16 +-
.../tsfile/write/schema/MeasurementSchema.java | 4 +-
.../write/writer/IncompleteFileTestUtil.java | 2 +-
.../write/writer/NativeRestorableIOWriter.java | 93 -
.../write/writer/RestorableTsFileIOWriter.java | 182 ++
.../iotdb/tsfile/write/writer/TsFileIOWriter.java | 49 +-
.../tsfile/encoding/decoder/BitmapDecoderTest.java | 4 +-
.../tsfile/encoding/decoder/FloatDecoderTest.java | 16 +-
.../encoding/decoder/GorillaDecoderTest.java | 6 +-
.../decoder/delta/DeltaBinaryEncoderLongTest.java | 7 -
.../iotdb/tsfile/read/ReadOnlyTsFileTest.java | 4 +-
.../iotdb/tsfile/read/TimePlainEncodeReadTest.java | 2 +-
.../tsfile/read/TsFileSequenceReaderTest.java | 10 -
.../read/filter/IExpressionOptimizerTest.java | 14 +-
.../read/query/executor/QueryExecutorTest.java | 2 +-
.../query/timegenerator/ReaderByTimestampTest.java | 6 +-
.../query/timegenerator/TimeGeneratorTest.java | 2 +-
.../iotdb/tsfile/read/reader/ReaderTest.java | 2 +-
.../org/apache/iotdb/tsfile/utils/RecordUtils.java | 2 -
.../iotdb/tsfile/utils/TsFileGeneratorForTest.java | 23 +-
.../iotdb/tsfile/write/TsFileIOWriterTest.java | 5 +-
.../iotdb/tsfile/write/TsFileReadWriteTest.java | 4 +-
...Test.java => RestorableTsFileIOWriterTest.java} | 93 +-
527 files changed, 17500 insertions(+), 24110 deletions(-)
copy docs/{Documentation/UserGuideV0.7.0/6-JDBC Documentation.md => Documentation-CHN/Frequently asked questions.md} (90%)
copy docs/{Documentation => Documentation-CHN}/OtherMaterial-Examples.md (83%)
copy docs/{Documentation => Documentation-CHN}/OtherMaterial-Reference.md (73%)
copy docs/{Community-History&Vision.md => Documentation-CHN/OtherMaterial-ReleaseNotesV0.7.0.md} (95%)
create mode 100755 docs/Documentation-CHN/QuickStart.md
copy docs/{Documentation/UserGuideV0.7.0/7-Tools-Hadoop.md => Documentation-CHN/UserGuideV0.7.0/1-Overview/1-What is IoTDB.md} (72%)
create mode 100644 docs/Documentation-CHN/UserGuideV0.7.0/1-Overview/2-Architecture.md
create mode 100644 docs/Documentation-CHN/UserGuideV0.7.0/1-Overview/3-Scenario.md
create mode 100644 docs/Documentation-CHN/UserGuideV0.7.0/1-Overview/4-Features.md
create mode 100644 docs/Documentation-CHN/UserGuideV0.7.0/2-Concept Key Concepts and Terminology/1-Key Concepts and Terminology.md
create mode 100644 docs/Documentation-CHN/UserGuideV0.7.0/2-Concept Key Concepts and Terminology/2-Data Type.md
create mode 100644 docs/Documentation-CHN/UserGuideV0.7.0/2-Concept Key Concepts and Terminology/3-Encoding.md
create mode 100644 docs/Documentation-CHN/UserGuideV0.7.0/2-Concept Key Concepts and Terminology/4-Compression.md
copy docs/{Documentation/UserGuideV0.7.0/7-Tools-Hadoop.md => Documentation-CHN/UserGuideV0.7.0/3-Operation Manual/1-Sample Data.md} (70%)
create mode 100644 docs/Documentation-CHN/UserGuideV0.7.0/3-Operation Manual/2-Data Model Selection.md
create mode 100644 docs/Documentation-CHN/UserGuideV0.7.0/3-Operation Manual/3-Data Import.md
create mode 100644 docs/Documentation-CHN/UserGuideV0.7.0/3-Operation Manual/4-Data Query.md
create mode 100644 docs/Documentation-CHN/UserGuideV0.7.0/3-Operation Manual/5-Data Maintenance.md
create mode 100644 docs/Documentation-CHN/UserGuideV0.7.0/3-Operation Manual/6-Priviledge Management.md
create mode 100644 docs/Documentation-CHN/UserGuideV0.7.0/4-Deployment and Management/1-Deployment.md
create mode 100644 docs/Documentation-CHN/UserGuideV0.7.0/4-Deployment and Management/2-Configuration.md
create mode 100644 docs/Documentation-CHN/UserGuideV0.7.0/4-Deployment and Management/3-System Monitor.md
create mode 100644 docs/Documentation-CHN/UserGuideV0.7.0/4-Deployment and Management/4-System log.md
create mode 100644 docs/Documentation-CHN/UserGuideV0.7.0/4-Deployment and Management/5-Data Management.md
copy docs/{Community-History&Vision.md => Documentation-CHN/UserGuideV0.7.0/4-Deployment and Management/6-Build and use IoTDB by Dockerfile.md} (94%)
copy docs/{Documentation/UserGuideV0.7.0/5-SQL Documentation.md => Documentation-CHN/UserGuideV0.7.0/5-IoTDB SQL Documentation/1-IoTDB Query Statement.md} (71%)
create mode 100644 docs/Documentation-CHN/UserGuideV0.7.0/5-IoTDB SQL Documentation/2-Reference.md
copy docs/{Community-History&Vision.md => Documentation-CHN/UserGuideV0.7.0/6-JDBC API/1-JDBC API.md} (96%)
create mode 100644 docs/Documentation-CHN/UserGuideV0.7.0/7-Tools-Cli.md
create mode 100644 docs/Documentation-CHN/UserGuideV0.7.0/7-Tools-Grafana.md
copy docs/{Community-History&Vision.md => Documentation-CHN/UserGuideV0.7.0/7-Tools-Hadoop.md} (94%)
copy docs/{Community-History&Vision.md => Documentation-CHN/UserGuideV0.7.0/7-Tools-spark.md} (94%)
copy hadoop/README.md => docs/Documentation/UserGuideV0.7.0/0-Content.md (56%)
rename docs/Documentation/UserGuideV0.7.0/{6-JDBC Documentation.md => 1-Overview/1-What is IoTDB.md} (62%)
create mode 100644 docs/Documentation/UserGuideV0.7.0/1-Overview/2-Architecture.md
rename docs/Documentation/UserGuideV0.7.0/{1-Overview.md => 1-Overview/3-Scenario.md} (66%)
create mode 100644 docs/Documentation/UserGuideV0.7.0/1-Overview/4-Features.md
rename docs/Documentation/UserGuideV0.7.0/{2-Concept.md => 2-Concept Key Concepts and Terminology/1-Key Concepts and Terminology.md} (60%)
create mode 100644 docs/Documentation/UserGuideV0.7.0/2-Concept Key Concepts and Terminology/2-Data Type.md
create mode 100644 docs/Documentation/UserGuideV0.7.0/2-Concept Key Concepts and Terminology/3-Encoding.md
create mode 100644 docs/Documentation/UserGuideV0.7.0/2-Concept Key Concepts and Terminology/4-Compression.md
copy docs/Documentation/UserGuideV0.7.0/{7-Tools-Hadoop.md => 3-Operation Manual/1-Sample Data.md} (57%)
create mode 100644 docs/Documentation/UserGuideV0.7.0/3-Operation Manual/2-Data Model Selection.md
create mode 100644 docs/Documentation/UserGuideV0.7.0/3-Operation Manual/3-Data Import.md
rename docs/Documentation/UserGuideV0.7.0/{3-Operation Manual.md => 3-Operation Manual/4-Data Query.md} (52%)
create mode 100644 docs/Documentation/UserGuideV0.7.0/3-Operation Manual/5-Data Maintenance.md
create mode 100644 docs/Documentation/UserGuideV0.7.0/3-Operation Manual/6-Priviledge Management.md
delete mode 100644 docs/Documentation/UserGuideV0.7.0/4-Deployment and Management.md
create mode 100644 docs/Documentation/UserGuideV0.7.0/4-Deployment and Management/1-Deployment.md
create mode 100644 docs/Documentation/UserGuideV0.7.0/4-Deployment and Management/2-Configuration.md
create mode 100644 docs/Documentation/UserGuideV0.7.0/4-Deployment and Management/3-System Monitor.md
create mode 100644 docs/Documentation/UserGuideV0.7.0/4-Deployment and Management/4-System log.md
create mode 100644 docs/Documentation/UserGuideV0.7.0/4-Deployment and Management/5-Data Management.md
create mode 100644 docs/Documentation/UserGuideV0.7.0/4-Deployment and Management/6-Build and use IoTDB by Dockerfile.md
rename docs/Documentation/UserGuideV0.7.0/{5-SQL Documentation.md => 5-IoTDB SQL Documentation/1-IoTDB Query Statement.md} (85%)
create mode 100644 docs/Documentation/UserGuideV0.7.0/5-IoTDB SQL Documentation/2-Reference.md
copy docs/{Community-History&Vision.md => Documentation/UserGuideV0.7.0/6-JDBC API/1-JDBC API.md} (96%)
copy {iotdb => hadoop}/src/test/resources/logback.xml (100%)
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/conf/directories/Directories.java
create mode 100644 iotdb/src/main/java/org/apache/iotdb/db/conf/directories/DirectoryManager.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/Processor.java
create mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/StorageEngine.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/bufferwrite/Action.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/bufferwrite/ActionException.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/bufferwrite/BufferWriteProcessor.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/bufferwrite/FileNodeConstants.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/bufferwrite/RestorableTsFileIOWriter.java
rename iotdb/src/main/java/org/apache/iotdb/db/engine/cache/{RowGroupBlockMetaDataCache.java => DeviceMetaDataCache.java} (86%)
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/filenode/FileNodeFlushFuture.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/filenode/FileNodeManager.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/filenode/FileNodeProcessor.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/filenode/FileNodeProcessorStatus.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/filenode/FileNodeProcessorStore.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/filenode/OverflowChangeType.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/filenode/TsFileResource.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/memcontrol/BasicMemController.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/memcontrol/DisabledMemController.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/memcontrol/FlushPartialPolicy.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/memcontrol/ForceFLushAllPolicy.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/memcontrol/JVMMemController.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/memcontrol/MemMonitorThread.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/memcontrol/MemStatisticThread.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/memcontrol/NoActPolicy.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/memcontrol/Policy.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/memcontrol/RecordMemController.java
create mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/memtable/ChunkBufferPool.java
create mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/memtable/MemTableFlushTask.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/memtable/MemTableFlushUtil.java
copy iotdb/src/main/java/org/apache/iotdb/db/engine/memtable/{PrimitiveMemTable.java => NotifyFlushMemTable.java} (71%)
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/overflow/io/OverflowIO.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/overflow/io/OverflowMemtable.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/overflow/io/OverflowProcessor.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/overflow/io/OverflowResource.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/overflow/io/OverflowedTsFileIOWriter.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/overflow/metadata/OFFileMetadata.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/overflow/metadata/OFRowGroupListMetadata.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/overflow/metadata/OFSeriesListMetadata.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/overflow/utils/MergeStatus.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/overflow/utils/OverflowOpType.java
rename iotdb/src/main/java/org/apache/iotdb/db/engine/pool/{FlushManager.java => FlushPoolManager.java} (63%)
create mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/pool/FlushSubTaskPoolManager.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/pool/MergeManager.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/querycontext/GlobalSortedSeriesDataSource.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/querycontext/MergeSeriesDataSource.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/querycontext/OverflowInsertFile.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/querycontext/OverflowSeriesDataSource.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/querycontext/OverflowUpdateDeleteFile.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/querycontext/UnsealedTsFile.java
create mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/storagegroup/FlushManager.java
create mode 100755 iotdb/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java
create mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessor.java
create mode 100644 iotdb/src/main/java/org/apache/iotdb/db/engine/storagegroup/TsFileResource.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/exception/FileNodeNotExistException.java
rename iotdb/src/main/java/org/apache/iotdb/db/exception/{RecoverException.java => FlushRunTimeException.java} (76%)
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/exception/NotConsistentException.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/exception/OverflowProcessorException.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/exception/OverflowWrongParameterException.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/exception/ProcessorRuntimException.java
copy iotdb/src/main/java/org/apache/iotdb/db/exception/{SysCheckException.java => QueryInBatchStmtException.java} (77%)
rename iotdb/src/main/java/org/apache/iotdb/db/exception/{FileNodeManagerException.java => StorageEngineException.java} (79%)
copy iotdb/src/main/java/org/apache/iotdb/db/exception/{SysCheckException.java => StorageEngineFailureException.java} (75%)
rename iotdb/src/main/java/org/apache/iotdb/db/exception/{FileNodeProcessorException.java => StorageGroupProcessorException.java} (74%)
rename iotdb/src/main/java/org/apache/iotdb/db/exception/{BufferWriteProcessorException.java => TsFileProcessorException.java} (69%)
create mode 100644 iotdb/src/main/java/org/apache/iotdb/db/monitor/collector/MemTableWriteTimeCost.java
copy iotdb/src/main/java/org/apache/iotdb/db/qp/executor/{QueryProcessExecutor.java => AbstractQueryProcessExecutor.java} (80%)
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/qp/executor/OverflowQPExecutor.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/qp/physical/transfer/Codec.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/qp/physical/transfer/CodecInstances.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/qp/physical/transfer/PhysicalPlanCodec.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/qp/physical/transfer/PhysicalPlanLogTransfer.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/qp/physical/transfer/SystemLogOperator.java
rename iotdb/src/main/java/org/apache/iotdb/db/query/dataset/{EngineDataSetWithTimeGenerator.java => EngineDataSetWithValueFilter.java} (77%)
rename iotdb/src/main/java/org/apache/iotdb/db/query/dataset/{EngineDataSetWithoutTimeGenerator.java => EngineDataSetWithoutValueFilter.java} (81%)
rename iotdb/src/main/java/org/apache/iotdb/db/query/dataset/groupby/{GroupByWithOnlyTimeFilterDataSet.java => GroupByWithoutValueFilterDataSet.java} (89%)
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/query/executor/AbstractExecutorWithoutTimeGenerator.java
create mode 100644 iotdb/src/main/java/org/apache/iotdb/db/query/executor/EngineExecutor.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/query/executor/EngineExecutorWithTimeGenerator.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/query/executor/EngineExecutorWithoutTimeGenerator.java
create mode 100644 iotdb/src/main/java/org/apache/iotdb/db/query/factory/ISeriesReaderFactory.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/query/factory/SeriesReaderFactory.java
create mode 100644 iotdb/src/main/java/org/apache/iotdb/db/query/factory/SeriesReaderFactoryImpl.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/query/reader/IReader.java
rename iotdb/src/main/java/org/apache/iotdb/db/query/reader/{merge/EngineReaderByTimeStamp.java => IReaderByTimeStamp.java} (82%)
create mode 100644 iotdb/src/main/java/org/apache/iotdb/db/query/reader/SeriesReaderWithValueFilter.java
rename iotdb/src/main/java/org/apache/iotdb/db/query/reader/{AllDataReader.java => SeriesReaderWithoutValueFilter.java} (72%)
rename iotdb/src/main/java/org/apache/iotdb/db/query/reader/merge/{PriorityMergeReaderByTimestamp.java => SeriesReaderByTimestamp.java} (76%)
create mode 100644 iotdb/src/main/java/org/apache/iotdb/db/query/reader/sequence/IterateReader.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/query/reader/sequence/SequenceDataReader.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/query/reader/sequence/SequenceDataReaderByTimestamp.java
rename iotdb/src/main/java/org/apache/iotdb/db/query/reader/sequence/{SealedTsFilesReader.java => SequenceSeriesReader.java} (53%)
rename iotdb/src/main/java/org/apache/iotdb/db/query/reader/sequence/{SealedTsFilesReaderByTimestamp.java => SequenceSeriesReaderByTimestamp.java} (60%)
create mode 100644 iotdb/src/main/java/org/apache/iotdb/db/query/reader/sequence/UnSealedTsFileReaderByTimestamp.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/query/reader/sequence/UnSealedTsFilesReaderByTimestamp.java
copy iotdb/src/main/java/org/apache/iotdb/db/query/{timegenerator/EngineLeafNode.java => reader/sequence/adapter/FileSeriesReaderAdapter.java} (50%)
copy iotdb/src/main/java/org/apache/iotdb/db/query/{dataset/AuthDataSet.java => reader/sequence/adapter/FileSeriesReaderByTimestampAdapter.java} (53%)
rename iotdb/src/main/java/org/apache/iotdb/db/query/reader/unsequence/{EngineChunkReader.java => DiskChunkReader.java} (78%)
rename iotdb/src/main/java/org/apache/iotdb/db/query/reader/unsequence/{EngineChunkReaderByTimestamp.java => DiskChunkReaderByTimestamp.java} (86%)
rename iotdb/src/main/java/org/apache/iotdb/db/query/reader/{merge/PriorityMergeReader.java => unsequence/UnsequenceSeriesReader.java} (82%)
create mode 100644 iotdb/src/main/java/org/apache/iotdb/db/rescon/MemTablePool.java
create mode 100644 iotdb/src/main/java/org/apache/iotdb/db/rescon/PrimitiveArrayPool.java
create mode 100644 iotdb/src/main/java/org/apache/iotdb/db/rescon/TVListAllocator.java
rename iotdb/src/main/java/org/apache/iotdb/db/{writelog/LogPosition.java => rescon/TVListAllocatorMBean.java} (85%)
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/service/CloseMergeService.java
rename iotdb/src/main/java/org/apache/iotdb/db/sync/receiver/{SyncServiceManager.java => SyncServerManager.java} (59%)
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/sync/receiver/SyncServiceEventHandler.java
create mode 100644 iotdb/src/main/java/org/apache/iotdb/db/utils/CopyOnReadLinkedList.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/utils/FileUtils.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/utils/ImmediateFuture.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/utils/LoadDataUtils.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/utils/PrimitiveArrayList.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/utils/PrimitiveArrayListFactory.java
rename iotdb/src/main/java/org/apache/iotdb/db/{service/Utils.java => utils/QueryDataSetUtils.java} (92%)
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/utils/RecordUtils.java
create mode 100644 iotdb/src/main/java/org/apache/iotdb/db/utils/datastructure/BinaryTVList.java
create mode 100644 iotdb/src/main/java/org/apache/iotdb/db/utils/datastructure/BooleanTVList.java
create mode 100644 iotdb/src/main/java/org/apache/iotdb/db/utils/datastructure/DoubleTVList.java
create mode 100644 iotdb/src/main/java/org/apache/iotdb/db/utils/datastructure/FloatTVList.java
create mode 100644 iotdb/src/main/java/org/apache/iotdb/db/utils/datastructure/IntTVList.java
create mode 100644 iotdb/src/main/java/org/apache/iotdb/db/utils/datastructure/LongTVList.java
create mode 100644 iotdb/src/main/java/org/apache/iotdb/db/utils/datastructure/TVList.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/writelog/RecoverStage.java
create mode 100644 iotdb/src/main/java/org/apache/iotdb/db/writelog/io/BatchLogReader.java
create mode 100644 iotdb/src/main/java/org/apache/iotdb/db/writelog/io/MultiFileLogReader.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/writelog/io/RAFLogReader.java
create mode 100644 iotdb/src/main/java/org/apache/iotdb/db/writelog/io/SingleFileLogReader.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/writelog/recover/ExclusiveLogRecoverPerformer.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/writelog/recover/FileNodeRecoverPerformer.java
create mode 100644 iotdb/src/main/java/org/apache/iotdb/db/writelog/recover/LogReplayer.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/writelog/recover/RecoverPerformer.java
create mode 100644 iotdb/src/main/java/org/apache/iotdb/db/writelog/recover/TsFileRecoverPerformer.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/writelog/replay/ConcreteLogReplayer.java
delete mode 100644 iotdb/src/main/java/org/apache/iotdb/db/writelog/replay/LogReplayer.java
delete mode 100644 iotdb/src/test/java/org/apache/iotdb/db/engine/PathUtils.java
delete mode 100644 iotdb/src/test/java/org/apache/iotdb/db/engine/ProcessorTest.java
delete mode 100644 iotdb/src/test/java/org/apache/iotdb/db/engine/bufferwrite/BufferWriteBenchmark.java
delete mode 100644 iotdb/src/test/java/org/apache/iotdb/db/engine/bufferwrite/BufferWriteProcessorNewTest.java
delete mode 100644 iotdb/src/test/java/org/apache/iotdb/db/engine/bufferwrite/BufferWriteProcessorTest.java
delete mode 100644 iotdb/src/test/java/org/apache/iotdb/db/engine/bufferwrite/RestorableTsFileIOWriterTest.java
delete mode 100644 iotdb/src/test/java/org/apache/iotdb/db/engine/filenode/FileNodeProcessorStoreTest.java
delete mode 100644 iotdb/src/test/java/org/apache/iotdb/db/engine/filenode/TsFileResourceTest.java
delete mode 100644 iotdb/src/test/java/org/apache/iotdb/db/engine/memcontrol/BufferwriteFileSizeControlTest.java
delete mode 100644 iotdb/src/test/java/org/apache/iotdb/db/engine/memcontrol/BufferwriteMetaSizeControlTest.java
delete mode 100644 iotdb/src/test/java/org/apache/iotdb/db/engine/memcontrol/IoTDBMemControlTest.java
delete mode 100644 iotdb/src/test/java/org/apache/iotdb/db/engine/memcontrol/MemControllerTest.java
delete mode 100644 iotdb/src/test/java/org/apache/iotdb/db/engine/memcontrol/OverflowFileSizeControlTest.java
delete mode 100644 iotdb/src/test/java/org/apache/iotdb/db/engine/memcontrol/OverflowMetaSizeControlTest.java
create mode 100644 iotdb/src/test/java/org/apache/iotdb/db/engine/memtable/ChunkBufferPoolTest.java
create mode 100644 iotdb/src/test/java/org/apache/iotdb/db/engine/memtable/MemTableFlushTaskTest.java
create mode 100644 iotdb/src/test/java/org/apache/iotdb/db/engine/memtable/MemTablePoolTest.java
delete mode 100644 iotdb/src/test/java/org/apache/iotdb/db/engine/overflow/io/OverflowIOTest.java
delete mode 100644 iotdb/src/test/java/org/apache/iotdb/db/engine/overflow/io/OverflowMemtableTest.java
delete mode 100644 iotdb/src/test/java/org/apache/iotdb/db/engine/overflow/io/OverflowProcessorBenchmark.java
delete mode 100644 iotdb/src/test/java/org/apache/iotdb/db/engine/overflow/io/OverflowProcessorTest.java
delete mode 100644 iotdb/src/test/java/org/apache/iotdb/db/engine/overflow/io/OverflowResourceTest.java
delete mode 100644 iotdb/src/test/java/org/apache/iotdb/db/engine/overflow/io/OverflowTestUtils.java
delete mode 100644 iotdb/src/test/java/org/apache/iotdb/db/engine/overflow/metadata/OFFileMetadataTest.java
delete mode 100644 iotdb/src/test/java/org/apache/iotdb/db/engine/overflow/metadata/OFRowGroupListMetadataTest.java
delete mode 100644 iotdb/src/test/java/org/apache/iotdb/db/engine/overflow/metadata/OFSeriesListMetadataTest.java
delete mode 100644 iotdb/src/test/java/org/apache/iotdb/db/engine/overflow/metadata/OverflowTestHelper.java
delete mode 100644 iotdb/src/test/java/org/apache/iotdb/db/engine/overflow/metadata/OverflowUtils.java
rename iotdb/src/test/java/org/apache/iotdb/db/engine/{filenodev2 => storagegroup}/FileNodeManagerBenchmark.java (87%)
create mode 100644 iotdb/src/test/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessorTest.java
create mode 100644 iotdb/src/test/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessorTest.java
create mode 100644 iotdb/src/test/java/org/apache/iotdb/db/integration/IoTDBPreparedStmtIT.java
delete mode 100644 iotdb/src/test/java/org/apache/iotdb/db/metadata/MManagerEfficiencyTest.java
delete mode 100644 iotdb/src/test/java/org/apache/iotdb/db/monitor/MonitorTest.java
delete mode 100644 iotdb/src/test/java/org/apache/iotdb/db/qp/physical/transfer/PhysicalPlanLogTransferTest.java
rename iotdb/src/test/java/org/apache/iotdb/db/query/dataset/{EngineDataSetWithTimeGeneratorTest.java => EngineDataSetWithValueFilterTest.java} (96%)
create mode 100644 iotdb/src/test/java/org/apache/iotdb/db/query/reader/ReaderTestHelper.java
rename iotdb/src/test/java/org/apache/iotdb/db/query/reader/{AllDataReaderTest.java => SeriesReaderWithoutValueFilterTest.java} (89%)
rename iotdb/src/test/java/org/apache/iotdb/db/query/reader/merge/{PriorityMergeReaderByTimestampTest.java => SeriesReaderByTimestampTest.java} (96%)
rename iotdb/src/test/java/org/apache/iotdb/db/query/reader/merge/{PriorityMergeReaderTest.java => UnsequenceSeriesReaderTest.java} (84%)
create mode 100644 iotdb/src/test/java/org/apache/iotdb/db/query/reader/sequence/SeqDataReaderTest.java
delete mode 100644 iotdb/src/test/java/org/apache/iotdb/db/query/reader/sequence/SequenceDataReaderByTimestampTest.java
create mode 100644 iotdb/src/test/java/org/apache/iotdb/db/query/reader/sequence/UnsealedSeqReaderTest.java
create mode 100644 iotdb/src/test/java/org/apache/iotdb/db/query/reader/unsequence/UnseqSeriesReaderByTimestampTest.java
create mode 100644 iotdb/src/test/java/org/apache/iotdb/db/query/reader/unsequence/UnsequenceSeriesReaderTest.java
rename iotdb/src/test/java/org/apache/iotdb/db/sql/{DatetimeUtilsTest.java => DatetimeQueryDataSetUtilsTest.java} (99%)
rename iotdb/src/test/java/org/apache/iotdb/db/utils/{MathUtilsTest.java => MathQueryDataSetUtilsTest.java} (98%)
delete mode 100644 iotdb/src/test/java/org/apache/iotdb/db/utils/PrimitiveArrayListTest.java
create mode 100644 iotdb/src/test/java/org/apache/iotdb/db/utils/datastructure/LongTVListTest.java
delete mode 100644 iotdb/src/test/java/org/apache/iotdb/db/writelog/RecoverTest.java
create mode 100644 iotdb/src/test/java/org/apache/iotdb/db/writelog/io/MultiFileLogReaderTest.java
create mode 100644 iotdb/src/test/java/org/apache/iotdb/db/writelog/recover/LogReplayerTest.java
create mode 100644 iotdb/src/test/java/org/apache/iotdb/db/writelog/recover/SeqTsFileRecoverTest.java
create mode 100644 iotdb/src/test/java/org/apache/iotdb/db/writelog/recover/UnseqTsFileRecoverTest.java
create mode 100644 jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBPreparedInsertionStatement.java
rename jdbc/src/main/java/org/apache/iotdb/jdbc/{IoTDBPrepareStatement.java => IoTDBPreparedStatement.java} (96%)
rename jdbc/src/test/java/org/apache/iotdb/jdbc/{IoTDBPrepareStatementTest.java => IoTDBPreparedStatementTest.java} (88%)
rename tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/series/{SeriesReaderByTimestamp.java => FileSeriesReaderByTimestamp.java} (96%)
delete mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/write/writer/NativeRestorableIOWriter.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/write/writer/RestorableTsFileIOWriter.java
rename tsfile/src/test/java/org/apache/iotdb/tsfile/write/writer/{NativeRestorableIOWriterTest.java => RestorableTsFileIOWriterTest.java} (82%)