This is an automated email from the ASF dual-hosted git repository. hui pushed a commit to branch lmh/addQueryIT in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 2634594e49345c816f29f57f0a241c16dd186ffc Merge: 2ca0c71f24 4f3890471c Author: Minghui Liu <[email protected]> AuthorDate: Tue Jun 21 22:08:14 2022 +0800 Merge remote-tracking branch 'origin/master' into lmh/addQueryIT client-py/tests/test_dataframe.py | 2 + client-py/tests/test_one_device.py | 1 + client-py/tests/test_tablet.py | 2 + client-py/tests/test_todf.py | 3 + .../resources/conf/iotdb-confignode.properties | 4 - .../confignode/client/AsyncDataNodeClientPool.java | 18 +++ .../confignode/client/SyncDataNodeClientPool.java | 21 +-- .../confignode/client/handlers/FlushHandler.java | 66 ++++++++ .../iotdb/confignode/conf/ConfigNodeConfig.java | 11 -- .../confignode/conf/ConfigNodeDescriptor.java | 5 - .../statemachine/PartitionRegionStateMachine.java | 2 + .../iotdb/confignode/manager/ConfigManager.java | 16 +- .../apache/iotdb/confignode/manager/Manager.java | 3 + .../iotdb/confignode/manager/NodeManager.java | 27 ++++ .../iotdb/confignode/manager/UDFManager.java | 18 +-- .../iotdb/confignode/manager/load/LoadManager.java | 76 +++++++--- .../thrift/ConfigNodeRPCServiceProcessor.java | 15 +- .../iotdb/consensus/config/MultiLeaderConfig.java | 2 +- .../multileader/MultiLeaderConsensus.java | 17 ++- .../multileader/MultiLeaderServerImpl.java | 6 +- .../multileader/logdispatcher/LogDispatcher.java | 12 +- docs/UserGuide/Query-Data/Query-Filter.md | 3 +- docs/UserGuide/Query-Data/Select-Expression.md | 39 ++++- docs/zh/UserGuide/Query-Data/Query-Filter.md | 3 +- docs/zh/UserGuide/Query-Data/Select-Expression.md | 38 ++++- integration-test/README.md | 95 +++--------- .../constant}/BuiltinAggregationFunctionEnum.java | 2 +- .../BuiltinTimeSeriesGeneratingFunctionEnum.java | 2 +- .../iotdb/itbase/constant/UDFTestConstant.java | 31 ++++ .../iotdb/itbase/runtime/ClusterTestStatement.java | 13 +- .../iotdb/db/it/udf/IoTDBUDFManagementIT.java | 2 + .../iotdb/db/it/udf/IoTDBUDTFHybridQueryIT.java | 167 +++++++++++++++++++++ .../db/integration/sync/IoTDBSyncSenderIT.java | 2 + .../resources/conf/iotdb-engine.properties | 10 +- .../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 26 +++- .../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 10 ++ .../apache/iotdb/db/engine/StorageEngineV2.java | 12 +- .../iotdb/db/engine/storagegroup/DataRegion.java | 16 +- .../iotdb/db/localconfignode/LocalConfigNode.java | 2 +- .../org/apache/iotdb/db/mpp/plan/Coordinator.java | 14 +- .../org/apache/iotdb/db/mpp/plan/StepTracker.java | 80 ++++++++++ .../apache/iotdb/db/mpp/plan/analyze/Analyzer.java | 36 ++++- .../db/mpp/plan/execution/QueryExecution.java | 22 ++- .../db/mpp/plan/expression/ExpressionType.java | 4 +- .../db/mpp/plan/expression/unary/InExpression.java | 24 ++- .../mpp/plan/expression/unary/LikeExpression.java | 6 + .../plan/expression/unary/RegularExpression.java | 6 + .../planner/distribution/DistributionPlanner.java | 3 - .../db/mpp/plan/scheduler/ClusterScheduler.java | 32 ++-- .../scheduler/FragmentInstanceDispatcherImpl.java | 21 ++- .../mpp/plan/scheduler/SimpleQueryTerminator.java | 63 +++++--- .../db/mpp/plan/scheduler/StandaloneScheduler.java | 7 +- .../dag/input/ConstantInputReader.java | 2 +- .../dag/transformer/unary/InTransformer.java | 36 +---- .../dag/transformer/unary/RegularTransformer.java | 6 +- .../java/org/apache/iotdb/db/service/DataNode.java | 14 +- .../iotdb/db/wal/recover/WALRecoverManager.java | 20 ++- .../db/mpp/plan/StandaloneCoordinatorTest.java | 2 + .../apache/iotdb/db/utils/EnvironmentUtils.java | 3 + .../db/wal/recover/WALRecoverManagerTest.java | 2 + .../main/java/org/apache/iotdb/rpc/RpcUtils.java | 12 ++ 61 files changed, 889 insertions(+), 326 deletions(-)
