You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by xi...@apache.org on 2022/06/23 12:44:27 UTC
[iotdb] 01/02: Merge branch 'master' into test_ratis_0623
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 <xi...@gmail.com>
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(-)