This is an automated email from the ASF dual-hosted git repository.
xiangweiwei pushed a change to branch accelerateCount
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 9981967f80 Merge branch 'accelerateCount' of github.com:apache/iotdb
into accelerateCount
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 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 26082c0dfe Merge branch 'master' into accelerateCount
No new revisions were added by this update.
Summary of changes:
.../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 +-
...edureLockState.java => AddConfigNodeState.java} | 8 +-
.../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 +--
.../apache/iotdb/db/it}/IoTDBNestedQueryIT.java | 283 ++--
...T.java => IoTDBAggregationWithDeletion2IT.java} | 3 +-
...IT.java => IoTDBAggregationWithDeletionIT.java} | 117 +-
.../db/it/aligned/IoTDBAlignedSeriesQueryIT.java | 1441 +++++++++++---------
.../org/apache/iotdb/db/it/env/StandaloneEnv.java | 6 +-
.../iotdb/db/it/udf}/IoTDBUDTFNonAlignQueryIT.java | 71 +-
.../iotdb/db/integration/IoTDBTimeZoneIT.java | 9 +-
.../db/integration/IoTDBUDTFBuiltinFunctionIT.java | 1038 --------------
.../IoTDBAggregationWithValueFilter2IT.java | 65 -
.../aligned/IoTDBAggregationWithValueFilterIT.java | 264 ----
...BAggregationWithValueFilterWithDeletion2IT.java | 85 --
...DBAggregationWithValueFilterWithDeletionIT.java | 221 ---
.../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 +
.../operator/process/FilterNullOperator.java | 57 -
.../execution/operator/process/FilterOperator.java | 121 +-
.../process/RawDataAggregationOperator.java | 12 +-
.../operator/process/TransformOperator.java | 130 +-
.../operator/schema/SchemaFetchMergeOperator.java | 52 +-
.../operator/schema/SchemaQueryMergeOperator.java | 43 +-
.../operator/sink/FragmentSinkOperator.java | 66 -
.../db/mpp/plan/planner/LocalExecutionPlanner.java | 2 +-
.../node/metedata/read/SchemaFetchMergeNode.java | 2 +-
.../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 +-
.../db/mpp/transformation/api/YieldableReader.java | 11 +-
.../db/mpp/transformation/api/YieldableState.java | 8 +-
.../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 +-
125 files changed, 3951 insertions(+), 3600 deletions(-)
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/procedure/impl/AddConfigNodeProcedure.java
copy
confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/{ProcedureLockState.java
=> AddConfigNodeState.java} (90%)
rename {integration/src/test/java/org/apache/iotdb/db/integration =>
integration-test/src/test/java/org/apache/iotdb/db/it}/IoTDBCreateTimeseriesIT.java
(64%)
copy {integration/src/test/java/org/apache/iotdb/db/integration =>
integration-test/src/test/java/org/apache/iotdb/db/it}/IoTDBNestedQueryIT.java
(71%)
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%)
copy {integration/src/test/java/org/apache/iotdb/db/integration =>
integration-test/src/test/java/org/apache/iotdb/db/it/udf}/IoTDBUDTFNonAlignQueryIT.java
(89%)
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
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
copy
tsfile/src/main/java/org/apache/iotdb/tsfile/read/query/timegenerator/node/Node.java
=>
server/src/main/java/org/apache/iotdb/db/mpp/transformation/api/YieldableReader.java
(79%)
copy cluster/src/test/java/org/apache/iotdb/cluster/utils/Constants.java =>
server/src/main/java/org/apache/iotdb/db/mpp/transformation/api/YieldableState.java
(83%)
rename server/src/main/java/org/apache/iotdb/db/{query/dataset =>
mpp/transformation/dag/input}/IUDFInputDataSet.java (79%)
