You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by hu...@apache.org on 2022/12/29 14:37:41 UTC
[iotdb] 02/05: Merge remote-tracking branch 'origin/master' into ml/thrift
This is an automated email from the ASF dual-hosted git repository.
hui pushed a commit to branch ml/thrift
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit cee00e0ce2c102f2a9e7da8f347f1372a23b35df
Merge: a000b57b87 0fedffd303
Author: Minghui Liu <li...@foxmail.com>
AuthorDate: Thu Dec 29 22:09:15 2022 +0800
Merge remote-tracking branch 'origin/master' into ml/thrift
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 1 +
.../apache/iotdb/db/qp/sql/InfluxDBSqlParser.g4 | 29 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 9 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 10 +-
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 8 +-
client-py/README.md | 37 +-
client-py/SessionExample.py | 26 +
client-py/iotdb/Session.py | 5 +-
client-py/iotdb/dbapi/tests/test_connection.py | 1 +
client-py/iotdb/dbapi/tests/test_cursor.py | 1 +
client-py/iotdb/sqlalchemy/tests/test_dialect.py | 3 +-
client-py/iotdb/utils/BitMap.py | 9 +
client-py/iotdb/utils/NumpyTablet.py | 33 +-
client-py/requirements_dev.txt | 2 +-
client-py/tests/test_aligned_timeseries.py | 1 +
client-py/tests/test_delete_data.py | 1 +
client-py/tests/test_numpy_tablet.py | 47 +
client-py/tests/test_one_device.py | 1 +
client-py/tests/test_session.py | 31 +-
.../resources/conf/iotdb-confignode.properties | 8 +-
.../assembly/resources/sbin/start-confignode.bat | 4 +-
.../async/AsyncConfigNodeHeartbeatClientPool.java | 6 +-
.../client/async/AsyncDataNodeClientPool.java | 5 +-
.../async/AsyncDataNodeHeartbeatClientPool.java | 6 +-
.../client/sync/SyncConfigNodeClientPool.java | 6 +-
.../client/sync/SyncDataNodeClientPool.java | 8 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 6 +-
.../confignode/conf/SystemPropertiesUtils.java | 9 +-
.../statemachine/ConfigNodeRegionStateMachine.java | 4 +-
.../iotdb/confignode/manager/ConfigManager.java | 121 +-
.../iotdb/confignode/manager/ConsensusManager.java | 2 +-
.../apache/iotdb/confignode/manager/IManager.java | 20 +
.../iotdb/confignode/manager/ProcedureManager.java | 50 +-
.../confignode/manager/RetryFailedTasksThread.java | 195 +++
.../iotdb/confignode/manager/SyncManager.java | 7 +-
.../iotdb/confignode/manager/node/NodeManager.java | 72 -
.../node/heartbeat/ConfigNodeHeartbeatCache.java | 2 +-
.../persistence/schema/ClusterSchemaInfo.java | 2 +-
.../impl/node/AddConfigNodeProcedure.java | 5 +-
.../OperatePipeProcedureRollbackProcessor.java | 122 --
.../iotdb/confignode/service/ConfigNode.java | 26 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 6 +
.../request/ConfigPhysicalPlanSerDeTest.java | 56 +-
.../load/balancer/router/RegionRouteMapTest.java | 8 +-
.../router/priority/GreedyPriorityTest.java | 8 +-
.../priority/LeaderPriorityBalancerTest.java | 16 +-
.../confignode/persistence/PartitionInfoTest.java | 8 +-
.../impl/CreateRegionGroupsProcedureTest.java | 16 +-
.../impl/node/AddConfigNodeProcedureTest.java | 2 +-
.../impl/node/RemoveConfigNodeProcedureTest.java | 2 +-
.../confignode1conf/iotdb-confignode.properties | 6 +-
.../confignode2conf/iotdb-confignode.properties | 6 +-
.../confignode3conf/iotdb-confignode.properties | 6 +-
.../consensus/iot/IoTConsensusServerImpl.java | 17 +-
.../consensus/iot/logdispatcher/LogDispatcher.java | 3 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 21 +-
docker/ReadMe.md | 10 +-
docker/src/main/DockerCompose/do-docker-build.sh | 18 +-
.../DockerCompose/docker-compose-cluster-1c2d.yml | 6 +-
.../DockerCompose/docker-compose-cluster-3c3d.yml | 16 +-
.../DockerCompose/docker-compose-host-3c3d.yml | 16 +-
...pose-1c1d.yml => docker-compose-standalone.yml} | 6 +-
docker/src/main/Dockerfile-0.12.6-cluster | 6 +-
docker/src/main/Dockerfile-0.13.0-cluster | 6 +-
docker/src/main/Dockerfile-1.0.0-confignode | 4 +-
docker/src/main/Dockerfile-1.0.0-datanode | 4 +-
...file-1.0.0-1c1d => Dockerfile-1.0.0-standalone} | 0
.../UserGuide/API/Programming-Python-Native-API.md | 39 +-
.../Administration-Management/Administration.md | 65 +-
docs/UserGuide/Cluster/Cluster-Maintenance.md | 85 +-
docs/UserGuide/Cluster/Cluster-Setup.md | 44 +-
.../Edge-Cloud-Collaboration/Sync-Tool.md | 8 +-
docs/UserGuide/QuickStart/ClusterQuickStart.md | 92 +-
docs/UserGuide/QuickStart/WayToGetIoTDB.md | 32 +-
.../Reference/ConfigNode-Config-Manual.md | 6 +-
docs/UserGuide/Reference/DataNode-Config-Manual.md | 10 +-
.../UserGuide/API/Programming-Python-Native-API.md | 39 +-
.../Administration-Management/Administration.md | 65 +-
docs/zh/UserGuide/Cluster/Cluster-Concept.md | 24 +-
docs/zh/UserGuide/Cluster/Cluster-Maintenance.md | 85 +-
docs/zh/UserGuide/Cluster/Cluster-Setup.md | 42 +-
.../Edge-Cloud-Collaboration/Sync-Tool.md | 8 +-
docs/zh/UserGuide/QuickStart/ClusterQuickStart.md | 102 +-
docs/zh/UserGuide/QuickStart/WayToGetIoTDB.md | 30 +-
.../Reference/ConfigNode-Config-Manual.md | 6 +-
.../UserGuide/Reference/DataNode-Config-Manual.md | 10 +-
.../web/grafana/interceptor/LoginInterceptor.java | 3 +
integration-test/import-control.xml | 1 +
.../java/org/apache/iotdb/it/env/AbstractEnv.java | 28 +-
.../org/apache/iotdb/it/env/RemoteServerEnv.java | 34 +-
.../org/apache/iotdb/itbase/env/BaseConfig.java | 30 +-
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 3 +-
.../confignode/it/IoTDBConfigNodeSnapshotIT.java | 5 +-
.../iotdb/confignode/it/IoTDBStorageGroupIT.java | 8 +-
.../it/cluster/IoTDBClusterNodeErrorStartUpIT.java | 58 +-
.../it/cluster/IoTDBClusterNodeGetterIT.java | 81 +-
.../it/cluster/IoTDBClusterRestartIT.java | 2 +-
.../load/IoTDBClusterRegionLeaderBalancingIT.java | 6 +-
.../it/load/IoTDBConfigNodeSwitchLeaderIT.java | 7 +-
.../partition/IoTDBAutoRegionGroupExtensionIT.java | 4 +-
.../IoTDBCustomRegionGroupExtensionIT.java | 6 +-
.../it/partition/IoTDBPartitionDurableIT.java | 14 +-
.../it/partition/IoTDBPartitionGetterIT.java | 19 +-
.../partition/IoTDBPartitionInheritPolicyIT.java | 5 +-
.../confignode/it/utils/ConfigNodeTestUtils.java | 46 +-
.../java/org/apache/iotdb/db/it/cq/IoTDBCQIT.java | 88 ++
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 166 +--
node-commons/pom.xml | 4 +
.../src/assembly/resources/sbin/iotdb-common.sh | 12 +-
.../iotdb/commons/auth/entity/PrivilegeType.java | 3 +-
.../commons/client/ClientFactoryProperty.java | 7 +-
.../apache/iotdb/commons/client/ClientManager.java | 78 +-
.../iotdb/commons/client/ClientPoolProperty.java | 18 +-
.../iotdb/commons/client/IClientManager.java | 18 +-
.../iotdb/commons/client/IClientPoolFactory.java | 7 +-
.../client/exception/ClientManagerException.java | 10 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 20 +-
.../apache/iotdb/commons/path/fa/FAFactory.java | 55 +
.../iotdb/commons/path/fa/IFATransition.java | 4 +-
.../apache/iotdb/commons/path/fa/IPatternFA.java | 58 +
.../apache/iotdb/commons/path/fa/dfa/DFAState.java | 66 +
.../iotdb/commons/path/fa/dfa/PatternDFA.java | 152 +++
.../iotdb/commons/path/fa/dfa/graph/Closure.java | 66 +
.../iotdb/commons/path/fa/dfa/graph/DFAGraph.java | 173 +++
.../iotdb/commons/path/fa/dfa/graph/NFAGraph.java | 126 ++
.../fa/dfa/transition/AbstractDFATransition.java | 54 +
.../fa/dfa/transition/DFAPreciseTransition.java | 28 +-
.../fa/dfa/transition/DFAWildcardTransition.java | 38 +-
.../iotdb/commons/path/fa/{ => nfa}/SimpleNFA.java | 12 +-
.../commons/schema/tree/AbstractTreeVisitor.java | 32 +-
.../iotdb/commons/service/ThriftServiceThread.java | 2 +-
.../iotdb/commons/client/ClientManagerTest.java | 24 +-
.../apache/iotdb/commons/path/PatternDFATest.java | 153 +++
.../iotdb/commons/utils/NodeUrlUtilsTest.java | 8 +-
.../commons/utils/ThriftCommonsSerDeUtilsTest.java | 16 +-
.../utils/ThriftConfigNodeSerDeUtilsTest.java | 2 +-
.../resources/conf/iotdb-datanode.properties | 12 +-
.../src/assembly/resources/sbin/start-datanode.bat | 8 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 4 +-
.../iotdb/db/auth/ClusterAuthorityFetcher.java | 10 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 22 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 10 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 4 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 3 +-
.../org/apache/iotdb/db/constant/SqlConstant.java | 66 +
.../db/engine/compaction/CompactionScheduler.java | 8 +-
.../db/engine/compaction/CompactionUtils.java | 14 +-
.../compaction/cross/CrossSpaceCompactionTask.java | 2 -
.../compaction/cross/ICrossSpaceSelector.java | 4 +-
.../cross/rewrite/CrossCompactionTaskResource.java | 119 ++
.../rewrite/CrossSpaceCompactionCandidate.java | 259 ++++
.../rewrite/CrossSpaceCompactionResource.java | 74 -
.../RewriteCrossSpaceCompactionSelector.java | 340 ++---
.../performer/impl/FastCompactionPerformer.java | 2 +-
.../compaction/task/ICompactionSelector.java | 4 +-
.../writer/AbstractCrossCompactionWriter.java | 10 +-
.../writer/FastCrossCompactionWriter.java | 14 +-
.../writer/ReadPointCrossCompactionWriter.java | 7 +
.../db/engine/querycontext/QueryDataSource.java | 2 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 2 +-
.../db/engine/storagegroup/TsFileResource.java | 33 +-
.../storagegroup/timeindex/DeviceTimeIndex.java | 4 +
.../apache/iotdb/db/exception/MergeException.java | 2 +-
.../index/IllegalIndexParamException.java | 28 -
.../db/exception/index/IndexManagerException.java | 34 -
.../db/exception/index/IndexRuntimeException.java | 32 -
.../db/exception/index/QueryIndexException.java | 29 -
.../exception/query/LogicalOperatorException.java | 54 -
.../exception/query/LogicalOptimizeException.java | 46 -
.../db/exception/query/OutOfTTLException.java | 2 +-
.../exception/query/PathNumOverLimitException.java | 33 -
.../query/UnSupportedFillTypeException.java | 33 -
.../iotdb/db/exception/sql/SQLParserException.java | 35 -
.../exception/sql/StatementAnalyzeException.java | 13 -
.../iotdb/db/index/common/IndexConstant.java | 36 -
.../apache/iotdb/db/index/common/IndexType.java | 78 --
.../apache/iotdb/db/index/common/IndexUtils.java | 35 -
.../iotdb/db/localconfignode/LocalConfigNode.java | 2 +-
.../apache/iotdb/db/metadata/MetadataConstant.java | 4 +
.../mtree/snapshot/MemMTreeSnapshotUtil.java | 4 +-
.../metadata/template/ClusterTemplateManager.java | 6 +-
.../db/metadata/utils/ResourceByPathUtils.java | 151 ---
.../timerangeiterator/AggrWindowIterator.java | 4 +-
.../TimeRangeIteratorFactory.java | 2 +-
.../constant => common}/DataNodeEndPoints.java | 7 +-
.../db/mpp/common/filter/BasicFilterType.java | 189 ---
.../db/mpp/common/filter/BasicFunctionFilter.java | 191 ---
.../mpp/common/filter/FilterDeserializeUtil.java | 63 -
.../iotdb/db/mpp/common/filter/FunctionFilter.java | 91 --
.../iotdb/db/mpp/common/filter/InFilter.java | 230 ----
.../iotdb/db/mpp/common/filter/LikeFilter.java | 152 ---
.../iotdb/db/mpp/common/filter/QueryFilter.java | 354 -----
.../iotdb/db/mpp/common/filter/RegexpFilter.java | 150 --
.../db/mpp/common/header/ColumnHeaderConstant.java | 10 +-
.../db/mpp/common/header/DatasetHeaderFactory.java | 4 +
.../db/mpp/execution/exchange/SinkHandle.java | 4 +-
.../execution/operator/source/SeriesScanUtil.java | 17 +-
.../org/apache/iotdb/db/mpp/plan/Coordinator.java | 2 +-
.../apache/iotdb/db/mpp/plan/TestRPCClient.java | 63 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 3 +-
.../mpp/plan/analyze/ClusterPartitionFetcher.java | 17 +-
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 10 +-
.../db/mpp/plan/analyze/cache/PartitionCache.java | 11 +-
.../iotdb/db/mpp/plan/constant/FilterConstant.java | 103 --
.../db/mpp/plan/execution/QueryExecution.java | 2 +-
.../plan/execution/config/ConfigTaskVisitor.java | 11 +-
.../config/executor/ClusterConfigTaskExecutor.java | 76 +-
.../config/executor/IConfigTaskExecutor.java | 2 +
.../config/metadata/ShowClusterDetailsTask.java | 4 +-
.../config/metadata/ShowClusterParametersTask.java | 136 ++
.../execution/config/sys/sync/ShowPipeTask.java | 2 +-
.../iotdb/db/mpp/plan/expression/ResultColumn.java | 146 --
.../visitor/OldIntermediateLayerVisitor.java | 461 -------
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 227 ++--
.../plan/parser/SqlParseError.java} | 7 +-
.../db/mpp/plan/parser/StatementGenerator.java | 13 +-
.../plan/planner/MemoryDistributionCalculator.java | 2 +-
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 2 +-
.../SimpleFragmentParallelPlanner.java | 2 +-
.../db/mpp/plan/rewriter/DnfFilterOptimizer.java | 163 ---
.../db/mpp/plan/rewriter/IFilterOptimizer.java | 29 -
.../plan/rewriter/MergeSingleFilterOptimizer.java | 179 ---
.../db/mpp/plan/rewriter/RemoveNotOptimizer.java | 103 --
.../scheduler/AbstractFragInsStateTracker.java | 4 +-
.../scheduler/FixedRateFragInsStateTracker.java | 4 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 4 +-
.../mpp/plan/scheduler/SimpleQueryTerminator.java | 7 +-
.../scheduler/load/LoadTsFileDispatcherImpl.java | 6 +-
.../iotdb/db/mpp/plan/statement/Statement.java | 1 -
.../{constant => statement}/StatementType.java | 2 +-
.../plan/statement/component/SelectComponent.java | 2 +-
.../plan/statement/crud/DeleteDataStatement.java | 2 +-
.../crud/InsertMultiTabletsStatement.java | 2 +-
.../plan/statement/crud/InsertRowStatement.java | 2 +-
.../crud/InsertRowsOfOneDeviceStatement.java | 2 +-
.../plan/statement/crud/InsertRowsStatement.java | 2 +-
.../mpp/plan/statement/crud/InsertStatement.java | 2 +-
.../plan/statement/crud/InsertTabletStatement.java | 2 +-
.../plan/statement/crud/LoadTsFileStatement.java | 2 +-
.../db/mpp/plan/statement/crud/QueryStatement.java | 2 +-
.../InternalCreateTimeSeriesStatement.java | 2 +-
.../statement/internal/SchemaFetchStatement.java | 2 +-
.../metadata/AlterTimeSeriesStatement.java | 2 +-
.../plan/statement/metadata/CountStatement.java | 2 +-
.../metadata/CreateAlignedTimeSeriesStatement.java | 2 +-
.../metadata/CreateContinuousQueryStatement.java | 2 +-
.../metadata/CreateFunctionStatement.java | 2 +-
.../metadata/CreateMultiTimeSeriesStatement.java | 2 +-
.../metadata/CreateTimeSeriesStatement.java | 2 +-
.../statement/metadata/CreateTriggerStatement.java | 2 +-
.../metadata/DeleteStorageGroupStatement.java | 2 +-
.../metadata/DeleteTimeSeriesStatement.java | 2 +-
.../metadata/DropContinuousQueryStatement.java | 2 +-
.../statement/metadata/DropFunctionStatement.java | 2 +-
.../statement/metadata/DropTriggerStatement.java | 2 +-
.../metadata/SetStorageGroupStatement.java | 2 +-
.../plan/statement/metadata/SetTTLStatement.java | 2 +-
.../statement/metadata/ShowClusterStatement.java | 9 +
.../metadata/ShowContinuousQueriesStatement.java | 2 +-
.../mpp/plan/statement/metadata/ShowStatement.java | 2 +-
.../plan/statement/metadata/UnSetTTLStatement.java | 2 +-
.../template/ActivateTemplateStatement.java | 2 +-
.../template/CreateSchemaTemplateStatement.java | 2 +-
.../template/DeactivateTemplateStatement.java | 2 +-
.../template/DropSchemaTemplateStatement.java | 2 +-
.../template/SetSchemaTemplateStatement.java | 2 +-
.../ShowNodesInSchemaTemplateStatement.java | 2 +-
.../template/ShowPathSetTemplateStatement.java | 2 +-
.../template/ShowPathsUsingTemplateStatement.java | 2 +-
.../template/ShowSchemaTemplateStatement.java | 2 +-
.../template/UnsetSchemaTemplateStatement.java | 2 +-
.../db/mpp/plan/statement/sys/AuthorStatement.java | 2 +-
.../plan/statement/sys/ClearCacheStatement.java | 2 +-
.../db/mpp/plan/statement/sys/FlushStatement.java | 2 +-
.../statement/sys/LoadConfigurationStatement.java | 2 +-
.../db/mpp/plan/statement/sys/MergeStatement.java | 2 +-
.../statement/sys/SetSystemStatusStatement.java | 2 +-
.../sys/sync/CreatePipeSinkStatement.java | 2 +-
.../statement/sys/sync/CreatePipeStatement.java | 2 +-
.../statement/sys/sync/DropPipeSinkStatement.java | 2 +-
.../plan/statement/sys/sync/DropPipeStatement.java | 2 +-
.../statement/sys/sync/StartPipeStatement.java | 2 +-
.../plan/statement/sys/sync/StopPipeStatement.java | 2 +-
.../db/mpp/transformation/dag/udf/UDTFContext.java | 8 -
...fluxSQLConstant.java => InfluxSqlConstant.java} | 15 +-
.../influxdb/function/InfluxFunctionFactory.java | 24 +-
.../function/aggregator/InfluxCountFunction.java | 4 +-
.../function/aggregator/InfluxMeanFunction.java | 4 +-
.../function/aggregator/InfluxMedianFunction.java | 4 +-
.../function/aggregator/InfluxModeFunction.java | 4 +-
.../function/aggregator/InfluxSpreadFunction.java | 4 +-
.../function/aggregator/InfluxStddevFunction.java | 4 +-
.../function/aggregator/InfluxSumFunction.java | 4 +-
.../function/selector/InfluxFirstFunction.java | 4 +-
.../function/selector/InfluxLastFunction.java | 4 +-
.../function/selector/InfluxMaxFunction.java | 4 +-
.../function/selector/InfluxMinFunction.java | 4 +-
.../influxdb/handler/AbstractQueryHandler.java | 202 +--
.../protocol/influxdb/handler/NewQueryHandler.java | 20 +-
.../protocol/influxdb/input/InfluxLineParser.java | 2 +-
.../influxdb/operator/InfluxQueryOperator.java | 38 -
.../influxdb/parser/InfluxDBAstVisitor.java | 321 +++++
.../InfluxDBStatementGenerator.java} | 25 +-
.../protocol/influxdb/sql/InfluxDBSqlVisitor.java | 298 ----
.../influxdb/statement/InfluxQueryStatement.java | 57 +
.../InfluxSelectComponent.java | 21 +-
.../db/protocol/influxdb/util/FilterUtils.java | 20 +-
.../db/protocol/mqtt/PayloadFormatManager.java | 19 +-
.../db/protocol/rest/handler/ExceptionHandler.java | 3 +-
.../rest/handler/ExecuteStatementHandler.java | 2 +-
.../iotdb/db/qp/constant/FilterConstant.java | 114 --
.../apache/iotdb/db/qp/constant/SQLConstant.java | 285 ----
.../org/apache/iotdb/db/qp/logical/Operator.java | 200 ---
.../db/qp/logical/crud/BasicFunctionOperator.java | 172 ---
.../db/qp/logical/crud/BasicOperatorType.java | 191 ---
.../iotdb/db/qp/logical/crud/FilterOperator.java | 295 ----
.../iotdb/db/qp/logical/crud/FromComponent.java | 41 -
.../iotdb/db/qp/logical/crud/FunctionOperator.java | 48 -
.../iotdb/db/qp/logical/crud/QueryOperator.java | 106 --
.../iotdb/db/qp/logical/crud/SelectComponent.java | 139 --
.../db/qp/logical/crud/SpecialClauseComponent.java | 162 ---
.../iotdb/db/qp/utils/GroupByLevelController.java | 327 -----
.../iotdb/db/query/control/FileReaderManager.java | 11 +
.../db/query/control/QueryResourceManager.java | 14 -
.../apache/iotdb/db/query/filter/TsFileFilter.java | 31 -
.../query/reader/series/AlignedSeriesReader.java | 109 --
.../reader/series/SeriesRawDataBatchReader.java | 140 --
.../iotdb/db/query/reader/series/SeriesReader.java | 1430 --------------------
.../java/org/apache/iotdb/db/service/DataNode.java | 4 +-
.../thrift/impl/NewInfluxDBServiceImpl.java | 17 +-
.../java/org/apache/iotdb/db/sync/SyncService.java | 2 +-
.../apache/iotdb/db/tools/IoTDBDataDirViewer.java | 2 +-
.../iotdb/db/tools/TsFileResourcePrinter.java | 2 +-
.../db/tools/watermark/WatermarkDetector.java | 9 +-
.../db/trigger/executor/TriggerFireVisitor.java | 10 +-
.../iotdb/db/utils/AlignedValueIterator.java | 59 -
.../org/apache/iotdb/db/utils/CommonUtils.java | 10 +-
.../iotdb/db/{qp => }/utils/DateTimeUtils.java | 2 +-
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 4 -
.../org/apache/iotdb/db/utils/FileLoaderUtils.java | 15 -
.../java/org/apache/iotdb/db/utils/FilesUtils.java | 43 -
.../iotdb/db/utils/IExpressionDeserializeUtil.java | 51 -
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 133 --
.../org/apache/iotdb/db/utils/SchemaUtils.java | 20 +-
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 46 +-
.../org/apache/iotdb/db/utils/ValueIterator.java | 56 -
.../timerangeiterator/AggrWindowIterator.java | 165 ---
.../timerangeiterator/ITimeRangeIterator.java | 39 -
.../timerangeiterator/PreAggrWindowIterator.java | 158 ---
.../PreAggrWindowWithNaturalMonthIterator.java | 123 --
.../TimeRangeIteratorFactory.java | 69 -
.../org/apache/iotdb/db/wal/buffer/WALBuffer.java | 3 +-
.../FastCrossCompactionPerformerTest.java | 329 ++++-
.../FastInnerCompactionPerformerTest.java | 186 +++
.../ReadPointCompactionPerformerTest.java | 470 ++++++-
.../CrossSpaceCompactionWithFastPerformerTest.java | 21 +-
...eCompactionWithFastPerformerValidationTest.java | 906 ++++++-------
...sSpaceCompactionWithReadPointPerformerTest.java | 21 +-
...actionWithReadPointPerformerValidationTest.java | 906 ++++++-------
.../engine/compaction/cross/MergeUpgradeTest.java | 4 +-
.../cross/RewriteCompactionFileSelectorTest.java | 121 +-
...eCrossSpaceCompactionWithFastPerformerTest.java | 163 +--
...sSpaceCompactionWithReadPointPerformerTest.java | 163 +--
.../inner/InnerCompactionMoreDataTest.java | 28 +-
.../SizeTieredCompactionRecoverTest.java | 230 ++--
.../compaction/utils/CompactionCheckerUtils.java | 24 +-
.../iotdb/db/engine/storagegroup/TTLTest.java | 31 +-
.../schemaRegion/SchemaRegionManagementTest.java | 43 +
.../common/schematree/ClusterSchemaTreeTest.java | 86 ++
.../db/mpp/execution/exchange/SinkHandleTest.java | 9 +-
.../mpp/execution/exchange/SourceHandleTest.java | 12 +-
.../mpp/plan/plan/FragmentInstanceSerdeTest.java | 16 +-
.../influxdb/sql/InfluxDBLogicalGeneratorTest.java | 70 -
.../sql/InfluxDBStatementGeneratorTest.java | 87 ++
.../org/apache/iotdb/db/qp/sql/ASTVisitorTest.java | 10 +-
.../db/qp/utils/DatetimeQueryDataSetUtilsTest.java | 2 +
.../apache/iotdb/db/utils/EnvironmentUtils.java | 3 +
.../org/apache/iotdb/db/utils/SchemaUtilsTest.java | 12 +-
.../iotdb/db/utils/TimeRangeIteratorTest.java | 298 ----
.../datanode1conf/iotdb-datanode.properties | 10 +-
.../datanode2conf/iotdb-datanode.properties | 12 +-
.../datanode3conf/iotdb-datanode.properties | 12 +-
server/src/test/resources/logback-test.xml | 1 +
.../src/main/thrift/confignode.thrift | 42 +-
.../read/common/block/column/NullColumn.java | 19 +-
.../iotdb/tsfile/read/common/ColumnTest.java | 12 +
386 files changed, 6942 insertions(+), 12338 deletions(-)