This is an automated email from the ASF dual-hosted git repository. shuwenwei pushed a commit to branch table_disk_usage_statistics in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 0a8c04f9c05b4fe32f866fb3565a55f82822d2e3 Merge: b4711270859 23b1313bad3 Author: shuwenwei <[email protected]> AuthorDate: Tue Oct 28 11:29:30 2025 +0800 Merge branch 'iotdb_master' into table_disk_usage_statistics LICENSE | 24 +- LICENSE-binary | 4 - dependencies.json | 334 ++++----- .../server/CustomizedJsonPayloadFormatter.java | 2 +- .../java/org/apache/iotdb/mqtt/MQTTClient.java | 13 +- integration-test/import-control.xml | 2 +- integration-test/pom.xml | 22 +- .../iotdb/it/env/cluster/ClusterConstant.java | 2 +- .../org/apache/iotdb/it/env/cluster/EnvUtils.java | 2 +- .../it/env/cluster/config/MppCommonConfig.java | 2 +- .../iotdb/it/env/cluster/node/AINodeWrapper.java | 2 +- .../it/env/cluster/node/AbstractNodeWrapper.java | 6 +- .../constant/BuiltinAggregationFunctionEnum.java | 7 +- .../BuiltinTimeSeriesGeneratingFunctionEnum.java | 1 + .../itbase/runtime/ClusterTestConnection.java | 2 +- .../ainode/it/AINodeConcurrentInferenceIT.java | 31 +- .../confignode/it/IoTDBConfigNodeSnapshotIT.java | 2 +- .../org/apache/iotdb/db/it/IoTDBRestartIT.java | 2 +- .../iotdb/db/it/IoTDBSetConfigurationIT.java | 10 +- .../org/apache/iotdb/db/it/auth/IoTDBAuthIT.java | 38 + .../iotdb/db/it/auth/IoTDBRelationalAuthIT.java | 37 + .../iotdb/it/framework/IoTDBTestListener.java | 2 +- .../pipe/it/dual/tablemodel/TableModelUtils.java | 33 + .../IoTDBPipeTsFileDecompositionWithModsIT.java | 192 +++++ .../IoTDBPipeTsFileDecompositionWithModsIT.java | 660 +++++++++++++++++ .../manual/IoTDBPipeTypeConversionISessionIT.java | 11 +- .../it/query/old/orderBy/IoTDBOrderByTableIT.java | 2 +- .../it/query/recent/IoTDBUnionTable2IT.java | 45 ++ .../it/query/recent/IoTDBUnionTableIT.java | 18 + .../query/recent/scalar/IoTDBCRC32FunctionIT.java | 149 ++++ .../scalar/IoTDBFromBase32ColumnFunctionIT.java | 197 +++++ .../scalar/IoTDBFromBase64ColumnFunctionIT.java | 117 +++ .../scalar/IoTDBFromBase64UrlColumnFunctionIT.java | 186 +++++ .../scalar/IoTDBFromBigEndian32FunctionIT.java | 170 +++++ .../scalar/IoTDBFromBigEndian64FunctionIT.java | 169 +++++ .../scalar/IoTDBFromHexColumnFunctionIT.java | 133 ++++ .../scalar/IoTDBFromIEEE754_32FunctionIT.java | 154 ++++ .../scalar/IoTDBFromIEEE754_64FunctionIT.java | 154 ++++ .../scalar/IoTDBFromLittleEndian32FunctionIT.java | 173 +++++ .../scalar/IoTDBFromLittleEndian64FunctionIT.java | 173 +++++ .../recent/scalar/IoTDBHmacMd5FunctionIT.java | 211 ++++++ .../recent/scalar/IoTDBHmacSha1FunctionIT.java | 211 ++++++ .../recent/scalar/IoTDBHmacSha256FunctionIT.java | 217 ++++++ .../recent/scalar/IoTDBHmacSha512FunctionIT.java | 221 ++++++ .../query/recent/scalar/IoTDBLpadFunctionIT.java | 230 ++++++ .../recent/scalar/IoTDBMd5ColumnFunctionIT.java | 132 ++++ .../scalar/IoTDBMurmur3ColumnFunctionIT.java | 132 ++++ .../recent/scalar/IoTDBReverseFunctionIT.java | 136 ++++ .../query/recent/scalar/IoTDBRpadFunctionIT.java | 230 ++++++ .../recent/scalar/IoTDBSha1ColumnFunctionIT.java | 132 ++++ .../recent/scalar/IoTDBSha256ColumnFunctionIT.java | 134 ++++ .../recent/scalar/IoTDBSha512ColumnFunctionIT.java | 132 ++++ .../scalar/IoTDBSpookyHashV2_32FunctionIT.java | 156 ++++ .../scalar/IoTDBSpookyHashV2_64FunctionIT.java | 156 ++++ .../scalar/IoTDBToBase32ColumnFunctionIT.java | 141 ++++ .../scalar/IoTDBToBase64ColumnFunctionIT.java | 149 ++++ .../scalar/IoTDBToBase64UrlColumnFunctionIT.java | 126 ++++ .../scalar/IoTDBToBigEndian32FunctionIT.java | 143 ++++ .../scalar/IoTDBToBigEndian64FunctionIT.java | 139 ++++ .../recent/scalar/IoTDBToHexColumnFunctionIT.java | 149 ++++ .../recent/scalar/IoTDBToIEEE754_32FunctionIT.java | 118 +++ .../recent/scalar/IoTDBToIEEE754_64FunctionIT.java | 119 +++ .../scalar/IoTDBToLittleEndian32FunctionIT.java | 140 ++++ .../scalar/IoTDBToLittleEndian64FunctionIT.java | 140 ++++ .../scalar/IoTDBXXHash64ColumnFunctionIT.java | 132 ++++ .../view/old/orderby/IoTDBOrderByTableViewIT.java | 2 +- .../iotdb/session/it/IoTDBSessionSimpleIT.java | 2 +- .../it/SkipOnSetUpAndTearDownFailure.java | 3 +- .../org/apache/iotdb/util/AbstractSchemaIT.java | 2 +- iotdb-client/cli/pom.xml | 8 - .../java/org/apache/iotdb/cli/AbstractCli.java | 2 +- .../org/apache/iotdb/cli/utils/IoTPrinter.java | 2 +- .../apache/iotdb/tool/data/AbstractDataTool.java | 4 +- .../org/apache/iotdb/tool/data/ExportData.java | 4 +- .../apache/iotdb/tool/data/ExportDataTable.java | 6 +- .../org/apache/iotdb/tool/data/ExportDataTree.java | 2 +- .../org/apache/iotdb/tool/data/ImportData.java | 4 +- .../apache/iotdb/tool/data/ImportDataTable.java | 8 +- .../iotdb/tool/schema/AbstractSchemaTool.java | 2 +- .../org/apache/iotdb/tool/schema/ExportSchema.java | 2 +- .../iotdb/tool/schema/ExportSchemaTable.java | 6 +- .../org/apache/iotdb/tool/schema/ImportSchema.java | 2 +- .../iotdb/tool/schema/ImportSchemaTable.java | 4 +- .../apache/iotdb/tool/schema/ImportSchemaTree.java | 6 +- .../org/apache/iotdb/tool/tsfile/ExportTsFile.java | 2 +- .../subscription/SubscriptionTableTsFile.java | 2 +- .../subscription/SubscriptionTreeTsFile.java | 2 +- iotdb-client/jdbc/pom.xml | 4 - .../org/apache/iotdb/jdbc/IoTDBConnection.java | 2 +- .../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 24 +- .../org/apache/iotdb/jdbc/IoTDBJDBCResultSet.java | 2 +- .../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 2 +- iotdb-core/confignode/pom.xml | 16 - .../confignode/conf/ConfigNodeRemoveCheck.java | 155 ---- .../consensus/request/write/cq/ActiveCQPlan.java | 2 +- .../consensus/request/write/cq/AddCQPlan.java | 2 +- .../consensus/request/write/cq/DropCQPlan.java | 2 +- .../request/write/cq/UpdateCQLastExecTimePlan.java | 2 +- .../load/cache/detector/PhiAccrualDetector.java | 14 +- .../manager/partition/PartitionManager.java | 8 +- .../receiver/protocol/IoTDBConfigNodeReceiver.java | 14 +- .../confignode/persistence/pipe/PipeTaskInfo.java | 14 +- .../schema/CNPhysicalPlanGenerator.java | 2 +- .../persistence/schema/TemplateTable.java | 2 +- .../procedure/impl/cq/CreateCQProcedure.java | 2 +- .../impl/pipe/AbstractOperatePipeProcedureV2.java | 21 + .../impl/pipe/task/AlterPipeProcedureV2.java | 45 +- .../confignode/persistence/AuthorInfoTest.java | 2 +- .../iotdb/confignode/persistence/CQInfoTest.java | 2 +- .../ConfigRegionListeningQueueTest.java | 2 +- .../iotdb/confignode/persistence/NodeInfoTest.java | 2 +- .../confignode/persistence/PartitionInfoTest.java | 2 +- .../iotdb/confignode/persistence/PipeInfoTest.java | 2 +- .../confignode/persistence/QuotaInfoTest.java | 2 +- .../iotdb/confignode/persistence/TTLInfoTest.java | 2 +- .../confignode/persistence/TriggerInfoTest.java | 2 +- .../iotdb/confignode/persistence/UDFInfoTest.java | 2 +- .../persistence/schema/ClusterSchemaInfoTest.java | 2 +- .../schema/TemplatePreSetTableTest.java | 2 +- .../persistence/schema/TemplateTableTest.java | 2 +- iotdb-core/consensus/pom.xml | 9 - .../consensus/iot/IoTConsensusServerImpl.java | 2 +- .../iot/client/AsyncIoTConsensusServiceClient.java | 2 +- .../consensus/iot/client/DispatchLogHandler.java | 2 +- .../iot/logdispatcher/IndexController.java | 2 +- .../pipe/consensuspipe/ConsensusPipeManager.java | 4 +- .../iotdb/consensus/ratis/SnapshotStorage.java | 2 +- iotdb-core/datanode/pom.xml | 32 +- .../src/main/codegen/templates/ModeAccumulator.ftl | 2 +- .../org/apache/iotdb/db/auth/LoginLockManager.java | 10 +- .../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 21 +- .../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 18 +- .../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 2 +- .../agent/runtime/SimpleProgressIndexAssigner.java | 2 +- .../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 30 +- .../task/builder/PipeDataNodeTaskBuilder.java | 98 +-- .../task/subtask/sink/PipeSinkSubtaskManager.java | 2 +- .../event/common/heartbeat/PipeHeartbeatEvent.java | 4 +- .../tablet/parser/TabletInsertionEventParser.java | 11 +- .../common/tsfile/PipeTsFileInsertionEvent.java | 2 +- .../tsfile/parser/TsFileInsertionEventParser.java | 16 + .../parser/TsFileInsertionEventParserProvider.java | 20 +- .../query/TsFileInsertionEventQueryParser.java | 79 +- ...ileInsertionEventQueryParserTabletIterator.java | 33 +- .../scan/TsFileInsertionEventScanParser.java | 356 ++++++--- .../table/TsFileInsertionEventTableParser.java | 30 +- ...ileInsertionEventTableParserTabletIterator.java | 53 +- .../tsfile/parser/util/ModsOperationUtil.java | 314 ++++++++ .../metric/processor/PipeProcessorMetrics.java | 3 +- .../schema/PipeSchemaRegionListenerMetrics.java | 4 +- .../metric/schema/PipeSchemaRegionSinkMetrics.java | 3 +- .../schema/PipeSchemaRegionSourceMetrics.java | 3 +- .../metric/sink/PipeDataRegionSinkMetrics.java | 3 +- .../db/pipe/metric/source/PipeAssignerMetrics.java | 3 +- .../metric/source/PipeDataRegionSourceMetrics.java | 3 +- .../legacy/IoTDBLegacyPipeReceiverAgent.java | 2 +- .../pipeconsensus/PipeConsensusReceiver.java | 2 +- .../pipeconsensus/PipeConsensusReceiverAgent.java | 2 +- .../protocol/thrift/IoTDBDataNodeReceiver.java | 6 +- .../transform/converter/ValueConverter.java | 2 +- ...leStatementDataTypeConvertExecutionVisitor.java | 5 +- ...eeStatementDataTypeConvertExecutionVisitor.java | 4 +- ...aNodeHardlinkOrCopiedFileDirStartupCleaner.java | 2 +- .../sink/protocol/legacy/IoTDBLegacyPipeSink.java | 2 +- .../async/handler/PipeTransferTsFileHandler.java | 2 +- .../thrift/sync/IoTDBDataRegionSyncSink.java | 2 +- .../websocket/WebSocketConnectorServer.java | 4 +- .../util/builder/PipeTableModelTsFileBuilder.java | 2 +- .../util/builder/PipeTreeModelTsFileBuilder.java | 2 +- .../pipe/sink/util/builder/PipeTsFileBuilder.java | 2 +- .../source/dataregion/IoTDBDataRegionSource.java | 71 +- ...istoricalDataRegionTsFileAndDeletionSource.java | 25 +- .../realtime/PipeRealtimeDataRegionSource.java | 4 +- .../realtime/assigner/DisruptorQueue.java | 16 +- .../assigner/DisruptorQueueExceptionHandler.java | 3 +- .../realtime/disruptor/BatchEventProcessor.java | 120 ++++ .../dataregion/realtime/disruptor/Disruptor.java | 135 ++++ .../realtime/disruptor/EventFactory.java} | 36 +- .../realtime/disruptor/EventHandler.java} | 39 +- .../ExceptionHandler.java} | 43 +- .../realtime/disruptor/MultiProducerSequencer.java | 270 +++++++ .../dataregion/realtime/disruptor/RingBuffer.java | 295 ++++++++ .../dataregion/realtime/disruptor/Sequence.java | 122 ++++ .../realtime/disruptor/SequenceBarrier.java | 78 ++ .../realtime/disruptor/SequenceGroups.java | 65 ++ .../listener/PipeTimePartitionListener.java | 3 +- .../db/protocol/mqtt/BrokerAuthenticator.java | 2 +- .../db/protocol/mqtt/JSONPayloadFormatter.java | 2 +- .../db/protocol/mqtt/LinePayloadFormatter.java | 15 +- .../db/protocol/mqtt/PayloadFormatManager.java | 6 +- .../table/v1/handler/RequestValidationHandler.java | 2 +- .../rest/v1/handler/RequestValidationHandler.java | 2 +- .../rest/v1/impl/GrafanaApiServiceImpl.java | 2 +- .../rest/v2/handler/RequestValidationHandler.java | 2 +- .../rest/v2/impl/GrafanaApiServiceImpl.java | 2 +- .../iotdb/db/protocol/session/SessionManager.java | 2 +- .../execution/exchange/MPPDataExchangeManager.java | 2 +- .../execution/exchange/SharedTsBlockQueue.java | 2 +- .../execution/exchange/sink/LocalSinkChannel.java | 2 +- .../execution/exchange/sink/ShuffleSinkHandle.java | 2 +- .../execution/exchange/sink/SinkChannel.java | 2 +- .../exchange/source/LocalSourceHandle.java | 2 +- .../execution/exchange/source/SourceHandle.java | 2 +- .../queryengine/execution/memory/MemoryPool.java | 2 +- .../execution/operator/AggregationUtil.java | 2 +- .../operator/process/CollectOperator.java | 6 +- .../operator/process/MappingCollectOperator.java | 79 ++ .../operator/process/TagAggregationOperator.java | 2 +- .../process/join/merge/MergeSortComparator.java | 2 +- .../relational/ColumnTransformerBuilder.java | 328 +++++++++ .../plan/analyze/ExpressionAnalyzer.java | 4 +- .../analyze/cache/partition/PartitionCache.java | 2 +- .../plan/analyze/load/LoadTsFileAnalyzer.java | 2 +- .../load/TreeSchemaAutoCreatorAndVerifier.java | 4 + .../config/executor/ClusterConfigTaskExecutor.java | 7 +- .../config/executor/IConfigTaskExecutor.java | 3 +- .../config/metadata/ShowFunctionsTask.java | 6 +- .../plan/execution/memory/MemorySourceHandle.java | 2 +- .../plan/expression/ExpressionFactory.java | 2 +- .../plan/expression/multi/FunctionExpression.java | 4 +- .../expression/other/CaseWhenThenExpression.java | 2 +- .../plan/expression/unary/RegularExpression.java | 2 +- .../cartesian/BindSchemaForExpressionVisitor.java | 2 +- .../cartesian/BindSchemaForPredicateVisitor.java | 2 +- ...catDeviceAndBindSchemaForExpressionVisitor.java | 2 +- ...ncatDeviceAndBindSchemaForPredicateVisitor.java | 2 +- .../ConcatExpressionWithSuffixPathsVisitor.java | 2 +- .../plan/optimization/AggregationPushDown.java | 6 +- .../db/queryengine/plan/parser/ASTVisitor.java | 2 +- .../plan/planner/LogicalPlanBuilder.java | 2 +- .../plan/planner/OperatorTreeGenerator.java | 4 +- .../plan/planner/TableOperatorGenerator.java | 20 +- .../plan/planner/TemplatedLogicalPlan.java | 2 +- .../distribution/DistributionPlanContext.java | 2 +- .../planner/distribution/DistributionPlanner.java | 2 +- .../plan/AbstractFragmentParallelPlanner.java | 2 +- .../plan/planner/plan/node/PlanGraphPrinter.java | 4 +- .../planner/plan/node/process/GroupByTagNode.java | 2 +- .../plan/node/source/LastQueryScanNode.java | 2 +- .../planner/plan/parameter/IntoPathDescriptor.java | 2 +- .../function/tvf/ForecastTableFunction.java | 2 +- .../relational/metadata/TableMetadataImpl.java | 469 +++++++++++- .../planner/distribute/SubPlanGenerator.java | 2 +- .../distribute/TableDistributedPlanGenerator.java | 96 ++- .../relational/planner/node/SetOperationNode.java | 4 +- .../plan/relational/planner/node/UnionNode.java | 31 +- .../plan/relational/sql/ast/LoadTsFile.java | 2 +- .../sql/ast/RelationalAuthorStatement.java | 11 + .../relational/sql/ast/SearchedCaseExpression.java | 2 +- .../plan/relational/sql/ast/ShowSubscriptions.java | 4 +- .../plan/relational/sql/ast/ShowTopics.java | 4 +- .../relational/sql/ast/SimpleCaseExpression.java | 2 +- .../plan/relational/type/CompatibleResolver.java | 5 + .../plan/scheduler/AsyncSendPlanNodeHandler.java | 2 +- .../scheduler/FragmentInstanceDispatcherImpl.java | 2 +- .../scheduler/load/LoadTsFileDispatcherImpl.java | 2 +- .../statement/component/GroupByTagComponent.java | 2 +- .../plan/statement/component/IntoItem.java | 2 +- .../plan/statement/crud/InsertTabletStatement.java | 34 +- .../plan/statement/crud/LoadTsFileStatement.java | 4 +- .../plan/statement/sys/AuthorStatement.java | 6 + .../plan/udf}/BuiltinAggregationFunction.java | 2 +- .../plan/udf}/BuiltinScalarFunction.java | 2 +- .../udf}/BuiltinTimeSeriesGeneratingFunction.java | 51 +- .../queryengine/plan/udf/UDFManagementService.java | 3 - .../db/queryengine/plan/udf/UDTFForecast.java | 273 +++++++ .../AbstractCaseWhenThenColumnTransformer.java | 2 +- .../dag/column/binary/HmacColumnTransformer.java | 108 +++ .../binary/factory/HmacStrategiesFactory.java | 93 +++ .../column/binary/strategies/HmacStrategy.java} | 23 +- .../dag/column/ternary/LpadColumnTransformer.java | 92 +++ .../dag/column/ternary/RpadColumnTransformer.java | 92 +++ .../column/ternary/TernaryColumnTransformer.java | 2 +- .../dag/column/ternary/utils/BytePaddingUtils.java | 87 +++ .../scalar/BytesToDoubleColumnTransformer.java | 78 ++ .../scalar/BytesToFloatColumnTransformer.java | 79 ++ .../unary/scalar/BytesToIntColumnTransformer.java | 81 +++ .../unary/scalar/BytesToLongColumnTransformer.java | 80 +++ .../dag/column/unary/scalar/CRC32Transformer.java | 61 ++ .../scalar/DoubleToBytesColumnTransformer.java | 61 ++ .../scalar/FloatToBytesColumnTransformer.java | 61 ++ .../scalar/GenericCodecColumnTransformer.java | 92 +++ .../scalar/HmacConstantKeyColumnTransformer.java | 68 ++ .../unary/scalar/IntToBytesColumnTransformer.java | 62 ++ .../unary/scalar/LongToBytesColumnTransformer.java | 60 ++ .../scalar/factory/CodecStrategiesFactory.java | 133 ++++ .../factory/NumericCodecStrategiesFactory.java | 169 +++++ .../unary/scalar/inteface/CodecStrategy.java} | 23 +- .../dag/column/unary/scalar/util/HexUtils.java | 86 +++ .../unary/scalar/util/SpookyHashV2Utils.java | 603 ++++++++++++++++ .../unary/scalar/util/TransformerDebugUtils.java | 62 ++ .../apache/iotdb/db/schemaengine/SchemaEngine.java | 27 +- .../schemaengine/schemaregion/tag/TagLogFile.java | 2 +- .../schemaengine/schemaregion/tag/TagManager.java | 2 +- .../iotdb/db/schemaengine/template/Template.java | 2 +- .../db/service/TemporaryQueryDataFileService.java | 2 +- .../iotdb/db/storageengine/StorageEngine.java | 2 +- .../db/storageengine/dataregion/DataRegion.java | 2 +- .../exception/CompactionExceptionHandler.java | 2 +- .../execute/recover/CompactionRecoverTask.java | 2 +- .../estimator/AbstractCompactionEstimator.java | 2 +- .../dataregion/flush/CompressionRatio.java | 2 +- .../dataregion/snapshot/SnapshotLoader.java | 2 +- .../dataregion/wal/io/CheckpointReader.java | 6 + .../dataregion/wal/io/WALInputStream.java | 14 +- .../storageengine/dataregion/wal/io/WALWriter.java | 4 + .../file/AbstractTsFileRecoverPerformer.java | 2 +- .../load/active/ActiveLoadDirScanner.java | 2 +- .../load/active/ActiveLoadTsFileLoader.java | 2 +- .../load/config/LoadTsFileConfigurator.java | 4 +- ...leStatementDataTypeConvertExecutionVisitor.java | 5 +- ...eeStatementDataTypeConvertExecutionVisitor.java | 10 +- .../rescon/disk/DirectoryChecker.java | 2 +- .../broker/SubscriptionPrefetchingQueue.java | 7 +- .../broker/SubscriptionPrefetchingTabletQueue.java | 3 +- .../broker/SubscriptionPrefetchingTsFileQueue.java | 3 +- .../event/batch/SubscriptionPipeEventBatch.java | 4 +- .../event/batch/SubscriptionPipeEventBatches.java | 4 +- .../response/SubscriptionEventTsFileResponse.java | 3 +- .../SubscriptionPrefetchingQueueMetrics.java | 3 +- .../subtask/SubscriptionSinkSubtaskManager.java | 2 +- .../trigger/service/TriggerManagementService.java | 2 +- .../org/apache/iotdb/db/utils/CommonUtils.java | 2 +- .../apache/iotdb/db/utils/TypeInferenceUtils.java | 2 +- .../apache/iotdb/db/auth/LoginLockManagerTest.java | 4 +- .../db/auth/role/LocalFileRoleAccessorTest.java | 2 +- .../db/auth/role/LocalFileRoleManagerTest.java | 2 +- .../db/auth/user/LocalFileUserAccessorTest.java | 2 +- .../db/auth/user/LocalFileUserManagerTest.java | 2 +- .../schemaRegion/AbstractSchemaRegionTest.java | 2 +- .../schemaRegion/SchemaRegionBasicTest.java | 2 +- .../pipe/event/TsFileInsertionEventParserTest.java | 2 +- .../tsfile/parser/util/ModsOperationUtilTest.java | 408 +++++++++++ .../source/SchemaRegionListeningQueueTest.java | 2 +- .../execution/exchange/SharedTsBlockQueueTest.java | 2 +- .../analyzer/PushAggregationThroughUnionTest.java | 148 ++++ .../plan/relational/analyzer/TSBSMetadata.java | 2 +- .../relational/analyzer/TableFunctionTest.java | 4 +- .../plan/relational/analyzer/TestMetadata.java | 2 +- .../binary/hmac/HmacMd5ColumnTransformerTest.java | 420 +++++++++++ .../binary/hmac/HmacSha1ColumnTransformerTest.java | 420 +++++++++++ .../hmac/HmacSha256ColumnTransformerTest.java | 420 +++++++++++ .../hmac/HmacSha512ColumnTransformerTest.java | 356 +++++++++ .../column/ternary/LpadColumnTransformerTest.java | 303 ++++++++ .../column/ternary/RpadColumnTransformerTest.java | 303 ++++++++ .../FromBigEndian32ColumnTransformerTest.java | 220 ++++++ .../FromBigEndian64ColumnTransformerTest.java | 242 +++++++ ...omIEEE754_32BigEndianColumnTransformerTest.java | 231 ++++++ ...omIEEE754_64BigEndianColumnTransformerTest.java | 231 ++++++ .../FromLittleEndian32ColumnTransformerTest.java | 221 ++++++ .../FromLittleEndian64ColumnTransformerTest.java | 243 +++++++ .../ToBigEndian32ColumnTransformerTest.java | 188 +++++ .../ToBigEndian64ColumnTransformerTest.java | 188 +++++ ...ToIEEE754_32BigEndianColumnTransformerTest.java | 179 +++++ ...ToIEEE754_64BigEndianColumnTransformerTest.java | 159 ++++ .../ToLittleEndian32ColumnTransformerTest.java | 189 +++++ .../ToLittleEndian64ColumnTransformerTest.java | 189 +++++ .../unary/scalar/ReverseColumnTransformerTest.java | 216 ++++++ .../FromBase32ColumnTransformerTest.java | 268 +++++++ .../FromBase64ColumnTransformerTest.java | 271 +++++++ .../FromBase64UrlColumnTransformerTest.java | 328 +++++++++ .../ToBase32ColumnTransformerTest.java | 196 +++++ .../ToBase64ColumnTransformerTest.java | 190 +++++ .../ToBase64UrlColumnTransformerTest.java | 235 ++++++ .../scalar/hashing/Crc32ColumnTransformerTest.java | 200 ++++++ .../scalar/hashing/Md5ColumnTransformerTest.java | 225 ++++++ .../hashing/Murmur3ColumnTransformerTest.java | 224 ++++++ .../scalar/hashing/Sha1ColumnTransformerTest.java | 225 ++++++ .../hashing/Sha256ColumnTransformerTest.java | 229 ++++++ .../hashing/Sha512ColumnTransformerTest.java | 224 ++++++ .../SpookyHashV2_32ColumnTransformerTest.java | 183 +++++ .../SpookyHashV2_64ColumnTransformerTest.java | 183 +++++ .../hashing/XxHash64ColumnTransformerTest.java | 238 ++++++ .../hexEncoding/FromHexColumnTransformerTest.java | 239 ++++++ .../hexEncoding/ToHexColumnTransformerTest.java | 222 ++++++ .../security/encrypt/MessageDigestEncryptTest.java | 2 +- .../storageengine/buffer/BloomFilterCacheTest.java | 2 +- .../dataregion/TsFileManagerTest.java | 2 +- .../TsFileResourceProgressIndexTest.java | 2 +- .../compaction/AbstractCompactionTest.java | 4 +- .../compaction/CompactionTaskManagerTest.java | 2 +- .../compaction/CompactionValidationTest.java | 2 +- .../TsFileValidationCorrectnessTests.java | 2 +- .../inner/AbstractInnerSpaceCompactionTest.java | 2 +- .../inner/FastCompactionPerformerAlignedTest.java | 2 +- .../FastCompactionPerformerNoAlignedTest.java | 2 +- .../inner/InnerCompactionEmptyTsFileTest.java | 2 +- .../compaction/inner/InnerCompactionLogTest.java | 2 +- .../inner/InnerCompactionMoreDataTest.java | 2 +- .../ReadChunkCompactionPerformerAlignedTest.java | 2 +- .../ReadChunkCompactionPerformerNoAlignedTest.java | 2 +- .../inner/ReadChunkCompactionPerformerOldTest.java | 2 +- .../recover/SizeTieredCompactionRecoverTest.java | 2 +- .../compaction/utils/CompactionClearUtils.java | 2 +- .../dataregion/flush/CompressionRatioTest.java | 2 +- .../dataregion/memtable/TsFileProcessorTest.java | 2 +- .../dataregion/tsfile/TsFileResourceTest.java | 2 +- .../wal/compression/WALCompressionTest.java | 2 +- .../dataregion/wal/io/WALFileTest.java | 22 +- .../iotdb/db/tools/TsFileSelfCheckToolTest.java | 2 +- .../iotdb/db/tools/TsFileSketchToolTest.java | 2 +- .../org/apache/iotdb/db/tools/WalCheckerTest.java | 2 +- .../apache/iotdb/db/utils/EnvironmentUtils.java | 2 +- .../apache/iotdb/db/utils/OpenFileNumUtilTest.java | 2 +- .../db/utils/SchemaRegionSnapshotParserTest.java | 2 +- .../db/utils/datastructure/AlignedTVListTest.java | 2 +- .../db/utils/datastructure/BinaryTVListTest.java | 2 +- .../db/utils/datastructure/BooleanTVListTest.java | 2 +- .../db/utils/datastructure/DoubleTVListTest.java | 2 +- .../db/utils/datastructure/FloatTVListTest.java | 2 +- .../db/utils/datastructure/IntTVListTest.java | 2 +- .../db/utils/datastructure/LongTVListTest.java | 2 +- iotdb-core/node-commons/pom.xml | 16 - .../conf/iotdb-system.properties.template | 2 +- .../commons/auth/role/LocalFileRoleAccessor.java | 4 +- .../commons/auth/user/LocalFileUserAccessor.java | 4 +- .../apache/iotdb/commons/client/ThriftClient.java | 2 +- .../AsyncConfigNodeInternalServiceClient.java | 2 +- .../async/AsyncDataNodeExternalServiceClient.java | 2 +- .../async/AsyncDataNodeInternalServiceClient.java | 2 +- .../AsyncDataNodeMPPDataExchangeServiceClient.java | 2 +- .../async/AsyncPipeConsensusServiceClient.java | 2 +- .../async/AsyncPipeDataTransferServiceClient.java | 2 +- .../commons/executable/ExecutableManager.java | 17 +- .../commons/external/collections4/BidiMap.java | 138 ++++ .../external/collections4/IterableSortedMap.java | 30 + .../external/collections4/OrderedBidiMap.java | 51 ++ .../collections4/ResettableListIterator.java | 33 + .../external/collections4/SortedBidiMap.java | 59 ++ .../collections4/bidimap/AbstractDualBidiMap.java | 798 +++++++++++++++++++++ .../collections4/bidimap/DualTreeBidiMap.java | 414 +++++++++++ .../collection/AbstractCollectionDecorator.java | 182 +++++ .../iterators/AbstractIteratorDecorator.java | 46 ++ .../AbstractUntypedIteratorDecorator.java | 66 ++ .../iterators/ListIteratorWrapper.java | 274 +++++++ .../keyvalue/AbstractMapEntryDecorator.java | 92 +++ .../collections4/map/AbstractIterableMap.java | 36 + .../collections4/map/AbstractMapDecorator.java | 153 ++++ .../map/AbstractSortedMapDecorator.java | 166 +++++ .../map/EntrySetToMapIteratorAdapter.java | 110 +++ .../iotdb/commons/file/SystemFileFactory.java | 2 +- .../org/apache/iotdb/commons/path/PartialPath.java | 4 +- .../iotdb/commons/path/fa/dfa/graph/NFAGraph.java | 2 +- .../fa/dfa/transition/DFAWildcardTransition.java | 2 +- .../service/PipePluginExecutableManager.java | 2 +- .../commons/pipe/agent/task/PipeTaskAgent.java | 48 ++ .../commons/pipe/agent/task/meta/PipeTaskMeta.java | 39 +- .../pipe/config/constant/SystemConstant.java | 5 +- .../datastructure/pattern/PrefixTreePattern.java | 2 +- .../commons/pipe/receiver/IoTDBFileReceiver.java | 2 +- .../commons/pipe/receiver/IoTDBReceiverAgent.java | 2 +- .../viewExpression/leaf/ConstantViewOperand.java | 2 +- .../unary/RegularViewExpression.java | 2 +- .../meta/consumer/ConsumerGroupMeta.java | 3 +- .../relational/TableBuiltinScalarFunction.java | 36 + .../commons/udf/service/UDFExecutableManager.java | 2 +- .../org/apache/iotdb/commons/utils/FileUtils.java | 23 +- library-udf/pom.xml | 4 + pom.xml | 56 +- 459 files changed, 25336 insertions(+), 1366 deletions(-)
