This is an automated email from the ASF dual-hosted git repository.
hui pushed a change to branch lmh/addQueryIT
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 2634594e49 Merge remote-tracking branch 'origin/master' into
lmh/addQueryIT
add b57604cbe6 [IOTDB-3545] Add permission and SQL relation table in doc
(#6369)
add fbb74cd83e Add comment on getLeader (#6371)
add f65514eea5 [IOTDB-3584] Snapshot unstable due to segment size (#6370)
add ff5a14a86d [IOTDB-3577] Add semantic checks for linear fill (#6372)
add 4a01899bc1 [IOTDB-3573] Fix IT test stucked by JDBC infinite network
timeout (#6361)
add 32096c9f04 [IoTDB-3052] ConfigNode shrinking process (#6329)
add 44f1d1813b [IOTDB-3589] Fix dataRegion cannot recover from snapshot
(#6376)
add 5aa0fe612e [IOTDB-3436] Add aggregation IT without value filter (#6338)
add cbc5e42d68 [IOTDB-3571] Add IT for UDTF Non Align (#6356)
add a59c4c806d [IOTDB-3349] Operator should not call child.next() twice in
one itself next call (#6203)
add 2e9cfd4bde [IOTDB-3547] AddConfigNode support procedure (#6350)
add 70f6d6fe37 [IOTDB-3467] Add IT for Nested Expressions (#6385)
add ff996f9098 [IOTDB-3484] Modify user docs about how to use udf api
(#6387)
add 074b37f5fe [IOTDB-3558] Dump node stacks if IT test request timeout
(#6382)
add 346ed83119 delete tsfiles when recovering data region (#6388)
add a3352882f1 delete file before recovery in ratis mode (#6390)
add f24722a9a6 [IOTDB-3386] Avoid the double-write problem of raftlog and
write-ahead log at the Datanode consensus layer (#6366)
add 3b1b4303be Fix DataTypeMismatchException npe (#6392)
add 0cc7887341 Fix Source Handle Bug (#6386)
add 9540c88be1 [IOTDB-3601] Fix error when query data from empty series on
new standalone iotdb (#6383)
add cb77e2ce22 Ratis Raftlog SegmentSize -> 24Mb (#6398)
add cb283d658a [IOTDB-3604] Refactor the time zone setter by using the
setClientInfo method of JDBC (#6384)
add a2436515e0 [IOTDB-3428] Linear expanse RegionGroup(simple version)
(#6325)
add cd30fd09e2 Merge remote-tracking branch 'origin/master' into
lmh/addQueryIT
add a5cc5680e9 move IoTDBGroupByQueryWithValueFilterIT
add 1a5fcb09e6 create TestUtils
add a6b359f656 move ITs & refactor IOTDBGroupByIT
add dda5579719 refactor IoTDBGroupByUnseqIT & IoTDBGroupByNaturalMonthIT
add f632ac0f90 move IoTDBGroupBySlidingWindowQueryWithoutValueFilterIT
add 8e780a80f6 move IoTDBGroupBySlidingWindowQueryWithoutValueFilterIT
add 19fff1d5d7 [IOTDB-3632] Add log for snapshot taker and loader (#6401)
add b7ea931296 Delete Useless Class (#6400)
add 874cc7a392 [IOTDB-3598] Fix isBlocked check in
SchemaQueryMergeOperator (#6399)
add 50552c6c0f [IOTDB-3598] Fix queue has been destroyed bug (#6395)
add f6068ab1a3 [IOTDB-3436] add aggregation with value filter IT (#6389)
add e1840dc35b [IOTDB-3585] Bugfix: Async compute md5 for snapshot (#6407)
add dbe28c7f96 [IOTDB-3534] Small tsfile flushed by wal effective
information ratio mechanism (#6342)
add 99eae05fb2 [IOTDB-3623] Add IT for UDF query (#6396)
add f0934081f6 [IOTDB-3590] Accelerate aggregation query in MPP (#6375)
add 29a8ce60a4 Merge remote-tracking branch 'origin/master' into
lmh/addQueryIT
add 578e08ca8a Add session and operation closing method in client RPC
service (#6406)
add d5d1236ad1 [IOTDB-3263] Support filtering null in expressions for mpp
cluster. (#6397)
add 9cfc0f0d4e Make test timeout as a RuntimeException (#6414)
add c2944e391b [IOTDB-3622] Use hardlink to decrease the copied file size
in cluster test (#6391)
add be315c0b62 [IOTDB-3599] Delete storage group should delete wal node
when using multi-leader consensus (#6409)
add d7d49024ca Fix IoTDBCreateTimeseriesIT (#6408)
add ce90958ac1 Make InconsistentDataException as a RuntimeException (#6419)
add 1b737743ac fix BadNodeUrlException when loadConfigNodeList (#6411)
add 3da63cb04e fix NPE (#6404)
add b13ef6d291 [IOTDB-3405] Document for IT developer (#6333)
add 484a52f2d9 [IOTDB-3159] Granting the user privileges to create_user
does not require adding a path (#6368)
add a3c8932c3d [IOTDB-3645] Fix use statistics bug in aggregation query
(#6420)
add 956ca739e1 [IOTDB-3635][IOTDB-3583] Increase the stability of the
getLeader interface (#6412)
add 6473930f7d Merge remote-tracking branch 'origin/master' into
lmh/addQueryIT
add 94366d11ee remove memory control of MTreeAboveSG (#6418)
add 06abd0c749 replace bytebuffer with IOStream (#6423)
add 4096fdf844 Fix insert failed (#6426)
add ba87116bb1 Move the IoTDBTimeZoneIT to integration-test (#6427)
add 1128140561 [IOTDB-3546] Add status code in wal filename to delete data
without search index (#6416)
add 8dc398a011 [IOTDB-3539] Adjust the capacity of SchemaCache according
to schema memory (#6403)
add 0bb50c3009 [IOTDB-3644] Fix the incorrect result bug when querying
with value filter & order by time desc (#6422)
add de39e834ff Merge remote-tracking branch 'origin/master' into
lmh/addQueryIT
add e1eb3a8f6e fix checkstyle
add e4393e4080 add group by month order by time desc bug
add f20cf4157d Fix IT
No new revisions were added by this update.
Summary of changes:
.github/workflows/cluster-it.yml | 6 +-
.github/workflows/standalone-it-for-mpp.yml | 8 +-
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 2 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 5 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 3 +-
.../assembly/resources/sbin/remove-confignode.sh | 79 +
.../confignode/client/AsyncDataNodeClientPool.java | 10 +-
.../client/SyncConfigNodeClientPool.java | 80 +-
.../confignode/conf/ConfigNodeRemoveCheck.java | 102 +
.../confignode/conf/ConfigNodeStartupCheck.java | 31 +-
.../consensus/request/ConfigRequest.java | 10 +-
.../consensus/request/ConfigRequestType.java | 4 +-
.../write/AdjustMaxRegionGroupCountReq.java | 89 +
.../consensus/request/write/CreateRegionsReq.java | 28 +-
.../request/write/RemoveConfigNodeReq.java | 77 +
.../confignode/manager/ClusterSchemaManager.java | 147 +-
.../iotdb/confignode/manager/ConfigManager.java | 53 +-
.../iotdb/confignode/manager/ConsensusManager.java | 134 +-
.../apache/iotdb/confignode/manager/Manager.java | 14 +-
.../iotdb/confignode/manager/NodeManager.java | 89 +-
.../iotdb/confignode/manager/PartitionManager.java | 222 +-
.../iotdb/confignode/manager/ProcedureManager.java | 15 +-
.../iotdb/confignode/manager/load/LoadManager.java | 28 +-
.../manager/load/balancer/RegionBalancer.java | 19 +-
.../confignode/persistence/ClusterSchemaInfo.java | 171 +-
.../iotdb/confignode/persistence/NodeInfo.java | 29 +
.../executor/ConfigRequestExecutor.java | 10 +-
.../persistence/partition/PartitionInfo.java | 39 +-
.../persistence/partition/RegionGroup.java | 11 +-
.../partition/StorageGroupPartitionTable.java | 42 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 43 +-
.../procedure/impl/AddConfigNodeProcedure.java | 188 +
.../impl/DeleteStorageGroupProcedure.java | 3 +-
.../procedure/state/AddConfigNodeState.java | 12 +-
.../procedure/store/ProcedureFactory.java | 9 +-
.../iotdb/confignode/service/ConfigNode.java | 49 +-
.../confignode/service/ConfigNodeCommandLine.java | 8 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 72 +-
.../consensus/request/ConfigRequestSerDeTest.java | 30 +-
.../confignode/persistence/PartitionInfoTest.java | 20 +-
.../apache/iotdb/consensus/config/RatisConfig.java | 4 +-
.../ratis/FileInfoWithDelayedMd5Computing.java | 75 +
.../iotdb/consensus/ratis/RatisConsensus.java | 11 +-
.../iotdb/consensus/ratis/SnapshotStorage.java | 10 +-
docs/Download/README.md | 1 +
.../Administration-Management/Administration.md | 298 +-
.../Integration-Test-refactoring-tutorial.md | 346 +-
.../Process-Data/UDF-User-Defined-Function.md | 58 +-
docs/UserGuide/Query-Data/Query-Filter.md | 15 +
docs/zh/Download/README.md | 1 +
.../Administration-Management/Administration.md | 297 +-
.../Integration-Test-refactoring-tutorial.md | 352 +-
.../Process-Data/UDF-User-Defined-Function.md | 61 +-
docs/zh/UserGuide/Query-Data/Query-Filter.md | 14 +
integration-test/import-control.xml | 3 +-
integration-test/pom.xml | 480 +-
.../assembly/mpp-share.xml} | 34 +-
integration-test/src/assembly/mpp-test.xml | 7 +-
.../java/org/apache/iotdb/it/env/AbstractEnv.java | 182 +-
.../apache/iotdb/it/env/AbstractNodeWrapper.java | 299 +-
.../org/apache/iotdb/it/env/ConfigNodeWrapper.java | 54 +-
.../org/apache/iotdb/it/env/DataNodeWrapper.java | 35 +-
.../org/apache/iotdb/it/env/IoTDBTestRunner.java | 7 +-
.../java/org/apache/iotdb/it/env/MppConfig.java | 7 +
.../org/apache/iotdb/it/env/RemoteServerEnv.java | 7 +-
.../iotdb/it/env/StandaloneDataNodeWrapper.java | 5 +-
.../apache/iotdb/it/env/StandaloneOnMppEnv.java | 34 +-
.../apache/iotdb/itbase/constant/TestConstant.java | 1 +
.../org/apache/iotdb/itbase/env/BaseConfig.java | 12 +
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 4 +-
.../apache/iotdb/itbase/env/BaseNodeWrapper.java | 4 +
.../InconsistentDataException.java | 7 +-
.../exception/ParallelRequestTimeoutException.java | 13 +-
.../itbase/runtime/ClusterTestConnection.java | 8 +-
.../iotdb/itbase/runtime/ClusterTestStatement.java | 2 +-
.../itbase/runtime/ParallelRequestDelegate.java | 8 +-
.../iotdb/itbase/runtime/RequestDelegate.java | 7 +-
integration-test/src/script/append-to-env.sh | 32 -
.../iotdb/db/it/IoTDBCreateTimeseriesIT.java | 257 +
.../org/apache/iotdb/db/it/IoTDBFilterNullIT.java | 131 +
.../org/apache/iotdb/db/it/IoTDBNestedQueryIT.java | 620 ++
.../org/apache/iotdb/db/it}/IoTDBTimeZoneIT.java | 32 +-
.../it}/aggregation/IoTDBAggregationByLevelIT.java | 323 +-
.../it}/aggregation/IoTDBAggregationDeleteIT.java | 23 +-
.../db/it}/aggregation/IoTDBAggregationIT.java | 494 +-
.../aggregation/IoTDBAggregationLargeDataIT.java | 431 +-
.../aggregation/IoTDBAggregationSmallDataIT.java | 241 +-
...T.java => IoTDBAggregationWithDeletion2IT.java} | 3 +-
...IT.java => IoTDBAggregationWithDeletionIT.java} | 117 +-
.../db/it/aligned/IoTDBAlignedSeriesQueryIT.java | 6573 ++++++++++++++------
.../org/apache/iotdb/db/it/env/StandaloneEnv.java | 6 +-
.../iotdb/db/it/env/StandaloneEnvConfig.java | 17 +
.../apache/iotdb/db/it/groupby/IOTDBGroupByIT.java | 531 ++
.../db/it/groupby/IoTDBGroupByFillMixPathsIT.java | 459 ++
.../it/groupby/IoTDBGroupByNaturalMonthFillIT.java | 237 +
.../db/it/groupby/IoTDBGroupByNaturalMonthIT.java | 238 +
.../iotdb/db/it}/groupby/IoTDBGroupByUnseqIT.java | 109 +-
.../db/it/groupby/IoTDBGroupByWithFillIT.java | 2607 ++++++++
.../org/apache/iotdb/db/it/query/IoTDBAliasIT.java | 38 +-
.../iotdb/db/it/query/IoTDBPaginationIT.java | 35 +-
.../apache/iotdb/db/it/query/IoTDBResultSetIT.java | 2 +-
.../org/apache/iotdb/db/it/query/TestUtils.java | 93 -
.../iotdb/db/it/udf/IoTDBUDFManagementIT.java | 3 -
.../iotdb/db/it/udf/IoTDBUDFWindowQueryIT.java | 816 +++
.../db/it/udf/IoTDBUDTFAlignByTimeQueryIT.java | 842 +++
.../db/it/udf/IoTDBUDTFBuiltinFunctionIT.java | 5 +-
.../iotdb/db/it/udf/IoTDBUDTFNonAlignQueryIT.java | 350 ++
.../org/apache/iotdb/db/it/utils/TestUtils.java | 210 +
.../iotdb/db/integration/IoTDBAuthorizationIT.java | 10 +-
.../db/integration/IoTDBCreateTimeseriesIT.java | 314 -
.../db/integration/IoTDBUDTFBuiltinFunctionIT.java | 1038 ----
.../IoTDBAggregationWithValueFilter2IT.java | 65 -
.../aligned/IoTDBAggregationWithValueFilterIT.java | 264 -
...BAggregationWithValueFilterWithDeletion2IT.java | 85 -
...DBAggregationWithValueFilterWithDeletionIT.java | 221 -
.../IoTDBGroupByQueryWithValueFilter2IT.java | 65 -
.../IoTDBGroupByQueryWithValueFilterIT.java | 1094 ----
...GroupBySlidingWindowQueryWithValueFilterIT.java | 951 ---
...upBySlidingWindowQueryWithoutValueFilterIT.java | 947 ---
.../db/integration/groupby/IOTDBGroupByIT.java | 996 ---
.../groupby/IOTDBGroupByInnerIntervalIT.java | 342 -
.../db/integration/groupby/IoTDBGroupByFillIT.java | 3 +-
.../groupby/IoTDBGroupByFillMixPathsIT.java | 3 +-
.../integration/groupby/IoTDBGroupByMonthIT.java | 366 --
...IT.java => IoTDBGroupByNaturalMonthFillIT.java} | 7 +-
.../main/java/org/apache/iotdb/jdbc/Config.java | 6 +
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 34 +-
.../apache/iotdb/jdbc/IoTDBConnectionParams.java | 25 +
.../src/main/java/org/apache/iotdb/jdbc/Utils.java | 18 +
.../org/apache/iotdb/jdbc/IoTDBConnectionTest.java | 12 +
.../apache/iotdb/commons/conf/IoTDBConstant.java | 1 +
.../org/apache/iotdb/commons/path/PartialPath.java | 32 +
.../commons/udf/service/UDFClassLoaderManager.java | 4 +-
.../schemaregion/rocksdb/RSchemaConfLoader.java | 4 +-
.../resources/conf/iotdb-engine.properties | 10 +-
.../src/assembly/resources/sbin/stop-datanode.sh | 2 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 36 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 58 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 56 +-
.../db/conf/directories/DirectoryManager.java | 6 +
.../db/consensus/DataRegionConsensusImpl.java | 9 +
.../apache/iotdb/db/engine/StorageEngineV2.java | 50 +-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 8 +-
.../apache/iotdb/db/engine/memtable/IMemTable.java | 2 +-
.../iotdb/db/engine/snapshot/SnapshotLoader.java | 144 +-
.../iotdb/db/engine/snapshot/SnapshotTaker.java | 53 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 71 +-
.../metadata/DataTypeMismatchException.java | 8 +-
.../iotdb/db/localconfignode/LocalConfigNode.java | 33 +-
.../db/metadata/cache/DataNodeSchemaCache.java | 8 +-
.../iotdb/db/metadata/cache/SchemaCacheEntry.java | 23 +
.../iotdb/db/metadata/mtree/MTreeAboveSG.java | 12 +-
.../mtree/snapshot/MemMTreeSnapshotUtil.java | 12 +
.../iotdb/db/metadata/rescon/MemoryStatistics.java | 2 +-
.../schemaregion/SchemaRegionMemoryImpl.java | 31 +-
.../iotdb/db/mpp/aggregation/Accumulator.java | 8 +-
.../iotdb/db/mpp/aggregation/Aggregator.java | 9 +-
.../iotdb/db/mpp/aggregation/AvgAccumulator.java | 62 +-
.../iotdb/db/mpp/aggregation/CountAccumulator.java | 27 +-
.../db/mpp/aggregation/ExtremeAccumulator.java | 62 +-
.../db/mpp/aggregation/FirstValueAccumulator.java | 110 +-
.../mpp/aggregation/FirstValueDescAccumulator.java | 48 +-
.../db/mpp/aggregation/LastValueAccumulator.java | 98 +-
.../mpp/aggregation/LastValueDescAccumulator.java | 60 +-
.../db/mpp/aggregation/MaxTimeAccumulator.java | 13 +-
.../db/mpp/aggregation/MaxTimeDescAccumulator.java | 15 +-
.../db/mpp/aggregation/MaxValueAccumulator.java | 62 +-
.../db/mpp/aggregation/MinTimeAccumulator.java | 15 +-
.../db/mpp/aggregation/MinTimeDescAccumulator.java | 13 +-
.../db/mpp/aggregation/MinValueAccumulator.java | 62 +-
.../iotdb/db/mpp/aggregation/SumAccumulator.java | 62 +-
.../slidingwindow/SlidingWindowAggregator.java | 3 +-
.../iotdb/db/mpp/common/schematree/SchemaTree.java | 22 +-
.../common/schematree/node/SchemaEntityNode.java | 22 +-
.../common/schematree/node/SchemaInternalNode.java | 22 +-
.../schematree/node/SchemaMeasurementNode.java | 22 +-
.../db/mpp/common/schematree/node/SchemaNode.java | 5 +-
.../execution/datatransfer/LocalSourceHandle.java | 7 +
.../mpp/execution/datatransfer/SourceHandle.java | 6 +-
.../operator/process/DeviceMergeOperator.java | 3 +
.../operator/process/DeviceViewOperator.java | 3 +
.../operator/process/FilterNullOperator.java | 57 -
.../execution/operator/process/FilterOperator.java | 127 +-
.../process/RawDataAggregationOperator.java | 50 +-
.../process/SlidingWindowAggregationOperator.java | 19 +-
.../operator/process/TransformOperator.java | 133 +-
.../operator/schema/SchemaFetchMergeOperator.java | 52 +-
.../operator/schema/SchemaFetchScanOperator.java | 21 +-
.../operator/schema/SchemaQueryMergeOperator.java | 43 +-
.../operator/sink/FragmentSinkOperator.java | 66 -
.../AlignedSeriesAggregationScanOperator.java | 137 +-
.../source/SeriesAggregationScanOperator.java | 120 +-
.../org/apache/iotdb/db/mpp/plan/Coordinator.java | 2 +-
.../apache/iotdb/db/mpp/plan/analyze/Analyzer.java | 61 +-
.../mpp/plan/analyze/ClusterPartitionFetcher.java | 14 +-
.../db/mpp/plan/analyze/ClusterSchemaFetcher.java | 11 +-
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 4 +
.../iotdb/db/mpp/plan/analyze/ExpressionUtils.java | 5 +
.../mpp/plan/analyze/GroupByLevelController.java | 13 +-
.../db/mpp/plan/execution/QueryExecution.java | 16 +-
.../iotdb/db/mpp/plan/expression/Expression.java | 13 +-
.../db/mpp/plan/expression/ExpressionType.java | 11 +-
.../plan/expression/unary/IsNullExpression.java | 88 +
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 13 +
.../db/mpp/plan/planner/LocalExecutionPlanner.java | 8 +-
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 16 +-
.../iotdb/db/mpp/plan/planner/LogicalPlanner.java | 18 +-
.../node/metedata/read/SchemaFetchMergeNode.java | 2 +-
.../plan/planner/plan/node/process/FilterNode.java | 19 +-
.../planner/plan/node/process/TransformNode.java | 30 +-
.../statement/component/GroupByLevelComponent.java | 13 +
.../db/mpp/plan/statement/component/OrderBy.java | 13 +-
.../db/mpp/plan/statement/crud/QueryStatement.java | 3 +-
.../mpp/plan/statement/literal/BooleanLiteral.java | 8 +-
.../mpp/plan/statement/literal/DoubleLiteral.java | 6 +
.../db/mpp/plan/statement/literal/LongLiteral.java | 6 +
.../db/mpp/plan/statement/literal/NullLiteral.java | 6 +
.../mpp/transformation/api/LayerPointReader.java | 2 +-
.../db/mpp/transformation/api/LayerRowReader.java | 2 +-
.../transformation/api/LayerRowWindowReader.java | 2 +-
.../api/YieldableReader.java} | 15 +-
.../api/YieldableState.java} | 12 +-
.../dag/input/ConstantInputReader.java | 8 +-
.../dag/input}/IUDFInputDataSet.java | 10 +-
.../dag/input/QueryDataSetInputLayer.java | 70 +-
.../dag/input/TsBlockInputDataSet.java | 37 +-
.../MultiInputColumnIntermediateLayer.java | 355 +-
...InputColumnMultiReferenceIntermediateLayer.java | 142 +
...nputColumnSingleReferenceIntermediateLayer.java | 158 +-
.../dag/transformer/Transformer.java | 19 +
.../dag/transformer/binary/BinaryTransformer.java | 71 +
.../transformer/binary/LogicBinaryTransformer.java | 34 +
.../transformer/multi/UDFQueryRowTransformer.java | 15 +
.../multi/UDFQueryRowWindowTransformer.java | 12 +
.../dag/transformer/multi/UDFQueryTransformer.java | 21 +-
...naryTransformer.java => IsNullTransformer.java} | 47 +-
.../dag/transformer/unary/UnaryTransformer.java | 22 +
.../mpp/transformation/dag/util/InputRowUtils.java | 2 +-
.../transformation/dag/util/LayerCacheUtils.java | 88 +-
.../tv/ElasticSerializableTVList.java | 6 +
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 28 +-
.../iotdb/db/query/control/SessionManager.java | 30 +-
.../dataset/RawQueryDataSetWithValueFilter.java | 1 +
.../iotdb/db/query/dataset/UDFInputDataSet.java | 1 +
.../UDFRawQueryInputDataSetWithoutValueFilter.java | 1 +
.../db/query/dataset/UDTFAlignByTimeDataSet.java | 1 +
.../apache/iotdb/db/query/dataset/UDTFDataSet.java | 1 +
.../groupby/impl/LocalAlignedGroupByExecutor.java | 81 +-
.../groupby/impl/LocalGroupByExecutor.java | 59 +-
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 9 +
.../thrift/impl/DataNodeTSIServiceImpl.java | 9 +-
.../java/org/apache/iotdb/db/wal/WALManager.java | 24 +-
.../allocation/AbstractNodeAllocationStrategy.java | 2 +-
.../db/wal/allocation/FirstCreateStrategy.java | 18 +-
.../iotdb/db/wal/buffer/AbstractWALBuffer.java | 34 +-
.../org/apache/iotdb/db/wal/buffer/IWALBuffer.java | 2 +-
.../apache/iotdb/db/wal/buffer/SignalWALEntry.java | 2 +-
.../org/apache/iotdb/db/wal/buffer/WALBuffer.java | 34 +-
.../org/apache/iotdb/db/wal/buffer/WALEntry.java | 22 +-
.../iotdb/db/wal/checkpoint/CheckpointManager.java | 16 +-
.../iotdb/db/wal/checkpoint/MemTableInfo.java | 24 +-
.../apache/iotdb/db/wal/io/CheckpointReader.java | 6 +-
.../org/apache/iotdb/db/wal/io/ILogWriter.java | 8 +
.../java/org/apache/iotdb/db/wal/io/LogWriter.java | 5 +
.../org/apache/iotdb/db/wal/node/IWALNode.java | 10 +-
.../org/apache/iotdb/db/wal/node/WALFakeNode.java | 10 +-
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 107 +-
.../db/wal/recover/CheckpointRecoverUtils.java | 14 +-
.../iotdb/db/wal/recover/WALNodeRecoverTask.java | 33 +-
.../utils/WALFileStatus.java} | 34 +-
.../apache/iotdb/db/wal/utils/WALFileUtils.java | 63 +-
.../db/metadata/mtree/disk/MemManagerTest.java | 6 +-
.../db/metadata/schemaRegion/SchemaRegionTest.java | 6 +-
.../db/mpp/common/schematree/SchemaTreeTest.java | 11 +-
.../schema/SchemaFetchScanOperatorTest.java | 4 +-
.../db/mpp/plan/plan/QueryLogicalPlanUtil.java | 24 +-
.../plan/node/process/FilterNodeSerdeTest.java | 3 +-
...piServiceIT.java => GrafanaApiServiceTest.java} | 2 +-
...estServiceIT.java => IoTDBRestServiceTest.java} | 2 +-
.../org/apache/iotdb/db/script/EnvScriptIT.java | 1 +
.../org/apache/iotdb/db/tools/WalCheckerTest.java | 13 +-
.../db/wal/checkpoint/CheckpointManagerTest.java | 16 +-
.../apache/iotdb/db/wal/io/CheckpointFileTest.java | 8 +-
.../org/apache/iotdb/db/wal/io/WALFileTest.java | 7 +-
.../iotdb/db/wal/node/ConsensusReqReaderTest.java | 28 +-
.../org/apache/iotdb/db/wal/node/WALNodeTest.java | 37 +-
.../db/wal/recover/WALRecoverManagerTest.java | 12 +-
.../iotdb/db/wal/utils/WALFileUtilsTest.java | 162 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 6 +-
.../src/main/thrift/confignode.thrift | 10 +-
.../read/common/block/column/TimeColumn.java | 4 +
291 files changed, 19939 insertions(+), 12497 deletions(-)
create mode 100644 confignode/src/assembly/resources/sbin/remove-confignode.sh
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeRemoveCheck.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/AdjustMaxRegionGroupCountReq.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/RemoveConfigNodeReq.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/AddConfigNodeProcedure.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/OrderBy.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/AddConfigNodeState.java
(80%)
create mode 100644
consensus/src/main/java/org/apache/iotdb/consensus/ratis/FileInfoWithDelayedMd5Computing.java
copy integration-test/{import-control.xml => src/assembly/mpp-share.xml} (51%)
rename integration-test/src/main/java/org/apache/iotdb/itbase/{runtime =>
exception}/InconsistentDataException.java (81%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/OrderBy.java
=>
integration-test/src/main/java/org/apache/iotdb/itbase/exception/ParallelRequestTimeoutException.java
(77%)
delete mode 100644 integration-test/src/script/append-to-env.sh
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBCreateTimeseriesIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBFilterNullIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBNestedQueryIT.java
rename {integration/src/test/java/org/apache/iotdb/db/integration =>
integration-test/src/test/java/org/apache/iotdb/db/it}/IoTDBTimeZoneIT.java
(86%)
rename {integration/src/test/java/org/apache/iotdb/db/integration =>
integration-test/src/test/java/org/apache/iotdb/db/it}/aggregation/IoTDBAggregationByLevelIT.java
(61%)
rename {integration/src/test/java/org/apache/iotdb/db/integration =>
integration-test/src/test/java/org/apache/iotdb/db/it}/aggregation/IoTDBAggregationDeleteIT.java
(79%)
rename {integration/src/test/java/org/apache/iotdb/db/integration =>
integration-test/src/test/java/org/apache/iotdb/db/it}/aggregation/IoTDBAggregationIT.java
(72%)
rename {integration/src/test/java/org/apache/iotdb/db/integration =>
integration-test/src/test/java/org/apache/iotdb/db/it}/aggregation/IoTDBAggregationLargeDataIT.java
(75%)
rename {integration/src/test/java/org/apache/iotdb/db/integration =>
integration-test/src/test/java/org/apache/iotdb/db/it}/aggregation/IoTDBAggregationSmallDataIT.java
(82%)
rename
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/{IoTDBAggregationWithoutValueFilterWithDeletion2IT.java
=> IoTDBAggregationWithDeletion2IT.java} (96%)
rename
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/{IoTDBAggregationWithoutValueFilterWithDeletionIT.java
=> IoTDBAggregationWithDeletionIT.java} (76%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/groupby/IOTDBGroupByIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/groupby/IoTDBGroupByFillMixPathsIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/groupby/IoTDBGroupByNaturalMonthFillIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/groupby/IoTDBGroupByNaturalMonthIT.java
rename {integration/src/test/java/org/apache/iotdb/db/integration =>
integration-test/src/test/java/org/apache/iotdb/db/it}/groupby/IoTDBGroupByUnseqIT.java
(55%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/groupby/IoTDBGroupByWithFillIT.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/query/TestUtils.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/udf/IoTDBUDFWindowQueryIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/udf/IoTDBUDTFAlignByTimeQueryIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/udf/IoTDBUDTFNonAlignQueryIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/utils/TestUtils.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/IoTDBCreateTimeseriesIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/IoTDBUDTFBuiltinFunctionIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBAggregationWithValueFilter2IT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBAggregationWithValueFilterIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBAggregationWithValueFilterWithDeletion2IT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBAggregationWithValueFilterWithDeletionIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBGroupByQueryWithValueFilter2IT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBGroupByQueryWithValueFilterIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBGroupBySlidingWindowQueryWithValueFilterIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBGroupBySlidingWindowQueryWithoutValueFilterIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/groupby/IOTDBGroupByIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/groupby/IOTDBGroupByInnerIntervalIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/groupby/IoTDBGroupByMonthIT.java
rename
integration/src/test/java/org/apache/iotdb/db/integration/groupby/{IoTDBGroupByMonthFillIT.java
=> IoTDBGroupByNaturalMonthFillIT.java} (97%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/FilterNullOperator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/sink/FragmentSinkOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/expression/unary/IsNullExpression.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/{plan/statement/component/OrderBy.java
=> transformation/api/YieldableReader.java} (76%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/{plan/statement/component/OrderBy.java
=> transformation/api/YieldableState.java} (80%)
rename server/src/main/java/org/apache/iotdb/db/{query/dataset =>
mpp/transformation/dag/input}/IUDFInputDataSet.java (79%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/transformer/unary/{UnaryTransformer.java
=> IsNullTransformer.java} (53%)
copy
server/src/main/java/org/apache/iotdb/db/{mpp/plan/statement/component/GroupByLevelComponent.java
=> wal/utils/WALFileStatus.java} (54%)
rename
server/src/test/java/org/apache/iotdb/db/protocol/rest/{GrafanaApiServiceIT.java
=> GrafanaApiServiceTest.java} (99%)
rename
server/src/test/java/org/apache/iotdb/db/protocol/rest/{IoTDBRestServiceIT.java
=> IoTDBRestServiceTest.java} (99%)
