This is an automated email from the ASF dual-hosted git repository.
xuekaifeng pushed a change to branch xkf_fix_idtable_compaction
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from a75cf65 fix comment
add c3e49a8 [IOTDB-2735] Remove the redundant code in Tablet (#5211)
add b05a81f [IOTDB-2732] Reject inserting an invalid infinity float value
(#5210)
add 10b15ea [IOTDB-2734] Correct result type name in ResultMetadata
(#5213)
add 2a5d371 Update dependabot to check rel/0.13 (#5203)
add 83ab2f6 Fix .github/dependabot.yml (#5222)
add 272d5db Update UserGuide descriptions (#5219)
add 1460bb7 [IOTDB-2739] Update v0.13 upgrade user guide (#5234)
add 0d2cad6 Bump org.slf4j.version from 1.7.32 to 1.7.36 (#5225)
add 7ce67a1 [IOTDB-2742] Hide IDTable configurations (#5238)
add b3147de fix write with null value in tsFileWriter (#5237)
add 30cd1c0 Revert "fix write with null value in tsFileWriter (#5237)"
(#5246)
add a88b6b5 Modify cross priority param to upper case in doc (#5242)
add c3d34b6 [IOTDB-2590] Group by time query: support time sliding step
less than the time interval (#5196)
add c2a2acd [IOTDB-2736] DELETE_STORAGE_GROUP can not be granted to user
(reporting 401) (#5233)
add 9f04de9 [IOTDB-2723] Fix sequence inner space compaction lose data
add 2f78450 [IOTDB-2614]Fix inserting tablet with null value in
TsFileWriter (#5244)
add 919532a Bump jacoco-maven-plugin from 0.8.5 to 0.8.7 (#5194)
add 74189ee Bump maven-bundle-plugin from 5.1.1 to 5.1.4 (#5192)
add 6347db7 [IOTDB-2725] MPP query engine interface definition (#5250)
add 1ff6db9 [IOTDB-2524] Aligned Timeseries support tags and attributes
(#5191)
add 5a88650 [IOTDB-2685] Create and start config node (#5247)
add 5edf9e9 [IOTDB-2750] Enhance check statement before writing mlog
(#5253)
add 34b480d [IOTDB-2737] Fix ID Table compaction bug (#5214)
add 0426e72 [IOTDB-1593] Fix generated files in client-py have unapproved
license (#5258)
add 37dae90 add setNoMoreTsBlocks(), close() and abort() methods in
SinkHandle interface (#5256)
add d29ef70 [IOTDB-2749]Fix isPathExist check on MTree (#5260)
add 3c22c12 [IOTDB-2675][IOTDB-2524] Manage Metadata by Storage Group &&
Support alias, tag and attributes on aligned timeseries (#5205)
add 3deadae [IOTDB-2752] reconstructing the start and stop command (#5261)
new 0b997f1 Merge branch 'master' of https://github.com/apache/iotdb into
xkf_fix_idtable_compaction
new 829b4ab reopen idtable
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/dependabot.yml | 26 +
README.md | 4 +-
README_ZH.md | 4 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 8 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 11 +-
.../org/apache/iotdb/cluster/ClusterIoTDB.java | 51 +-
.../cluster/ClusterIoTDBServerCommandLine.java | 94 ++
.../cluster/client/async/AsyncDataClient.java | 2 +-
.../cluster/client/async/AsyncMetaClient.java | 2 +-
.../iotdb/cluster/client/sync/SyncDataClient.java | 2 +-
.../iotdb/cluster/client/sync/SyncMetaClient.java | 2 +-
.../iotdb/cluster/config/ClusterConstant.java | 2 +-
.../iotdb/cluster/coordinator/Coordinator.java | 2 +-
.../apache/iotdb/cluster/log/LogDispatcher.java | 2 +-
.../iotdb/cluster/log/applier/BaseApplier.java | 2 +-
.../iotdb/cluster/log/catchup/CatchUpTask.java | 2 +-
.../iotdb/cluster/log/catchup/LogCatchUpTask.java | 2 +-
.../cluster/log/manage/CommittedEntryManager.java | 2 +-
.../iotdb/cluster/log/manage/RaftLogManager.java | 2 +-
.../log/manage/UnCommittedEntryManager.java | 2 +-
.../serializable/SyncLogDequeSerializer.java | 2 +-
.../apache/iotdb/cluster/metadata/CMManager.java | 9 +-
.../iotdb/cluster/query/ClusterPlanExecutor.java | 2 +-
.../iotdb/cluster/query/ClusterPlanRouter.java | 2 +-
.../iotdb/cluster/query/LocalQueryExecutor.java | 4 +-
.../groupby/ClusterGroupByNoVFilterDataSet.java | 4 +-
.../groupby/ClusterGroupByVFilterDataSet.java | 2 +-
.../query/groupby/MergeGroupByExecutor.java | 2 +-
.../query/groupby/RemoteGroupByExecutor.java | 2 +-
.../cluster/query/manage/ClusterQueryManager.java | 2 +-
.../cluster/query/reader/ClusterReaderFactory.java | 2 +-
.../cluster/query/reader/ClusterTimeGenerator.java | 2 +-
.../iotdb/cluster/query/reader/EmptyReader.java | 2 +-
.../cluster/server/member/DataGroupMember.java | 2 +-
.../cluster/server/member/MetaGroupMember.java | 2 +-
.../iotdb/cluster/server/member/RaftMember.java | 2 +-
.../cluster/server/monitor/NodeStatusManager.java | 2 +-
.../cluster/server/service/DataGroupEngine.java | 2 +-
.../apache/iotdb/cluster/utils/PartitionUtils.java | 2 -
.../cluster/log/applier/MetaLogApplierTest.java | 10 -
.../query/groupby/RemoteGroupByExecutorTest.java | 2 +-
code-coverage/pom.xml | 2 +-
confignode/pom.xml | 17 +-
.../src/assembly/resources/conf/confignode-env.bat | 146 ++
.../src/assembly/resources/conf/confignode-env.sh | 264 ++++
.../resources/conf/iotdb-confignode.properties | 10 +-
.../src/assembly/resources/conf/jmx.access | 0
.../src/assembly/resources/conf/jmx.password | 0
.../assembly/resources/sbin/start-confignode.bat | 121 ++
.../assembly/resources/sbin/start-confignode.sh | 77 +
.../assembly/resources/sbin/stop-confignode.bat | 38 +
.../resources/sbin/stop-confignode.sh} | 32 +-
.../iotdb/confignode/conf/ConfigNodeConf.java | 5 +-
.../iotdb/confignode/conf/ConfigNodeConfCheck.java | 136 ++
.../iotdb/confignode/conf/ConfigNodeConstant.java | 28 +-
.../confignode/conf/ConfigNodeDescriptor.java | 66 +-
.../confignode/exception/ConfigNodeException.java | 11 +-
.../conf/RepeatConfigurationException.java} | 18 +-
.../startup/StartupException.java} | 17 +-
.../iotdb/confignode/manager/ConfigManager.java | 4 +-
.../iotdb/confignode/service/ConfigNode.java | 112 ++
.../confignode/service/ConfigNodeCommandLine.java | 80 +
.../iotdb/confignode/service/ConfigNodeMBean.java | 10 +-
.../register/IService.java} | 39 +-
.../confignode/service/register/JMXService.java | 105 ++
.../service/register}/RegisterManager.java | 33 +-
.../register/ServiceType.java} | 30 +-
.../confignode/service/startup/StartupCheck.java | 11 +-
.../confignode/service/startup/StartupChecks.java | 89 ++
.../{impl => server}/ConfigNodeRPCServer.java | 2 +-
.../confignode/conf/ConfigNodeDescriptorTest.java | 76 -
.../manager/hash/DeviceGroupHashExecutorTest.java | 3 +-
.../utils/ConfigNodeEnvironmentUtils.java | 133 ++
docs/Download/README.md | 16 +-
.../Administration-Management/Administration.md | 6 +-
.../Maintenance-Tools/Maintenance-Command.md | 8 -
docs/UserGuide/Operate-Metadata/Timeseries.md | 41 +-
docs/UserGuide/Query-Data/Aggregate-Query.md | 28 +-
docs/UserGuide/Query-Data/Overview.md | 2 +-
docs/UserGuide/Reference/Config-Manual.md | 7 +-
docs/UserGuide/Reference/SQL-Reference.md | 5 -
docs/zh/Download/README.md | 11 +-
.../Administration-Management/Administration.md | 8 +-
.../Maintenance-Tools/Maintenance-Command.md | 7 -
docs/zh/UserGuide/Operate-Metadata/Timeseries.md | 36 +-
docs/zh/UserGuide/Query-Data/Aggregate-Query.md | 37 +-
docs/zh/UserGuide/Query-Data/Overview.md | 2 +-
docs/zh/UserGuide/Reference/Config-Manual.md | 5 +-
docs/zh/UserGuide/Reference/SQL-Reference.md | 6 -
.../iotdb/AlignedTimeseriesSessionExample.java | 9 +-
.../main/java/org/apache/iotdb/SessionExample.java | 5 +-
.../apache/iotdb/db/integration/IOTDBInsertIT.java | 26 +
.../iotdb/db/integration/IoTDBAuthorizationIT.java | 49 +
.../db/integration/IoTDBCreateSnapshotIT.java | 180 ---
.../iotdb/db/integration/IoTDBMetadataFetchIT.java | 43 +-
.../db/integration/IoTDBResultMetadataIT.java | 82 +
.../IoTDBGroupByQueryWithoutValueFilterIT.java | 14 -
...roupBySlidingWindowQueryWithValueFilterIT.java} | 575 +++-----
...pBySlidingWindowQueryWithoutValueFilterIT.java} | 552 +++----
.../integration/{ => groupby}/IOTDBGroupByIT.java | 2 +-
.../{ => groupby}/IOTDBGroupByInnerIntervalIT.java | 2 +-
.../{ => groupby}/IoTDBGroupByFillIT.java | 2 +-
.../{ => groupby}/IoTDBGroupByFillMixPathsIT.java | 2 +-
.../{ => groupby}/IoTDBGroupByFillWithRangeIT.java | 2 +-
.../{ => groupby}/IoTDBGroupByMonthFillIT.java | 2 +-
.../{ => groupby}/IoTDBGroupByMonthIT.java | 95 +-
.../{ => groupby}/IoTDBGroupByUnseqIT.java | 2 +-
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 5 +-
iotdb-commons/pom.xml | 159 ++
.../apache/iotdb/commons/ServerCommandLine.java | 67 +
.../apache/iotdb/commons}/hash/APHashExecutor.java | 2 +-
.../iotdb/commons}/hash/BKDRHashExecutor.java | 2 +-
.../commons}/hash/DeviceGroupHashExecutor.java | 2 +-
.../apache/iotdb/commons}/hash/JSHashExecutor.java | 2 +-
.../iotdb/commons}/hash/SDBMHashExecutor.java | 2 +-
.../org/apache/iotdb/commons}/utils/TestOnly.java | 2 +-
.../org/apache/iotdb/jdbc/IoTDBResultMetadata.java | 29 +-
pom.xml | 14 +-
server/pom.xml | 9 +
.../resources/conf/iotdb-engine.properties | 36 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 2 +
.../apache/iotdb/db/auth/entity/PrivilegeType.java | 38 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 36 -
.../org/apache/iotdb/db/conf/IoTDBConfigCheck.java | 4 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 14 -
.../org/apache/iotdb/db/engine/StorageEngine.java | 2 +-
.../iotdb/db/engine/cache/BloomFilterCache.java | 2 +-
.../apache/iotdb/db/engine/cache/ChunkCache.java | 2 +-
.../db/engine/cache/TimeSeriesMetadataCache.java | 2 +-
.../engine/compaction/CompactionTaskManager.java | 2 +-
.../utils/SingleSeriesCompactionExecutor.java | 9 +-
.../iotdb/db/engine/cq/ContinuousQueryService.java | 2 +-
.../db/engine/storagegroup/StorageGroupInfo.java | 2 +-
.../db/engine/storagegroup/TsFileProcessor.java | 2 +-
.../db/engine/storagegroup/TsFileResource.java | 2 +-
.../db/engine/storagegroup/TsFileResourceList.java | 2 +-
.../storagegroup/VirtualStorageGroupProcessor.java | 2 +-
.../engine/trigger/executor/TriggerExecutor.java | 2 +-
.../service/TriggerRegistrationService.java | 2 +-
.../SchemaDirCreationFailureException.java | 12 +-
.../org/apache/iotdb/db/metadata/MManager.java | 1559 ++++++--------------
.../apache/iotdb/db/metadata/MetadataConstant.java | 3 +
.../idtable/AppendOnlyDiskSchemaManager.java | 2 +-
.../apache/iotdb/db/metadata/idtable/IDTable.java | 2 +-
.../db/metadata/idtable/IDTableHashmapImpl.java | 2 +-
.../db/metadata/idtable/IDiskSchemaManager.java | 2 +-
.../db/metadata/idtable/entry/DeviceEntry.java | 2 +-
.../db/metadata/idtable/entry/DeviceIDFactory.java | 2 +-
.../idtable/entry/InsertMeasurementMNode.java | 7 +-
.../db/metadata/idtable/entry/SchemaEntry.java | 2 +-
.../iotdb/db/metadata/logfile/MLogUpgrader.java | 290 ----
.../iotdb/db/metadata/mnode/EntityMNode.java | 13 +
.../org/apache/iotdb/db/metadata/mnode/IMNode.java | 7 +-
.../db/metadata/mnode/IStorageGroupMNode.java | 6 +
.../iotdb/db/metadata/mnode/InternalMNode.java | 38 +-
.../org/apache/iotdb/db/metadata/mnode/MNode.java | 14 +-
.../iotdb/db/metadata/mnode/MeasurementMNode.java | 3 +-
.../db/metadata/mnode/StorageGroupEntityMNode.java | 23 +
.../iotdb/db/metadata/mnode/StorageGroupMNode.java | 23 +
.../iotdb/db/metadata/mtree/MTreeAboveSG.java | 559 +++++++
.../mtree/{MTree.java => MTreeBelowSG.java} | 1105 +++-----------
.../db/metadata/mtree/traverser/Traverser.java | 86 +-
.../MNodeAboveSGCollector.java} | 48 +-
.../traverser/collector/MeasurementCollector.java | 20 +-
...lCounter.java => MNodeAboveSGLevelCounter.java} | 47 +-
.../mtree/traverser/counter/MNodeLevelCounter.java | 10 +-
.../counter/MeasurementGroupByLevelCounter.java | 26 +
.../apache/iotdb/db/metadata/path/AlignedPath.java | 2 +-
.../iotdb/db/metadata/path/MeasurementPath.java | 2 +-
.../apache/iotdb/db/metadata/path/PartialPath.java | 2 +-
.../db/metadata/rescon/TimeseriesStatistics.java | 104 ++
.../storagegroup/IStorageGroupSchemaManager.java | 232 +++
.../SGMManager.java} | 1255 ++++------------
.../storagegroup/StorageGroupSchemaManager.java | 252 ++++
.../apache/iotdb/db/metadata/tag/TagManager.java | 27 +-
.../template/TemplateLogReader.java} | 34 +-
.../db/metadata/template/TemplateLogWriter.java | 64 +
.../db/metadata/template/TemplateManager.java | 123 +-
.../db/metadata/upgrade/MetadataUpgrader.java | 425 ++++++
.../apache/iotdb/db/metadata/utils/MetaUtils.java | 2 +-
.../org/apache/iotdb/db/mpp/buffer/SinkHandle.java | 56 +
.../apache/iotdb/db/mpp/buffer/SourceHandle.java | 22 +-
.../common/Analysis.java} | 13 +-
.../common/FillPolicy.java} | 12 +-
.../common/GroupByTimeParameter.java} | 16 +-
.../common/OrderBy.java} | 16 +-
.../common/QueryContext.java} | 18 +-
.../common/QueryId.java} | 16 +-
.../common/QuerySession.java} | 12 +-
.../org/apache/iotdb/db/mpp/common/TreeNode.java | 25 +-
.../org/apache/iotdb/db/mpp/common/TsBlock.java | 48 +
.../iotdb/db/mpp/common/TsBlockMetadata.java | 41 +
.../common/WithoutPolicy.java} | 13 +-
.../execution/Coordinator.java} | 32 +-
.../db/mpp/execution/ExecFragmentInstance.java | 57 +
.../iotdb/db/mpp/execution/QueryExecution.java | 96 ++
.../iotdb/db/mpp/execution/QueryScheduler.java | 51 +
.../execution/QueryStateMachine.java} | 14 +-
.../org/apache/iotdb/db/mpp/operator/Operator.java | 49 +
.../operator/OperatorContext.java} | 31 +-
.../iotdb/db/mpp/operator/SeriesScanOperator.java | 21 +-
.../iotdb/db/mpp/plan/DistributedQueryPlan.java | 20 +-
.../iotdb/db/mpp/plan/DistributionPlanner.java | 21 +-
.../apache/iotdb/db/mpp/plan/FragmentInstance.java | 17 +-
.../plan/FragmentInstanceId.java} | 15 +-
.../apache/iotdb/db/mpp/plan/LogicalPlanner.java | 35 +-
.../apache/iotdb/db/mpp/plan/LogicalQueryPlan.java | 22 +-
.../org/apache/iotdb/db/mpp/plan/PlanFragment.java | 19 +-
.../plan/PlanFragmentId.java} | 14 +-
.../TestOnly.java => mpp/plan/node/PlanNode.java} | 26 +-
.../plan/node/PlanNodeId.java} | 21 +-
.../plan/node/PlanNodeIdAllocator.java} | 13 +-
.../db/mpp/plan/node/process/DeviceMergeNode.java | 66 +
.../iotdb/db/mpp/plan/node/process/FillNode.java | 30 +-
.../iotdb/db/mpp/plan/node/process/FilterNode.java | 30 +-
.../db/mpp/plan/node/process/FilterNullNode.java | 30 +-
.../db/mpp/plan/node/process/GroupByLevelNode.java | 41 +
.../iotdb/db/mpp/plan/node/process/LimitNode.java | 23 +-
.../iotdb/db/mpp/plan/node/process/OffsetNode.java | 26 +-
.../db/mpp/plan/node/process/ProcessNode.java | 17 +-
.../node/process/RowBasedSeriesAggregateNode.java | 59 +
.../iotdb/db/mpp/plan/node/process/SortNode.java | 32 +-
.../db/mpp/plan/node/process/TimeJoinNode.java | 67 +
.../iotdb/db/mpp/plan/node/sink/CsvSinkNode.java | 15 +-
.../db/mpp/plan/node/sink/FragmentSinkNode.java | 17 +-
.../iotdb/db/mpp/plan/node/sink/SinkNode.java | 16 +-
.../db/mpp/plan/node/sink/ThriftSinkNode.java | 17 +-
.../db/mpp/plan/node/source/CsvSourceNode.java | 17 +-
.../mpp/plan/node/source/SeriesAggregateNode.java | 81 +
.../db/mpp/plan/node/source/SeriesScanNode.java | 85 ++
.../iotdb/db/mpp/plan/node/source/SourceNode.java | 16 +-
.../plan/optimzation/PlanOptimizer.java} | 14 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 7 -
.../sys/CreateAlignedTimeSeriesOperator.java | 57 +-
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 6 +-
.../iotdb/db/qp/physical/crud/AggregationPlan.java | 2 +-
.../db/qp/physical/crud/GroupByTimeFillPlan.java | 7 +-
.../iotdb/db/qp/physical/crud/InsertRowPlan.java | 2 +-
.../physical/sys/CreateAlignedTimeSeriesPlan.java | 179 ++-
.../db/qp/physical/sys/CreateSnapshotPlan.java | 56 -
.../db/qp/physical/sys/CreateTemplatePlan.java | 2 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 28 +-
.../iotdb/db/qp/strategy/LogicalGenerator.java | 2 +-
.../apache/iotdb/db/qp/utils/DatetimeUtils.java | 24 +-
.../db/query/aggregation/AggregateResult.java | 53 +-
.../aggregation/RemovableAggregateResult.java} | 13 +-
.../db/query/aggregation/impl/AvgAggrResult.java | 22 +-
.../db/query/aggregation/impl/CountAggrResult.java | 14 +-
.../query/aggregation/impl/ExtremeAggrResult.java | 8 +-
.../aggregation/impl/FirstValueAggrResult.java | 3 -
.../aggregation/impl/LastValueAggrResult.java | 3 -
.../query/aggregation/impl/MaxTimeAggrResult.java | 5 +
.../query/aggregation/impl/MaxValueAggrResult.java | 4 +
.../query/aggregation/impl/MinTimeAggrResult.java | 5 +
.../query/aggregation/impl/MinValueAggrResult.java | 4 +
.../db/query/aggregation/impl/SumAggrResult.java | 20 +-
.../dataset/groupby/GroupByEngineDataSet.java | 239 ---
.../query/dataset/groupby/GroupByFillDataSet.java | 2 +-
.../query/dataset/groupby/GroupByLevelDataSet.java | 2 +-
.../query/dataset/groupby/GroupByTimeDataSet.java | 177 +++
.../dataset/groupby/GroupByTimeEngineDataSet.java | 91 ++
.../groupby/GroupByWithValueFilterDataSet.java | 87 +-
.../groupby/GroupByWithoutValueFilterDataSet.java | 104 +-
.../iotdb/db/query/executor/QueryRouter.java | 10 +-
.../apache/iotdb/db/query/executor/fill/IFill.java | 13 +-
.../groupby/AlignedGroupByExecutor.java | 2 +-
.../groupby/GroupByExecutor.java | 2 +-
.../groupby/SlidingWindowGroupByExecutor.java | 66 +
.../SlidingWindowGroupByExecutorFactory.java | 117 ++
.../EmptyQueueSlidingWindowGroupByExecutor.java | 51 +
.../groupby/impl}/LocalAlignedGroupByExecutor.java | 3 +-
.../groupby/impl}/LocalGroupByExecutor.java | 3 +-
...MonotonicQueueSlidingWindowGroupByExecutor.java | 73 +
.../NormalQueueSlidingWindowGroupByExecutor.java | 61 +
.../SmoothQueueSlidingWindowGroupByExecutor.java | 55 +
.../db/query/factory/AggregateResultFactory.java | 2 +
.../query/reader/series/AlignedSeriesReader.java | 2 +-
.../query/reader/series/SeriesAggregateReader.java | 2 +-
.../reader/series/SeriesRawDataBatchReader.java | 2 +-
.../iotdb/db/query/reader/series/SeriesReader.java | 2 +-
.../reader/series/SeriesReaderByTimestamp.java | 2 +-
.../query/udf/service/UDFRegistrationService.java | 2 +-
.../iotdb/db/rescon/TsFileResourceManager.java | 2 +-
.../apache/iotdb/db/service/RegisterManager.java | 2 +-
.../db/service/thrift/impl/TSServiceImpl.java | 4 +-
.../db/tools/virtualsg/DeviceMappingViewer.java | 1 -
.../java/org/apache/iotdb/db/utils/AuthUtils.java | 2 +
.../org/apache/iotdb/db/utils/CommonUtils.java | 13 +-
.../db/utils/datastructure/AlignedTVList.java | 2 +-
.../iotdb/db/utils/datastructure/TVList.java | 2 +-
.../iotdb/db/utils/datastructure/TimeSelector.java | 18 +
.../timerangeiterator/AggrWindowIterator.java | 149 ++
.../timerangeiterator/ITimeRangeIterator.java | 27 +-
.../timerangeiterator/PreAggrWindowIterator.java | 142 ++
.../PreAggrWindowWithNaturalMonthIterator.java | 109 ++
.../TimeRangeIteratorFactory.java | 69 +
.../utils/windowing/window/EvictableBatchList.java | 2 +-
.../org/apache/iotdb/db/writelog/io/LogWriter.java | 2 +-
.../InnerSpaceCompactionUtilsNoAlignedTest.java | 83 +-
.../iotdb/db/metadata/MManagerBasicTest.java | 124 +-
.../org/apache/iotdb/db/metadata/MTreeTest.java | 1060 -------------
.../iotdb/db/metadata/idtable/IDTableTest.java | 4 +
.../iotdb/db/metadata/mlog/MLogUpgraderTest.java | 176 ---
.../iotdb/db/metadata/mtree/MTreeAboveSGTest.java | 292 ++++
.../iotdb/db/metadata/mtree/MTreeBelowSGTest.java | 796 ++++++++++
.../db/metadata/upgrade/MetadataUpgradeTest.java | 304 ++++
.../db/qp/physical/PhysicalPlanSerializeTest.java | 2 +
...imeDataSetTest.java => GroupByDataSetTest.java} | 4 +-
.../dataset/groupby/GroupByEngineDataSetTest.java | 504 -------
.../dataset/groupby/GroupByTimeDataSetTest.java | 636 +++++---
.../org/apache/iotdb/db/tools/MLogParserTest.java | 88 +-
.../iotdb/db/utils/TimeRangeIteratorTest.java | 220 +++
.../db/utils/datastructure/TimeSelectorTest.java | 22 +
.../java/org/apache/iotdb/session/Session.java | 38 +-
.../session/IoTDBSessionDisableMemControlIT.java | 9 +-
.../session/IoTDBSessionVectorABDeviceIT.java | 2 +-
.../IoTDBSessionVectorAggregationWithUnSeqIT.java | 2 +-
.../iotdb/session/IoTDBSessionVectorInsertIT.java | 9 +-
thrift-confignode/pom.xml | 2 +-
thrift/src/main/thrift/rpc.thrift | 2 +
.../write/chunk/AlignedChunkGroupWriterImpl.java | 9 +-
.../chunk/NonAlignedChunkGroupWriterImpl.java | 6 +
.../iotdb/tsfile/write/chunk/ValueChunkWriter.java | 12 +-
.../apache/iotdb/tsfile/write/record/Tablet.java | 15 +-
.../iotdb/tsfile/write/TsFileWriteApiTest.java | 99 ++
325 files changed, 11271 insertions(+), 7840 deletions(-)
create mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/ClusterIoTDBServerCommandLine.java
create mode 100644 confignode/src/assembly/resources/conf/confignode-env.bat
create mode 100644 confignode/src/assembly/resources/conf/confignode-env.sh
copy {server => confignode}/src/assembly/resources/conf/jmx.access (100%)
copy {server => confignode}/src/assembly/resources/conf/jmx.password (100%)
create mode 100644 confignode/src/assembly/resources/sbin/start-confignode.bat
create mode 100644 confignode/src/assembly/resources/sbin/start-confignode.sh
create mode 100644 confignode/src/assembly/resources/sbin/stop-confignode.bat
rename confignode/src/{test/resources/iotdb-confignode.properties =>
assembly/resources/sbin/stop-confignode.sh} (50%)
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConfCheck.java
copy
server/src/main/java/org/apache/iotdb/db/metadata/mnode/IStorageGroupMNode.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/exception/ConfigNodeException.java
(78%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/{conf/ConfigNodeConstant.java
=> exception/conf/RepeatConfigurationException.java} (60%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/{conf/ConfigNodeConstant.java
=> exception/startup/StartupException.java} (64%)
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/service/ConfigNode.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/service/ConfigNodeCommandLine.java
copy
server/src/main/java/org/apache/iotdb/db/metadata/mnode/IStorageGroupMNode.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/service/ConfigNodeMBean.java
(78%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/{manager/hash/JSHashExecutor.java
=> service/register/IService.java} (51%)
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/service/register/JMXService.java
copy {server/src/main/java/org/apache/iotdb/db/service =>
confignode/src/main/java/org/apache/iotdb/confignode/service/register}/RegisterManager.java
(70%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/{manager/hash/BKDRHashExecutor.java
=> service/register/ServiceType.java} (57%)
copy
server/src/main/java/org/apache/iotdb/db/metadata/mnode/IStorageGroupMNode.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/service/startup/StartupCheck.java
(73%)
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/service/startup/StartupChecks.java
rename
confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/{impl =>
server}/ConfigNodeRPCServer.java (97%)
delete mode 100644
confignode/src/test/java/org/apache/iotdb/confignode/conf/ConfigNodeDescriptorTest.java
create mode 100644
confignode/src/test/java/org/apache/iotdb/confignode/utils/ConfigNodeEnvironmentUtils.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/IoTDBCreateSnapshotIT.java
create mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/IoTDBResultMetadataIT.java
copy
integration/src/test/java/org/apache/iotdb/db/integration/aligned/{IoTDBGroupByQueryWithoutValueFilterIT.java
=> IoTDBGroupBySlidingWindowQueryWithValueFilterIT.java} (61%)
copy
integration/src/test/java/org/apache/iotdb/db/integration/aligned/{IoTDBGroupByQueryWithoutValueFilterIT.java
=> IoTDBGroupBySlidingWindowQueryWithoutValueFilterIT.java} (63%)
rename integration/src/test/java/org/apache/iotdb/db/integration/{ =>
groupby}/IOTDBGroupByIT.java (99%)
rename integration/src/test/java/org/apache/iotdb/db/integration/{ =>
groupby}/IOTDBGroupByInnerIntervalIT.java (99%)
rename integration/src/test/java/org/apache/iotdb/db/integration/{ =>
groupby}/IoTDBGroupByFillIT.java (99%)
rename integration/src/test/java/org/apache/iotdb/db/integration/{ =>
groupby}/IoTDBGroupByFillMixPathsIT.java (99%)
rename integration/src/test/java/org/apache/iotdb/db/integration/{ =>
groupby}/IoTDBGroupByFillWithRangeIT.java (99%)
rename integration/src/test/java/org/apache/iotdb/db/integration/{ =>
groupby}/IoTDBGroupByMonthFillIT.java (99%)
rename integration/src/test/java/org/apache/iotdb/db/integration/{ =>
groupby}/IoTDBGroupByMonthIT.java (75%)
rename integration/src/test/java/org/apache/iotdb/db/integration/{ =>
groupby}/IoTDBGroupByUnseqIT.java (99%)
create mode 100644 iotdb-commons/pom.xml
create mode 100644
iotdb-commons/src/main/java/org/apache/iotdb/commons/ServerCommandLine.java
copy {confignode/src/main/java/org/apache/iotdb/confignode/manager =>
iotdb-commons/src/main/java/org/apache/iotdb/commons}/hash/APHashExecutor.java
(96%)
copy {confignode/src/main/java/org/apache/iotdb/confignode/manager =>
iotdb-commons/src/main/java/org/apache/iotdb/commons}/hash/BKDRHashExecutor.java
(96%)
rename {confignode/src/main/java/org/apache/iotdb/confignode/manager =>
iotdb-commons/src/main/java/org/apache/iotdb/commons}/hash/DeviceGroupHashExecutor.java
(95%)
copy {confignode/src/main/java/org/apache/iotdb/confignode/manager =>
iotdb-commons/src/main/java/org/apache/iotdb/commons}/hash/JSHashExecutor.java
(96%)
rename {confignode/src/main/java/org/apache/iotdb/confignode/manager =>
iotdb-commons/src/main/java/org/apache/iotdb/commons}/hash/SDBMHashExecutor.java
(96%)
copy {server/src/main/java/org/apache/iotdb/db =>
iotdb-commons/src/main/java/org/apache/iotdb/commons}/utils/TestOnly.java (96%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConstant.java
=>
server/src/main/java/org/apache/iotdb/db/exception/metadata/SchemaDirCreationFailureException.java
(75%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/logfile/MLogUpgrader.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mtree/MTreeAboveSG.java
rename server/src/main/java/org/apache/iotdb/db/metadata/mtree/{MTree.java =>
MTreeBelowSG.java} (53%)
copy
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/{counter/MNodeLevelCounter.java
=> collector/MNodeAboveSGCollector.java} (54%)
copy
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/counter/{MNodeLevelCounter.java
=> MNodeAboveSGLevelCounter.java} (57%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/rescon/TimeseriesStatistics.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/storagegroup/IStorageGroupSchemaManager.java
copy server/src/main/java/org/apache/iotdb/db/metadata/{MManager.java =>
storagegroup/SGMManager.java} (59%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/storagegroup/StorageGroupSchemaManager.java
rename
server/src/main/java/org/apache/iotdb/db/{qp/logical/sys/CreateSnapshotOperator.java
=> metadata/template/TemplateLogReader.java} (55%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/template/TemplateLogWriter.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/upgrade/MetadataUpgrader.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/buffer/SinkHandle.java
copy
confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConstant.java
=> server/src/main/java/org/apache/iotdb/db/mpp/buffer/SourceHandle.java (67%)
copy
server/src/main/java/org/apache/iotdb/db/{metadata/mnode/IStorageGroupMNode.java
=> mpp/common/Analysis.java} (73%)
copy
server/src/main/java/org/apache/iotdb/db/{metadata/mnode/IStorageGroupMNode.java
=> mpp/common/FillPolicy.java} (73%)
copy
server/src/main/java/org/apache/iotdb/db/{metadata/mnode/IStorageGroupMNode.java
=> mpp/common/GroupByTimeParameter.java} (66%)
copy
server/src/main/java/org/apache/iotdb/db/{metadata/mnode/IStorageGroupMNode.java
=> mpp/common/OrderBy.java} (73%)
copy
server/src/main/java/org/apache/iotdb/db/{metadata/mnode/IStorageGroupMNode.java
=> mpp/common/QueryContext.java} (69%)
copy
server/src/main/java/org/apache/iotdb/db/{metadata/mnode/IStorageGroupMNode.java
=> mpp/common/QueryId.java} (73%)
copy
server/src/main/java/org/apache/iotdb/db/{metadata/mnode/IStorageGroupMNode.java
=> mpp/common/QuerySession.java} (73%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConstant.java
=> server/src/main/java/org/apache/iotdb/db/mpp/common/TreeNode.java (60%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/common/TsBlock.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/common/TsBlockMetadata.java
copy
server/src/main/java/org/apache/iotdb/db/{metadata/mnode/IStorageGroupMNode.java
=> mpp/common/WithoutPolicy.java} (73%)
copy
server/src/main/java/org/apache/iotdb/db/{query/dataset/groupby/AlignedGroupByExecutor.java
=> mpp/execution/Coordinator.java} (57%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/ExecFragmentInstance.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/QueryExecution.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/QueryScheduler.java
copy
server/src/main/java/org/apache/iotdb/db/{metadata/mnode/IStorageGroupMNode.java
=> mpp/execution/QueryStateMachine.java} (76%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/operator/Operator.java
copy server/src/main/java/org/apache/iotdb/db/{utils/TestOnly.java =>
mpp/operator/OperatorContext.java} (57%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConstant.java
=>
server/src/main/java/org/apache/iotdb/db/mpp/operator/SeriesScanOperator.java
(70%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConstant.java
=> server/src/main/java/org/apache/iotdb/db/mpp/plan/DistributedQueryPlan.java
(59%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConstant.java
=> server/src/main/java/org/apache/iotdb/db/mpp/plan/DistributionPlanner.java
(62%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConstant.java
=> server/src/main/java/org/apache/iotdb/db/mpp/plan/FragmentInstance.java
(65%)
copy
server/src/main/java/org/apache/iotdb/db/{metadata/mnode/IStorageGroupMNode.java
=> mpp/plan/FragmentInstanceId.java} (70%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/manager/hash/APHashExecutor.java
=> server/src/main/java/org/apache/iotdb/db/mpp/plan/LogicalPlanner.java (54%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConstant.java
=> server/src/main/java/org/apache/iotdb/db/mpp/plan/LogicalQueryPlan.java
(62%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConstant.java
=> server/src/main/java/org/apache/iotdb/db/mpp/plan/PlanFragment.java (64%)
copy
server/src/main/java/org/apache/iotdb/db/{metadata/mnode/IStorageGroupMNode.java
=> mpp/plan/PlanFragmentId.java} (73%)
rename server/src/main/java/org/apache/iotdb/db/{utils/TestOnly.java =>
mpp/plan/node/PlanNode.java} (58%)
copy
server/src/main/java/org/apache/iotdb/db/{metadata/mnode/IStorageGroupMNode.java
=> mpp/plan/node/PlanNodeId.java} (71%)
copy
server/src/main/java/org/apache/iotdb/db/{metadata/mnode/IStorageGroupMNode.java
=> mpp/plan/node/PlanNodeIdAllocator.java} (73%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/node/process/DeviceMergeNode.java
copy
confignode/src/main/java/org/apache/iotdb/confignode/manager/hash/JSHashExecutor.java
=>
server/src/main/java/org/apache/iotdb/db/mpp/plan/node/process/FillNode.java
(58%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/manager/hash/BKDRHashExecutor.java
=>
server/src/main/java/org/apache/iotdb/db/mpp/plan/node/process/FilterNode.java
(58%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/manager/hash/JSHashExecutor.java
=>
server/src/main/java/org/apache/iotdb/db/mpp/plan/node/process/FilterNullNode.java
(55%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/node/process/GroupByLevelNode.java
copy
confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConstant.java
=>
server/src/main/java/org/apache/iotdb/db/mpp/plan/node/process/LimitNode.java
(61%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConstant.java
=>
server/src/main/java/org/apache/iotdb/db/mpp/plan/node/process/OffsetNode.java
(60%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConstant.java
=>
server/src/main/java/org/apache/iotdb/db/mpp/plan/node/process/ProcessNode.java
(68%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/node/process/RowBasedSeriesAggregateNode.java
copy
confignode/src/main/java/org/apache/iotdb/confignode/manager/hash/JSHashExecutor.java
=>
server/src/main/java/org/apache/iotdb/db/mpp/plan/node/process/SortNode.java
(56%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/node/process/TimeJoinNode.java
copy
confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConstant.java
=>
server/src/main/java/org/apache/iotdb/db/mpp/plan/node/sink/CsvSinkNode.java
(74%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConstant.java
=>
server/src/main/java/org/apache/iotdb/db/mpp/plan/node/sink/FragmentSinkNode.java
(68%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConstant.java
=> server/src/main/java/org/apache/iotdb/db/mpp/plan/node/sink/SinkNode.java
(69%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConstant.java
=>
server/src/main/java/org/apache/iotdb/db/mpp/plan/node/sink/ThriftSinkNode.java
(70%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConstant.java
=>
server/src/main/java/org/apache/iotdb/db/mpp/plan/node/source/CsvSourceNode.java
(69%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/node/source/SeriesAggregateNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/node/source/SeriesScanNode.java
copy
confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConstant.java
=>
server/src/main/java/org/apache/iotdb/db/mpp/plan/node/source/SourceNode.java
(67%)
copy
server/src/main/java/org/apache/iotdb/db/{metadata/mnode/IStorageGroupMNode.java
=> mpp/plan/optimzation/PlanOptimizer.java} (67%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/qp/physical/sys/CreateSnapshotPlan.java
copy
server/src/main/java/org/apache/iotdb/db/{metadata/mnode/IStorageGroupMNode.java
=> query/aggregation/RemovableAggregateResult.java} (73%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/GroupByEngineDataSet.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/GroupByTimeDataSet.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/GroupByTimeEngineDataSet.java
rename server/src/main/java/org/apache/iotdb/db/query/{dataset =>
executor}/groupby/AlignedGroupByExecutor.java (96%)
rename server/src/main/java/org/apache/iotdb/db/query/{dataset =>
executor}/groupby/GroupByExecutor.java (96%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/executor/groupby/SlidingWindowGroupByExecutor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/executor/groupby/SlidingWindowGroupByExecutorFactory.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/executor/groupby/impl/EmptyQueueSlidingWindowGroupByExecutor.java
rename server/src/main/java/org/apache/iotdb/db/query/{dataset/groupby =>
executor/groupby/impl}/LocalAlignedGroupByExecutor.java (98%)
rename server/src/main/java/org/apache/iotdb/db/query/{dataset/groupby =>
executor/groupby/impl}/LocalGroupByExecutor.java (98%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/executor/groupby/impl/MonotonicQueueSlidingWindowGroupByExecutor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/executor/groupby/impl/NormalQueueSlidingWindowGroupByExecutor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/executor/groupby/impl/SmoothQueueSlidingWindowGroupByExecutor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/utils/timerangeiterator/AggrWindowIterator.java
rename
confignode/src/main/java/org/apache/iotdb/confignode/manager/hash/JSHashExecutor.java
=>
server/src/main/java/org/apache/iotdb/db/utils/timerangeiterator/ITimeRangeIterator.java
(60%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/utils/timerangeiterator/PreAggrWindowIterator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/utils/timerangeiterator/PreAggrWindowWithNaturalMonthIterator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/utils/timerangeiterator/TimeRangeIteratorFactory.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/metadata/MTreeTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/metadata/mlog/MLogUpgraderTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/metadata/mtree/MTreeAboveSGTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/metadata/mtree/MTreeBelowSGTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/metadata/upgrade/MetadataUpgradeTest.java
copy
server/src/test/java/org/apache/iotdb/db/query/dataset/groupby/{GroupByTimeDataSetTest.java
=> GroupByDataSetTest.java} (98%)
delete mode 100644
server/src/test/java/org/apache/iotdb/db/query/dataset/groupby/GroupByEngineDataSetTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/utils/TimeRangeIteratorTest.java
