This is an automated email from the ASF dual-hosted git repository.
ColinLeeo pushed a change to branch fix/table-udf-result-chunking
in repository https://gitbox.apache.org/repos/asf/iotdb.git
omit ce8dbea3b31 Remove redundant table UDF type list copy
omit 8f594888446 Harden table UDF result splitting lifecycle
omit 03b243239cf Reuse AbstractOperator for table UDF result splitting
omit 40eed71fd33 Remove redundant table UDF split condition
omit 608536ee1e8 Clarify table UDF result size accounting
omit dfa312d2d36 Estimate table UDF result blocks by memory size
omit 2962df6729f Optimize table UDF result block splitting
omit 507ab082551 Fix table UDF result splitting after pass-through
omit 8b9f1d23a7e Fix table UDF result block splitting
add a321fa34d5d Subscription: preserve topic updates during owner transfer
(#18353)
add 154644107a8 Pipe: Respect history enable with source time range
(#18362)
add 75eaa40744b Fix race condition in ExternalTsFileQueryResource
reference counting (#18371)
add 09252d40064 feat(load): reject managed TsFile directories (#18271)
add d82806fa208 Subscription: Rename topic modes to initial and
incremental (#18370)
add 157efaef283 Use provider-compatible file deletion and truncation APIs
(#18349)
add cc583ca61b0 Fix query analyze metric of TableModel
add 83d536aa17d [Fix] Keep heartbeat alive when metadata lease is fenced
(#18343)
add e23500e1a10 Support rate family aggregation functions in table model
(#18334)
add cde1601d17d [Pipe] Batch OPC UA sink writes (#18380) (#18384)
add bee70a863b4 Fix IndexOutOfBoundsException caused by concurrent sort
and delete on TVList (#18389)
add f6a844d8191 Query: Optimize schema traversal for non-leading tag IN
predicates (#18369)
add 303686e8604 Pipe: Add receiver session authentication integration
tests (#18395)
add d37536bc0ca Fix table UDF result block splitting
add 210f3de71c9 Fix table UDF result splitting after pass-through
add f04184766e0 Optimize table UDF result block splitting
add 27b36d91df3 Estimate table UDF result blocks by memory size
add 117b54a5bf3 Clarify table UDF result size accounting
add 34503f3ba9a Remove redundant table UDF split condition
add 8e493dfc090 Reuse AbstractOperator for table UDF result splitting
add 2e58a212863 Harden table UDF result splitting lifecycle
add afecd840dd0 Remove redundant table UDF type list copy
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (ce8dbea3b31)
\
N -- N -- N refs/heads/fix/table-udf-result-chunking
(afecd840dd0)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.../ConsensusSubscriptionWalFileAnalyzer.java | 5 +-
.../iotdb/ConsensusSubscriptionSessionExample.java | 2 +-
...sensusTableModelSubscriptionSessionExample.java | 2 +-
.../org/apache/iotdb/it/env/cluster/EnvUtils.java | 9 +-
.../iotdb/it/env/cluster/env/AbstractEnv.java | 9 +-
.../org/apache/iotdb/db/it/IoTDBLoadTsFileIT.java | 22 +
.../treemodel/auto/basic/IoTDBPipeSourceIT.java | 60 +++
.../auto/basic/IoTDBPipeTwoStageAggregateIT.java | 146 ++++++
.../IoTDBLegacyPipeReceiverAutoCreateIT.java | 159 ++++++
.../single/IoTDBLegacyPipeReceiverSecurityIT.java | 148 ++++++
.../pipe/it/single/IoTDBPipeReceiverSessionIT.java | 281 ++++++++++
.../it/query/recent/IoTDBTableAggregationIT.java | 564 ++++++++++++++++++++-
.../local/ConsensusSubscriptionITSupport.java | 2 +-
.../ConsensusSubscriptionTableITSupport.java | 2 +-
...ConsensusSubscriptionColumnFilterClusterIT.java | 2 +-
.../IoTDBSubscriptionColumnFilterIT.java | 5 +-
.../tablemodel/IoTDBSubscriptionPermissionIT.java | 2 +-
.../IoTDBAllTsDatasetPullConsumerIT.java | 2 +-
.../IoTDBAllTsTsfilePullConsumerIT.java | 2 +-
.../IoTDBPathDeviceDataSetPullConsumerIT.java | 2 +-
.../IoTDBPathDeviceTsfilePullConsumerIT.java | 2 +-
.../IoTDBTimeTsDatasetPullConsumerIT.java | 2 +-
.../IoTDBTimeTsTsfilePullConsumerIT.java | 2 +-
.../IoTDBLooseAllTsDatasetPushConsumerIT.java | 4 +-
.../IoTDBLooseAllTsfilePushConsumerIT.java | 4 +-
.../IoTDBPathLooseDeviceTsfilePushConsumerIT.java | 2 +-
.../IoTDBPathLooseTsDatasetPushConsumerIT.java | 2 +-
.../IoTDBPathLooseTsfilePushConsumerIT.java | 2 +-
.../IoTDBPathTsLooseDatasetPushConsumerIT.java | 2 +-
.../IoTDBTimeLooseTsDatasetPushConsumerIT.java | 4 +-
.../IoTDBTimeLooseTsTsfilePushConsumerIT.java | 4 +-
.../IoTDBTimeLooseTsfilePushConsumerIT.java | 2 +-
.../IoTDBTimeTsLooseDatasetPushConsumerIT.java | 4 +-
.../subscription/i18n/SubscriptionMessages.java | 2 +-
.../subscription/i18n/SubscriptionMessages.java | 2 +-
.../iotdb/rpc/subscription/config/TopicConfig.java | 51 +-
.../rpc/subscription/config/TopicConstant.java | 19 +-
.../base/AbstractSubscriptionConsumer.java | 2 +-
.../rpc/subscription/config/TopicConfigTest.java | 57 +++
.../org/apache/iotdb/calc/i18n/CalcMessages.java | 60 +++
.../org/apache/iotdb/calc/i18n/CalcMessages.java | 60 +++
.../relational/aggregation/AccumulatorFactory.java | 141 +++++-
.../rate/AbstractGroupedDeltaAccumulator.java | 138 +++++
.../rate/AbstractGroupedIncreaseAccumulator.java | 147 ++++++
.../rate/AbstractGroupedIrateAccumulator.java | 83 +++
.../rate/AbstractGroupedRateAccumulator.java | 150 ++++++
.../grouped/rate/GroupedNaiveDeltaAccumulator.java | 141 ++++++
.../rate/GroupedNaiveIncreaseAccumulator.java | 151 ++++++
.../grouped/rate/GroupedNaiveIrateAccumulator.java | 120 +++++
.../grouped/rate/GroupedNaiveRateAccumulator.java | 148 ++++++
.../rate/GroupedOrderedDeltaAccumulator.java | 159 ++++++
.../rate/GroupedOrderedIncreaseAccumulator.java | 167 ++++++
.../rate/GroupedOrderedIrateAccumulator.java | 143 ++++++
.../rate/GroupedOrderedRateAccumulator.java | 164 ++++++
.../grouped/rate/TimeValueBufferBigArray.java | 75 +++
.../rate/AbstractDeltaTableAccumulator.java | 109 ++++
.../rate/AbstractIncreaseTableAccumulator.java | 118 +++++
.../rate/AbstractIrateTableAccumulator.java | 78 +++
.../rate/AbstractRateTableAccumulator.java | 121 +++++
.../aggregation/rate/ExtrapolationUtil.java | 139 +++++
.../aggregation/rate/NaiveDeltaAccumulator.java | 155 ++++++
.../aggregation/rate/NaiveIncreaseAccumulator.java | 171 +++++++
.../aggregation/rate/NaiveIrateAccumulator.java | 143 ++++++
.../aggregation/rate/NaiveRateAccumulator.java | 163 ++++++
.../aggregation/rate/OrderedDeltaAccumulator.java | 143 ++++++
.../rate/OrderedIncreaseAccumulator.java | 150 ++++++
.../aggregation/rate/OrderedIrateAccumulator.java | 133 +++++
.../aggregation/rate/OrderedRateAccumulator.java | 147 ++++++
.../rate/RateFunctionIntermediateStateCodec.java | 201 ++++++++
.../aggregation/rate/RateFunctionType.java | 28 +-
.../aggregation/rate/RateFunctionValidation.java | 119 +++++
.../aggregation/rate/TimeValueBuffer.java | 228 +++++++++
.../calc/plan/planner/TableOperatorGenerator.java | 4 +
.../datastructure/SerializableList.java | 28 +-
.../iotdb/calc/utils/constant/SqlConstant.java | 4 +
.../rate/GroupedRateAccumulatorMemoryTest.java | 91 ++++
.../aggregation/rate/ExtrapolationUtilTest.java | 65 +++
.../rate/RateAccumulatorFactoryTest.java | 178 +++++++
.../RateFunctionIntermediateStateCodecTest.java | 152 ++++++
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 7 +-
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 7 +-
.../iotdb/confignode/manager/ProcedureManager.java | 40 +-
.../subscription/SubscriptionCoordinator.java | 69 ++-
.../runtime/SubscriptionRuntimeCoordinator.java | 2 +-
.../confignode/persistence/ProcedureInfo.java | 40 +-
.../confignode/persistence/node/NodeInfo.java | 3 +-
.../persistence/partition/PartitionInfo.java | 3 +-
.../persistence/schema/ClusterSchemaInfo.java | 3 +-
.../persistence/schema/TemplatePreSetTable.java | 3 +-
.../persistence/schema/TemplateTable.java | 3 +-
.../persistence/subscription/SubscriptionInfo.java | 44 +-
.../SubscriptionHandleLeaderChangeProcedure.java | 2 +-
.../subscription/CreateSubscriptionProcedure.java | 2 +-
.../subscription/DropSubscriptionProcedure.java | 2 +-
.../subscription/topic/AlterTopicProcedure.java | 66 ++-
.../procedure/store/ProcedureFactory.java | 7 +-
.../confignode/procedure/store/ProcedureType.java | 1 +
.../confignode/procedure/store/ProcedureWAL.java | 10 +-
.../writelog/io/SingleFileLogReader.java | 8 +-
.../subscription/SubscriptionCoordinatorTest.java | 152 ++++++
.../SubscriptionInfoTopicValidationTest.java | 103 ++--
.../topic/AlterTopicProcedureTest.java | 82 ++-
.../consensus/iot/IoTConsensusServerImpl.java | 7 +-
.../ratis/ApplicationStateMachineProxy.java | 12 +-
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 13 +-
.../iotdb/db/i18n/DataNodeQueryMessages.java | 7 +
.../iotdb/db/i18n/DataNodeSchemaMessages.java | 3 +
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 13 +-
.../iotdb/db/i18n/DataNodeQueryMessages.java | 7 +
.../iotdb/db/i18n/DataNodeSchemaMessages.java | 3 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 22 +
.../deletion/persist/PageCacheDeletionBuffer.java | 22 +-
.../consensus/deletion/recover/DeletionReader.java | 7 +-
.../iotconsensusv2/IoTConsensusV2Receiver.java | 3 +-
.../protocol/legacy/loader/TsFileLoader.java | 2 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 2 +-
...aNodeHardlinkOrCopiedFileDirStartupCleaner.java | 4 +-
.../batch/PipeTabletEventTsFileBatch.java | 3 +-
.../protocol/opcua/client/IoTDBOpcUaClient.java | 175 +++++--
.../thrift/async/IoTDBDataRegionAsyncSink.java | 5 +-
.../util/builder/PipeTableModelTsFileBuilder.java | 9 +-
.../builder/PipeTableModelTsFileBuilderV2.java | 8 +-
.../util/builder/PipeTreeModelTsFileBuilder.java | 6 +-
.../util/builder/PipeTreeModelTsFileBuilderV2.java | 5 +-
.../pipe/sink/util/builder/PipeTsFileBuilder.java | 20 +-
.../source/dataregion/IoTDBDataRegionSource.java | 8 +-
...istoricalDataRegionTsFileAndDeletionSource.java | 27 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 31 +-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 25 +-
.../queryengine/plan/execution/QueryExecution.java | 4 +
.../config/executor/ClusterConfigTaskExecutor.java | 2 +-
.../plan/relational/analyzer/Analyzer.java | 2 +-
.../read_tsfile/ExternalTsFileQueryResource.java | 4 +-
.../relational/metadata/TableMetadataImpl.java | 49 ++
.../distribute/TableDistributedPlanGenerator.java | 74 ++-
.../PushAggregationIntoTableScan.java | 18 +
.../plan/relational/sql/ast/LoadTsFile.java | 22 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 9 +-
.../plan/statement/crud/LoadTsFileStatement.java | 67 ++-
.../apache/iotdb/db/schemaengine/SchemaEngine.java | 28 +-
.../schemaregion/logfile/SchemaLogReader.java | 14 +-
.../schemaregion/logfile/SchemaLogWriter.java | 28 +-
.../mtree/impl/pbtree/schemafile/SchemaFile.java | 21 +-
.../pbtree/schemafile/log/SchemaFileLogReader.java | 3 +-
.../pbtree/schemafile/pagemgr/PageIOChannel.java | 12 +-
.../schemaregion/mtree/traverser/Traverser.java | 6 +
.../schemaengine/schemaregion/tag/TagManager.java | 4 +-
.../db/storageengine/dataregion/DataRegion.java | 2 +-
.../dataregion/flush/CompressionRatio.java | 5 +-
.../modification/v1/ModificationFileV1.java | 4 +-
.../v1/io/LocalTextModificationAccessor.java | 37 +-
.../dataregion/tsfile/TsFileResource.java | 2 +-
.../FileTimeIndexCacheWriter.java | 30 +-
.../storageengine/dataregion/wal/io/LogWriter.java | 12 +-
.../storageengine/dataregion/wal/node/WALNode.java | 2 +-
.../file/AbstractTsFileRecoverPerformer.java | 2 +-
...leStatementDataTypeConvertExecutionVisitor.java | 12 +-
...eeStatementDataTypeConvertExecutionVisitor.java | 12 +-
.../rescon/disk/DirectoryChecker.java | 36 +-
.../agent/SubscriptionBrokerAgent.java | 5 +-
.../ConsensusSubscriptionCommitManager.java | 17 +-
.../ConsensusSubscriptionSetupHandler.java | 12 +-
.../batch/SubscriptionPipeTsFileEventBatch.java | 3 +-
.../org/apache/iotdb/db/utils/ObjectWriter.java | 31 +-
.../db/utils/datastructure/AlignedTVList.java | 31 +-
.../iotdb/db/utils/datastructure/TVList.java | 8 +-
.../apache/iotdb/db/utils/writelog/LogWriter.java | 25 +-
.../SchemaRegionTableDevicePerformanceTest.java | 335 ++++++++++++
.../opcua/client/IoTDBOpcUaClientTest.java | 176 +++++++
...ricalDataRegionTsFileAndDeletionSourceTest.java | 36 ++
.../metadata/fetcher/SchemaPredicateUtilTest.java | 125 +++++
.../planner/AggregationNodeRateSerdeTest.java | 92 ++++
.../TableDistributedPlanGeneratorRateTest.java | 124 +++++
.../statement/crud/LoadTsFileStatementTest.java | 60 +++
.../DataNodeInternalRPCServiceImplTest.java | 73 +++
.../commons/auth/role/LocalFileRoleAccessor.java | 5 +-
.../commons/auth/user/LocalFileUserAccessor.java | 3 +-
.../commons/executable/ExecutableManager.java | 14 +-
.../commons/file/SystemPropertiesHandler.java | 8 +-
.../iotdb/commons/path/ExtendedPartialPath.java | 34 +-
.../apache/iotdb/commons/path/fa/IPatternFA.java | 8 +
.../iotdb/commons/path/fa/nfa/SimpleNFA.java | 102 +++-
.../queue/serializer/PlainQueueSerializer.java | 32 +-
.../commons/pipe/receiver/IoTDBFileReceiver.java | 7 +-
.../relational/planner/node/AggregationNode.java | 33 +-
.../schema/filter/impl/DeviceFilterUtil.java | 261 +++++++++-
.../commons/schema/tree/AbstractTreeVisitor.java | 79 ++-
.../TableBuiltinAggregationFunction.java | 11 +-
.../org/apache/iotdb/commons/utils/FileUtils.java | 17 +-
.../org/apache/iotdb/commons/utils/IOUtils.java | 2 +-
.../schema/filter/impl/DeviceFilterUtilTest.java | 385 ++++++++++++++
.../apache/iotdb/commons/utils/FileUtilsTest.java | 10 +
.../thrift-commons/src/main/thrift/common.thrift | 4 +
pom.xml | 28 +
.../main/forbidden-apis/secure-erase | 24 +-
195 files changed, 9769 insertions(+), 592 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeTwoStageAggregateIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/single/IoTDBLegacyPipeReceiverAutoCreateIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/single/IoTDBPipeReceiverSessionIT.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/rate/AbstractGroupedDeltaAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/rate/AbstractGroupedIncreaseAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/rate/AbstractGroupedIrateAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/rate/AbstractGroupedRateAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/rate/GroupedNaiveDeltaAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/rate/GroupedNaiveIncreaseAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/rate/GroupedNaiveIrateAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/rate/GroupedNaiveRateAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/rate/GroupedOrderedDeltaAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/rate/GroupedOrderedIncreaseAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/rate/GroupedOrderedIrateAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/rate/GroupedOrderedRateAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/rate/TimeValueBufferBigArray.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/AbstractDeltaTableAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/AbstractIncreaseTableAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/AbstractIrateTableAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/AbstractRateTableAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/ExtrapolationUtil.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/NaiveDeltaAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/NaiveIncreaseAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/NaiveIrateAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/NaiveRateAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/OrderedDeltaAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/OrderedIncreaseAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/OrderedIrateAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/OrderedRateAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/RateFunctionIntermediateStateCodec.java
copy
integration-test/src/main/java/org/apache/iotdb/itbase/constant/BuiltinScalarFunctionEnum.java
=>
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/RateFunctionType.java
(63%)
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/RateFunctionValidation.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/TimeValueBuffer.java
create mode 100644
iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/rate/GroupedRateAccumulatorMemoryTest.java
create mode 100644
iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/ExtrapolationUtilTest.java
create mode 100644
iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/RateAccumulatorFactoryTest.java
create mode 100644
iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/RateFunctionIntermediateStateCodecTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/subscription/SubscriptionCoordinatorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/metadata/schemaRegion/SchemaRegionTableDevicePerformanceTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/client/IoTDBOpcUaClientTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/fetcher/SchemaPredicateUtilTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/AggregationNodeRateSerdeTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/distribute/TableDistributedPlanGeneratorRateTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/schema/filter/impl/DeviceFilterUtilTest.java
copy iotdb-client/jdbc/osgi.bnd => src/main/forbidden-apis/secure-erase (67%)
