This is an automated email from the ASF dual-hosted git repository. xingtanzjr pushed a commit to branch test_ratis_0623 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit ed314291fe993ae29b4d52340f6e8b5f05fa1c2c Merge: 7b6e5c83a8 19fff1d5d7 Author: Jinrui.Zhang <[email protected]> AuthorDate: Thu Jun 23 20:42:05 2022 +0800 Merge branch 'master' into test_ratis_0623 .../confignode/client/AsyncDataNodeClientPool.java | 10 +- .../client/SyncConfigNodeClientPool.java | 15 +- .../confignode/conf/ConfigNodeStartupCheck.java | 28 +- .../consensus/request/ConfigRequest.java | 6 +- .../consensus/request/ConfigRequestType.java | 3 +- .../write/AdjustMaxRegionGroupCountReq.java | 89 ++ .../consensus/request/write/CreateRegionsReq.java | 28 +- .../confignode/manager/ClusterSchemaManager.java | 147 ++- .../iotdb/confignode/manager/ConfigManager.java | 25 +- .../iotdb/confignode/manager/ConsensusManager.java | 78 +- .../apache/iotdb/confignode/manager/Manager.java | 6 +- .../iotdb/confignode/manager/NodeManager.java | 11 +- .../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 ++- .../executor/ConfigRequestExecutor.java | 7 +- .../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 | 26 +- .../procedure/store/ProcedureFactory.java | 9 +- .../thrift/ConfigNodeRPCServiceProcessor.java | 17 +- .../consensus/request/ConfigRequestSerDeTest.java | 18 +- .../confignode/persistence/PartitionInfoTest.java | 20 +- .../apache/iotdb/consensus/config/RatisConfig.java | 2 +- .../iotdb/consensus/ratis/RatisConsensus.java | 2 +- docs/Download/README.md | 1 + .../Process-Data/UDF-User-Defined-Function.md | 58 +- docs/zh/Download/README.md | 1 + .../Process-Data/UDF-User-Defined-Function.md | 61 +- integration-test/pom.xml | 2 +- .../java/org/apache/iotdb/it/env/AbstractEnv.java | 145 ++- .../apache/iotdb/it/env/AbstractNodeWrapper.java | 223 ++-- .../org/apache/iotdb/it/env/ConfigNodeWrapper.java | 49 +- .../org/apache/iotdb/it/env/DataNodeWrapper.java | 35 +- .../org/apache/iotdb/it/env/IoTDBTestRunner.java | 2 +- .../org/apache/iotdb/it/env/RemoteServerEnv.java | 7 +- .../iotdb/it/env/StandaloneDataNodeWrapper.java | 5 +- .../apache/iotdb/it/env/StandaloneOnMppEnv.java | 34 +- .../java/org/apache/iotdb/itbase/env/BaseEnv.java | 4 +- .../apache/iotdb/itbase/env/BaseNodeWrapper.java | 4 + .../itbase/runtime/InconsistentDataException.java | 2 +- .../itbase/runtime/ParallelRequestDelegate.java | 3 + .../iotdb/itbase/runtime/RequestDelegate.java | 5 +- .../iotdb/db/it}/IoTDBCreateTimeseriesIT.java | 153 +-- .../org/apache/iotdb/db/it/IoTDBNestedQueryIT.java | 620 ++++++++++ .../db/it/aligned/IoTDBAlignedSeriesQueryIT.java | 1274 ++++++++++---------- .../org/apache/iotdb/db/it/env/StandaloneEnv.java | 6 +- .../iotdb/db/it/udf/IoTDBUDTFNonAlignQueryIT.java | 350 ++++++ .../iotdb/db/integration/IoTDBTimeZoneIT.java | 9 +- .../db/integration/IoTDBUDTFBuiltinFunctionIT.java | 1038 ---------------- .../main/java/org/apache/iotdb/jdbc/Config.java | 3 + .../org/apache/iotdb/jdbc/IoTDBConnection.java | 23 +- .../apache/iotdb/jdbc/IoTDBConnectionParams.java | 12 + .../src/main/java/org/apache/iotdb/jdbc/Utils.java | 14 + .../org/apache/iotdb/jdbc/IoTDBConnectionTest.java | 12 + .../commons/udf/service/UDFClassLoaderManager.java | 4 +- .../src/assembly/resources/sbin/stop-datanode.sh | 2 +- .../apache/iotdb/db/client/ConfigNodeClient.java | 4 +- .../db/conf/directories/DirectoryManager.java | 6 + .../db/consensus/DataRegionConsensusImpl.java | 9 + .../iotdb/db/engine/snapshot/SnapshotLoader.java | 7 + .../iotdb/db/engine/snapshot/SnapshotTaker.java | 6 + .../iotdb/db/engine/storagegroup/DataRegion.java | 25 +- .../metadata/DataTypeMismatchException.java | 8 +- .../iotdb/db/localconfignode/LocalConfigNode.java | 33 +- .../schemaregion/SchemaRegionMemoryImpl.java | 28 +- .../execution/datatransfer/LocalSourceHandle.java | 7 + .../mpp/execution/datatransfer/SourceHandle.java | 6 +- .../operator/process/DeviceMergeOperator.java | 3 + .../operator/process/DeviceViewOperator.java | 3 + .../execution/operator/process/FilterOperator.java | 121 +- .../process/RawDataAggregationOperator.java | 12 +- .../operator/process/TransformOperator.java | 130 +- .../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 +- ...erRowWindowReader.java => YieldableReader.java} | 12 +- .../db/mpp/transformation/api/YieldableState.java | 26 +- .../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 +- .../dag/transformer/unary/UnaryTransformer.java | 22 + .../mpp/transformation/dag/util/InputRowUtils.java | 2 +- .../transformation/dag/util/LayerCacheUtils.java | 88 +- .../tv/ElasticSerializableTVList.java | 6 + .../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 + .../apache/iotdb/db/service/IoTDBShutdownHook.java | 9 + .../src/main/thrift/confignode.thrift | 6 +- 113 files changed, 4426 insertions(+), 2634 deletions(-)
