This is an automated email from the ASF dual-hosted git repository.
hui pushed a change to branch tsfile_name
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 35086c870d Update filename when upgrading from old version (#6603)
add 3f596c676f [IOTDB-3550]Fix show child nodes (#6598)
add 2343a33b88 remove duplicate IT (#6602)
add 05ffd8893b [IOTDB-3711] Update RegionRouteMap based on heartbeat
sample (#6590)
add a0e30f5157 [IOTDB-3745]Deduplicate mods of target files in compaction
(#6591)
add d7f26ab019 [IOTDB-3387]Print all bad files in Validation Tool (#6489)
add f7464253fb [IOTDB-3637] Optimize getOrCreatePartition process (#6596)
add c609bd01d8 [IOTDB-3313] Mappable UDTF, Reduce boxing/unboxing overhead
in UDF InputLayer / OutputLayer (#6565)
add 73db1ee9e4 [IOTDB-3628][IOTDB-3630][IOTDB-3764] Fix some faild ITs of
UDF
add 96b0e67304 Merge remote-tracking branch 'origin/master' into
tsfile_name
add 4dea3cf241 merge master
No new revisions were added by this update.
Summary of changes:
.../confignode/client/AsyncDataNodeClientPool.java | 19 +
.../handlers/ConfigNodeHeartbeatHandler.java | 6 +-
.../client/handlers/DataNodeHeartbeatHandler.java | 24 +-
...ndler.java => UpdateRegionRouteMapHandler.java} | 12 +-
.../iotdb/confignode/manager/ConfigManager.java | 2 +-
.../iotdb/confignode/manager/NodeManager.java | 6 +-
.../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 +-
.../persistence/partition/PartitionInfo.java | 31 -
.../partition/StorageGroupPartitionTable.java | 54 -
.../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 | 10 +-
.../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 +-
.../db/engine/compaction/CompactionUtils.java | 49 +-
.../engine/storagegroup/TsFileNameGenerator.java | 12 +
.../operator/schema/NodePathsConvertOperator.java | 3 +
.../operator/schema/SchemaQueryMergeOperator.java | 10 +-
.../plan/expression/multi/FunctionExpression.java | 7 +
.../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 ++
.../main/java/org/apache/iotdb/udf/api/UDTF.java | 14 +
.../api/customizer/strategy/AccessStrategy.java | 3 +
...gy.java => MappableRowByRowAccessStrategy.java} | 12 +-
60 files changed, 1026 insertions(+), 9218 deletions(-)
copy
confignode/src/main/java/org/apache/iotdb/confignode/client/handlers/{SetTTLHandler.java
=> UpdateRegionRouteMapHandler.java} (74%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/manager/load/heartbeat/{IHeartbeatStatistic.java
=> INodeCache.java} (77%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/manager/load/heartbeat/{HeartbeatPackage.java
=> NodeHeartbeatSample.java} (89%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/manager/load/heartbeat/{HeartbeatPackage.java
=> RegionHeartbeatSample.java} (71%)
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/IoTDBAutoCreateSchemaIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/IoTDBCreateStorageGroupIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/IoTDBDeleteStorageGroupIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/IoTDBDeletionIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/IoTDBMetadataFetchIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/IoTDBMultiDeviceIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/IoTDBNestedQueryIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/IoTDBSameMeasurementsDifferentTypesIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/IoTDBSimpleQueryIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/IoTDBSyntaxConventionIdentifierIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/IoTDBSyntaxConventionStringLiteralIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/IoTDBTagAlterIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBDeletionIT.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/transformer/multi/MappableUDFQueryRowTransformer.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/transformer/multi/{UDFQueryTransformer.java
=> UniversalUDFQueryTransformer.java} (77%)
copy
udf-api/src/main/java/org/apache/iotdb/udf/api/customizer/strategy/{RowByRowAccessStrategy.java
=> MappableRowByRowAccessStrategy.java} (81%)
