This is an automated email from the ASF dual-hosted git repository. xingtanzjr pushed a commit to branch multileader_restart_test in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 283bd3a5f9a5b792e9d39f31df8ae51963961fed Merge: 62cdf9adb7 9c244b7f4f Author: Jinrui.Zhang <[email protected]> AuthorDate: Thu Jul 7 20:03:11 2022 +0800 Merge branch 'master' into multileader_restart_test .../confignode/client/AsyncDataNodeClientPool.java | 19 + .../handlers/ConfigNodeHeartbeatHandler.java | 6 +- .../client/handlers/DataNodeHeartbeatHandler.java | 24 +- .../handlers/UpdateRegionRouteMapHandler.java | 58 + .../request/read/GetDataPartitionPlan.java | 46 +- .../request/read/GetOrCreateDataPartitionPlan.java | 24 + .../read/GetOrCreateSchemaPartitionPlan.java | 9 + .../request/read/GetSchemaPartitionPlan.java | 5 +- .../response/DataNodeConfigurationResp.java | 6 +- .../consensus/response/DataPartitionResp.java | 30 + .../consensus/response/SchemaPartitionResp.java | 19 + .../iotdb/confignode/manager/ConfigManager.java | 167 ++- .../apache/iotdb/confignode/manager/IManager.java | 20 +- .../iotdb/confignode/manager/NodeManager.java | 44 +- .../iotdb/confignode/manager/PartitionManager.java | 343 ++---- .../iotdb/confignode/manager/load/LoadManager.java | 98 +- .../load/heartbeat/ConfigNodeHeartbeatCache.java | 40 +- .../load/heartbeat/DataNodeHeartbeatCache.java | 32 +- .../{IHeartbeatStatistic.java => INodeCache.java} | 16 +- .../manager/load/heartbeat/IRegionGroupCache.java | 16 +- ...rtbeatPackage.java => NodeHeartbeatSample.java} | 6 +- .../manager/load/heartbeat/RegionGroupCache.java | 59 +- ...beatPackage.java => RegionHeartbeatSample.java} | 21 +- .../iotdb/confignode/persistence/NodeInfo.java | 11 +- .../persistence/partition/PartitionInfo.java | 31 - .../partition/StorageGroupPartitionTable.java | 54 - .../thrift/ConfigNodeRPCServiceProcessor.java | 61 +- .../request/ConfigPhysicalPlanSerDeTest.java | 12 +- docs/UserGuide/Query-Data/Fill-Null-Value.md | 389 ++---- docs/zh/UserGuide/Query-Data/Fill-Null-Value.md | 399 ++----- .../org/apache/iotdb/db/it/IoTDBNestedQueryIT.java | 5 +- .../db/it/udf/IoTDBUDTFBuiltinFunctionIT.java | 7 - .../db/integration/IoTDBAutoCreateSchemaIT.java | 208 ---- .../IoTDBCreateAlignedTimeseriesIT.java | 27 - .../db/integration/IoTDBCreateStorageGroupIT.java | 131 -- .../db/integration/IoTDBDeleteStorageGroupIT.java | 183 --- .../iotdb/db/integration/IoTDBDeletionIT.java | 529 -------- .../iotdb/db/integration/IoTDBMetadataFetchIT.java | 660 ---------- .../iotdb/db/integration/IoTDBMultiDeviceIT.java | 297 ----- .../iotdb/db/integration/IoTDBNestedQueryIT.java | 681 ----------- .../IoTDBSameMeasurementsDifferentTypesIT.java | 182 --- .../iotdb/db/integration/IoTDBSimpleQueryIT.java | 1258 -------------------- .../IoTDBSyntaxConventionIdentifierIT.java | 998 ---------------- .../IoTDBSyntaxConventionStringLiteralIT.java | 764 ------------ .../iotdb/db/integration/IoTDBTagAlterIT.java | 625 ---------- .../apache/iotdb/db/integration/IoTDBTagIT.java | 887 +------------- .../db/integration/IoTDBUDFWindowQueryIT.java | 35 +- .../integration/IoTDBUDTFAlignByTimeQueryIT.java | 628 ---------- .../db/integration/aligned/IoTDBDeletionIT.java | 554 --------- .../commons/partition/DataPartitionTable.java | 24 +- .../commons/udf/builtin/String/UDTFEndsWith.java | 13 +- .../commons/udf/builtin/String/UDTFLower.java | 14 +- .../commons/udf/builtin/String/UDTFUpper.java | 14 +- .../apache/iotdb/commons/udf/builtin/UDTFAbs.java | 27 +- .../apache/iotdb/commons/udf/builtin/UDTFMath.java | 29 +- .../iotdb/commons/udf/builtin/UDTFOnOff.java | 34 +- .../apache/iotdb/db/client/ConfigNodeClient.java | 69 ++ .../db/engine/compaction/CompactionUtils.java | 49 +- .../engine/storagegroup/TsFileNameGenerator.java | 23 + .../operator/schema/NodePathsConvertOperator.java | 3 + .../operator/schema/SchemaQueryMergeOperator.java | 10 +- .../plan/expression/multi/FunctionExpression.java | 7 + .../db/mpp/plan/statement/literal/LongLiteral.java | 11 +- .../multi/MappableUDFQueryRowTransformer.java | 122 ++ .../transformer/multi/UDFQueryRowTransformer.java | 2 +- .../multi/UDFQueryRowWindowTransformer.java | 2 +- .../dag/transformer/multi/UDFQueryTransformer.java | 83 +- ...rmer.java => UniversalUDFQueryTransformer.java} | 48 +- .../mpp/transformation/dag/udf/UDTFExecutor.java | 13 + .../db/tools/validate/TsFileValidationTool.java | 181 ++- .../cross/RewriteCrossSpaceCompactionTest.java | 8 +- .../compaction/inner/InnerSeqCompactionTest.java | 90 ++ .../src/main/thrift/confignode.thrift | 26 + .../main/java/org/apache/iotdb/udf/api/UDTF.java | 14 + .../api/customizer/strategy/AccessStrategy.java | 3 + .../strategy/MappableRowByRowAccessStrategy.java | 59 + 76 files changed, 1772 insertions(+), 9930 deletions(-)
