This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a change to branch fix-audit-logger
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from c45305c46ca fix
add 72c3e915f70 Fixed the failure of IoTDBDistinctTagIT
add e188287645f fix: Handle NaN results in approx_percentile evaluation
add 9a25d725313 fix login locked error message (#16550)
add 76852612417 User userId to check whether the user is admin in
ConfigNode (#16554)
add db28f95e901 Add method to convert author type
add 26aa85378f5 Fix NPE for audit func. (#16556)
add a7e042fae03 fix: count device operation
add a3116f46591 Fix initial old password not encrypted & bump TsFile
Version (#16557)
add d6c2719f95a Fix that quotes cannot be passed to start-cli-table.bat
(#16558)
add 36f98a99910 encrypt audit log (#16551)
add 4256d38070d Add keystore truststore expire check and avoid unnecessary
error log printed (#16552)
add 38793052091 Fix UserLockInfo concurrency (#16559)
add 7110f166d64 Update keystore truststore for tests (#16561)
add 558839f3d59 Fix audit log for list user, role and privilege (#16562)
add 18964f41cda Patch for AUDIT privilege authentication on table model
(#16563)
add 2df8710feef Pipe: Cleaned some questionable parameters & Fixed
unstable testPipeAfterDataRegionLeaderStop (#16555)
add ea7e2a68b92 Fix cast of TimeColumn after deserialize
add d65fa92f563 Fix author type conversion (#16560)
add 5621279d5e2 Audit SQL 'COUNT DATABASE' (#16569)
add 629860ade15 fix: Updated TSFile version to fix Load failure in
creating aligned time series (#16502)
add e22a54f44b2 Pipe: Fixed the potential memory shortage may lead to
forever blocking (#16570)
add 006b6fc57d4 enable_grant_option first start take effect (#16572)
add c983221c6a7 Hide keystore truststore file name in logs (#16573)
add 41fd7b8cf4f [AINode] Modify timer_xl and sundial for
transformersv4.56.2 (#16568)
add be172fb23ea add encrypt param when constructing CompactionTsFileReader
(#16578)
add 32f287a400a Fix compatibility issues when loading snapshot in pipe.
(#16580)
add d289944750f Fixed lock error messages and default values in
LoginLockManager. Corrected table model unlock syntax. Resolved errors in
security administrator unlock functionality. (#16579)
add 2c6e5b83120 Fix rename user ConfigNode physical plan
serialize/deserialize NPE (#16582)
add 4c037e7df03 Pipe: Fixed the bug that mark-as-pipe-request may not be
of use in configNode events (#16581)
add a29bf52950e Pipe: Fixed the NPE bug in historical user parsing (#16584)
add b098e34d9c6 Pipe: Fixed the bug that the schema may be sent twice when
split-enabled & database may be null for non-first schema pipes (#16586)
add 867a457d8be Pipe: Stablized the table model IoTDBPipeSyntaxIT (#16585)
add d719d4651d8 Fix some data types are not supported in Mode
AggregationFunction
add a1c34887c3b [AINode] Code format
add 1d852bf406e [AINode] Reformat codebase
add 2a120776bce Don't print warn msg while meeting 400 (#16597)
add 2a591bd267b Pipe: Added parameter check to handshake of legacy
receiver (#16596)
add c72f67e80bf Pipe: Banned the audit / system DB from configNode sync
(#16592)
add 7db498025f0 Fix that ConcurrentLinkedDeque.removeIf is not actually
thread-safe (#16598)
add d49baf77096 Fix IoTDBClusterNodeShutdownHookIT (#16601)
add 8d933843dec Delete unused and vulnerable rpc interface (#16603)
add 46a0c6ac0b1 [AINode] Concurrent inference bug fix (#16595)
add 0d0b7d1e926 Fix aggregation query when device cross region in TreeModel
add fe96a5573dd Perfect implicit time process in first, last, first_by,
last_by of TableModel
add 2ae06e811bd Optimize memtable scan
add b20558f3158 Avoid NPE in the Procedure framework #16607
add 4e2b3b935a3 Set ExternalRPCService server connection with ssl no
timeout (#16617)
add dd4a21c76b2 Fix Cannot invoke
jdk.internal.platform.CgroupInfo.getMountPoint() issue in CI (#16621)
add 332ba5b56ed Pipe: support multiple path patterns under tree model
(#16575)
add 01ae4dcc481 Load: Deleted the unnecessary auto-creation (#16624)
add 09da138a93f Resolve the problem that it will execute endFile() twice
and generate an invalid wal file that… (#16627)
add 1ba2bb79c92 Resolve the situation where the field value contains
commas in line formatter. (#16609)
add aa560e7ddc5 No need to include http client in distribution (#16634)
add 07d457e36df Fix union when cross region or need mapping from child
input
add 9daaaa8687d fix/loginlockmgr-constructor (#16636)
add fd98737405c Delete concurrent-206 and checker-qual directly dependency
add 2c9064ff67c [AINode] Adjust the maximum inference input length (#16640)
add dbf55834d67 Refactored some dependencies
add 656b4fc1a85 Pipe: Fixed the semantics for new regions & realtime /
history only pipes (#16622)
add 9b0e48f2f42 Pipe: Fixed the shouldMarkAsPipeRequest for CreateTable
and AlterLogicalView Sync (#16619)
add a429dfcb3b6 Pipe: Implementing DisruptorQueue (#16639)
add bbe7882f297 Made the schemaRegionMap nonnull for SchemaEngine (#15775)
add ca85e803ecd Pipe: Add TsFile parsing with Mods function (#16540)
add e15fb6aa227 Refactored IoTDB codes (#16644)
add 8867ab60185 Revert "Refactored IoTDB codes (#16644)" (#16645)
add a527b929822 Set the parameter names from default_storage_group_level
to default_database_level (#16626)
add 70b964386f9 Push the aggregation node down the union node
add 25c86c26a69 reject grant/revoke author statement on audit database
add 7131dab25fd feat: Add 36 new built-in scalar functions about BLOB type
add 18cd382b186 Pipe: Fixed the potential NPE in receiver tablet
construction (#16648)
add c1580924bca Support built-in forecast function through UDTF for tree
model (#15682)
add 1e4238f6e32 Pipe: Deleted the reflection code of AtomicUpdater (#16663)
add 23b1313bad3 Fix group by time in tree model bug
add aa899ccf8f5 Pipe: Added log control for pipe receiver auth exception
(#16659)
add 74fe8e69c06 Fix some dependencies version fallback (#16664)
add 57fe5734dd3 Optimize the efficiency of DualKeyCacheImpl's mayEvict
(#16445)
add 37388a1d494 implement MergeUnion rule to flatten nested UnionNode
(#16657)
add 0cbe3e16abd Pipe: Add metrics for TsFile parsing to tablets (#16668)
add 51b112340bd Clarify the non-ssl client connects the ssl server error
log information (#16665)
add 2738e7afe91 Pipe: Fix HistoricalDataRegionTsFileAndDeletionSource
`double-living` parameter failure (#16667)
add 6f07e859d89 Fixed the bug that the user deletion may delete audit
TimeSeries (#16670)
add fe37a4b5779 Hide password related parameters in show configuration
result (#16675)
add f8ad340df55 Avoid throwing AuthException to the state machine (#16677)
add acaf594ab46 If the client input uses "-usessl", then force interactive
input of trustStore and trustStorePwd. (#16676)
add 993a7839133 Fix process logic of empty TsBlock in InputLayer of
TransformOperator (#16678)
add 26ca344925e Bump logback version to 1.3.16 (#16671)
add 274fc9ed443 Use the correct value in showConfiguration to override the
value read from the configuration file (#16681)
add e5a9799a49b Merge remote-tracking branch 'upstream/master' into
fix-audit-logger
add d22189ff3b3 fix
No new revisions were added by this update.
Summary of changes:
.github/workflows/cluster-it-1c1d.yml | 2 +-
.github/workflows/cluster-it-1c3d.yml | 2 +-
.github/workflows/daily-it.yml | 20 +-
.github/workflows/dependency-check.yml | 2 +-
.github/workflows/pipe-it.yml | 106 +-
.github/workflows/table-cluster-it-1c1d.yml | 2 +-
.github/workflows/table-cluster-it-1c3d.yml | 2 +-
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 | 23 +-
.../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 | 8 +-
.../constant/BuiltinAggregationFunctionEnum.java | 7 +-
.../BuiltinTimeSeriesGeneratingFunctionEnum.java | 1 +
.../itbase/runtime/ClusterTestConnection.java | 2 +-
.../ainode/it/AINodeConcurrentInferenceIT.java | 102 +-
.../iotdb/ainode/it/AINodeInferenceSQLIT.java | 4 +-
.../iotdb/auth/it/IoTDBLoginLockManagerIT.java | 6 +-
.../confignode/it/IoTDBConfigNodeSnapshotIT.java | 2 +-
.../it/cluster/IoTDBClusterNodeShutdownHookIT.java | 2 +-
.../org/apache/iotdb/db/it/IoTDBRestartIT.java | 2 +-
.../iotdb/db/it/IoTDBSetConfigurationIT.java | 10 +-
.../iotdb/db/it/aggregation/IoTDBModeIT.java | 24 +-
.../db/it/alignbydevice/IoTDBAlignByDevice2IT.java | 8 +-
.../db/it/alignbydevice/IoTDBAlignByDevice3IT.java | 8 +-
...ByDevice3IT.java => IoTDBAlignByDevice4IT.java} | 20 +-
.../db/it/alignbydevice/IoTDBAlignByDeviceIT.java | 34 +-
.../IoTDBAlignByDeviceWithTemplate2IT.java | 8 +-
...java => IoTDBAlignByDeviceWithTemplate3IT.java} | 21 +-
...DBAlignByDeviceWithTemplateAggregation2IT.java} | 23 +-
...oTDBAlignByDeviceWithTemplateAggregationIT.java | 4 +-
.../IoTDBAlignByDeviceWithTemplateIT.java | 11 +-
.../IoTDBOrderByLimitOffsetAlignByDevice2IT.java | 8 +-
...> IoTDBOrderByLimitOffsetAlignByDevice3IT.java} | 17 +-
.../IoTDBOrderByLimitOffsetAlignByDeviceIT.java | 4 +-
.../IoTDBOrderByWithAlignByDevice2IT.java | 8 +-
.../IoTDBOrderByWithAlignByDevice3IT.java | 8 +-
....java => IoTDBOrderByWithAlignByDevice4IT.java} | 19 +-
.../IoTDBOrderByWithAlignByDeviceIT.java | 4 +-
.../db/it/alignbydevice/IoTDBShuffleSink1IT.java | 8 +-
...ByDevice2IT.java => IoTDBShuffleSink1_2IT.java} | 27 +-
.../db/it/alignbydevice/IoTDBShuffleSink2IT.java | 10 +-
...ByDevice2IT.java => IoTDBShuffleSink2_2IT.java} | 29 +-
.../org/apache/iotdb/db/it/audit/AuditLogSet.java | 87 +
.../iotdb/db/it/audit/IoTDBAuditLogBasicIT.java | 3337 +++++++++++++-------
.../org/apache/iotdb/db/it/auth/IoTDBAuthIT.java | 52 +
.../iotdb/db/it/auth/IoTDBRelationalAuthIT.java | 37 +
.../apache/iotdb/db/it/auth/IoTDBUserRenameIT.java | 15 +-
.../iotdb/db/it/schema/IoTDBCountDeviceIT.java | 268 ++
.../it/udf/IoTDBUDFIntermediateBlockSerdeIT.java | 74 +
.../org/apache/iotdb/db/it/utils/TestUtils.java | 9 +
.../iotdb/it/framework/IoTDBTestListener.java | 2 +-
.../apache/iotdb/it/framework/IoTDBTestRunner.java | 3 +
.../pipe/it/dual/tablemodel/TableModelUtils.java | 33 +
.../manual/AbstractPipeTableModelDualManualIT.java | 1 -
.../manual/basic/IoTDBPipePermissionIT.java | 1 -
.../manual/basic/IoTDBPipeProtocolIT.java | 1 -
.../tablemodel/manual/basic/IoTDBPipeSourceIT.java | 1 -
.../tablemodel/manual/basic/IoTDBPipeSyntaxIT.java | 1 -
.../IoTDBPipeTsFileDecompositionWithModsIT.java | 192 ++
.../manual/basic/IoTDBPipeWithLoadIT.java | 1 -
.../manual/enhanced/IoTDBPipeAutoConflictIT.java | 1 -
.../manual/enhanced/IoTDBPipeClusterIT.java | 342 +-
.../IoTDBPipeTypeConversionISessionIT.java | 114 +-
.../auto/AbstractPipeDualTreeModelAutoIT.java | 1 -
.../treemodel/auto/basic/IoTDBPipeProcessorIT.java | 1 -
.../treemodel/auto/basic/IoTDBPipeProtocolIT.java | 1 -
.../treemodel/auto/basic/IoTDBPipeSourceIT.java | 1 -
.../auto/basic/IoTDBTreePatternFormatIT.java | 326 +-
.../auto/enhanced/IoTDBPipeAutoConflictIT.java | 1 -
.../auto/enhanced/IoTDBPipeIdempotentIT.java | 1 -
.../auto/enhanced/IoTDBPipeWithLoadIT.java | 1 -
.../manual/AbstractPipeDualTreeModelManualIT.java | 1 -
.../treemodel/manual/IoTDBPipeInclusionIT.java | 73 +-
.../manual/IoTDBPipeMetaHistoricalIT.java | 1 -
.../treemodel/manual/IoTDBPipePermissionIT.java | 1 -
.../IoTDBPipeTsFileDecompositionWithModsIT.java | 660 ++++
.../manual/IoTDBPipeTypeConversionISessionIT.java | 102 +-
.../AbstractPipeTripleManualIT.java} | 57 +-
.../iotdb/pipe/it/triple/IoTDBPipeForwardIT.java | 117 +
.../db/it/IoTDBMultiTAGsWithAttributesTableIT.java | 39 +-
.../it/query/old/orderBy/IoTDBOrderByTableIT.java | 2 +-
.../it/query/recent/IoTDBDistinctTagIT.java | 2 +
.../it/query/recent/IoTDBTableAggregationIT.java | 36 +-
.../it/query/recent/IoTDBUnionTable2IT.java} | 27 +-
.../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 +-
.../it/session/IoTDBSessionRelationalIT.java | 44 +-
.../session/it/IoTDBSessionSchemaTemplateIT.java | 4 -
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 2 +-
.../it/SkipOnSetUpAndTearDownFailure.java | 3 +-
.../org/apache/iotdb/util/AbstractSchemaIT.java | 2 +-
integration-test/src/test/resources/test-keystore | Bin 2429 -> 2710 bytes
.../src/test/resources/test-truststore | Bin 1149 -> 1238 bytes
iotdb-client/cli/pom.xml | 8 -
.../java/org/apache/iotdb/cli/AbstractCli.java | 21 +-
.../src/main/java/org/apache/iotdb/cli/Cli.java | 6 +-
.../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 +-
.../apache/iotdb/rpc/BaseRpcTransportFactory.java | 12 +-
.../iotdb/rpc/NettyTNonblockingTransport.java | 23 +-
.../apache/iotdb/rpc/TElasticFramedTransport.java | 53 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 2 +
iotdb-core/ainode/iotdb/__init__.py | 17 +
.../ainode/core/inference/batcher}/__init__.py | 0
.../core/inference/inference_request_pool.py | 22 +-
.../iotdb/ainode/core/inference/pool_controller.py | 21 +-
.../iotdb/ainode/core/inference/pool_group.py | 6 +
.../pool_scheduler/abstract_pool_scheduler.py | 9 +-
.../pool_scheduler/basic_pool_scheduler.py | 61 +-
.../iotdb/ainode/core/manager/inference_manager.py | 6 +-
.../iotdb/ainode/core/manager/model_manager.py | 3 +
.../iotdb/ainode/core/model/model_storage.py | 7 +
.../ainode/core/model/sundial/modeling_sundial.py | 80 +-
.../core/model/sundial/ts_generation_mixin.py | 14 +-
.../ainode/core/model/timerxl/modeling_timer.py | 77 +-
.../core/model/timerxl/ts_generation_mixin.py | 12 +-
iotdb-core/ainode/poetry.lock | 1841 +++++------
iotdb-core/ainode/pyproject.toml | 7 +-
iotdb-core/confignode/pom.xml | 16 -
.../confignode/conf/ConfigNodeRemoveCheck.java | 155 -
.../confignode/conf/SystemPropertiesUtils.java | 2 +
.../consensus/request/ConfigPhysicalPlan.java | 2 +
.../consensus/request/ConfigPhysicalPlanType.java | 2 +
.../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 +-
.../consensus/response/model/GetModelInfoResp.java | 8 -
.../iotdb/confignode/manager/ModelManager.java | 38 +-
.../load/cache/detector/PhiAccrualDetector.java | 14 +-
.../iotdb/confignode/manager/node/NodeManager.java | 1 +
.../manager/partition/PartitionManager.java | 8 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 108 +-
.../pipe/source/ConfigRegionListeningFilter.java | 20 +
.../pipe/source/ConfigRegionListeningQueue.java | 24 +-
.../pipe/source/IoTDBConfigRegionSource.java | 6 +-
.../source/PipeConfigTreePatternParseVisitor.java | 60 +-
.../iotdb/confignode/persistence/ModelInfo.java | 2 -
.../confignode/persistence/auth/AuthorInfo.java | 138 +-
.../persistence/auth/AuthorPlanExecutor.java | 11 +-
.../persistence/executor/ConfigPlanExecutor.java | 2 +
.../confignode/persistence/pipe/PipeTaskInfo.java | 14 +-
.../schema/CNPhysicalPlanGenerator.java | 21 +-
.../confignode/persistence/schema/ConfigMTree.java | 8 +-
.../persistence/schema/TemplateTable.java | 2 +-
.../procedure/impl/cq/CreateCQProcedure.java | 2 +-
.../impl/pipe/AbstractOperatePipeProcedureV2.java | 21 +
.../impl/pipe/task/AlterPipeProcedureV2.java | 45 +-
.../impl/schema/DeleteTimeSeriesProcedure.java | 4 +-
.../scheduler/AbstractProcedureScheduler.java | 2 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 50 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 31 +
.../PipeConfigTreePatternParseVisitorTest.java | 79 +-
.../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 +-
.../apache/iotdb/consensus/ratis/utils/Utils.java | 6 +
iotdb-core/datanode/pom.xml | 32 +-
.../src/main/codegen/templates/ModeAccumulator.ftl | 2 +-
.../org/apache/iotdb/db/audit/DNAuditLogger.java | 66 +-
.../org/apache/iotdb/db/auth/LoginLockManager.java | 68 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 61 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 89 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 6 +-
.../agent/runtime/SimpleProgressIndexAssigner.java | 2 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 34 +-
.../task/builder/PipeDataNodeTaskBuilder.java | 98 +-
.../agent/task/connection/PipeEventCollector.java | 4 +-
.../agent/task/subtask/sink/PipeSinkSubtask.java | 3 +
.../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 | 84 +-
.../parser/TsFileInsertionEventParserProvider.java | 27 +-
.../query/TsFileInsertionEventQueryParser.java | 113 +-
...ileInsertionEventQueryParserTabletIterator.java | 33 +-
.../scan/TsFileInsertionEventScanParser.java | 407 ++-
.../table/TsFileInsertionEventTableParser.java | 38 +-
...ileInsertionEventTableParserTabletIterator.java | 53 +-
.../tsfile/parser/util/ModsOperationUtil.java | 314 ++
.../overview/PipeTsFileToTabletsMetrics.java | 67 +
.../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 | 11 +-
.../pipeconsensus/PipeConsensusReceiver.java | 2 +-
.../pipeconsensus/PipeConsensusReceiverAgent.java | 2 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 26 +-
.../transform/converter/ValueConverter.java | 2 +-
.../visitor/PipeStatementTSStatusVisitor.java | 5 -
.../PipeStatementTreePatternParseVisitor.java | 30 +-
...leStatementDataTypeConvertExecutionVisitor.java | 5 +-
...eeStatementDataTypeConvertExecutionVisitor.java | 4 +-
...aNodeHardlinkOrCopiedFileDirStartupCleaner.java | 2 +-
.../db/pipe/resource/memory/PipeMemoryManager.java | 6 -
.../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 | 78 +-
...istoricalDataRegionTsFileAndDeletionSource.java | 43 +-
.../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} | 32 +-
.../realtime/disruptor/EventHandler.java} | 32 +-
.../realtime/disruptor/ExceptionHandler.java} | 32 +-
.../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 +-
.../schemaregion/IoTDBSchemaRegionSource.java | 7 +-
.../PipePlanTreePatternParseVisitor.java | 53 +-
.../db/protocol/mqtt/BrokerAuthenticator.java | 2 +-
.../db/protocol/mqtt/JSONPayloadFormatter.java | 2 +-
.../db/protocol/mqtt/LinePayloadFormatter.java | 15 +-
.../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 34 +-
.../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 | 10 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 75 +-
.../execution/aggregation/AccumulatorFactory.java | 8 +-
.../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 +-
.../fragment/FragmentInstanceContext.java | 20 +
.../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 +-
.../operator/schema/SchemaCountOperator.java | 54 +-
.../operator/schema/source/DeviceSchemaSource.java | 8 +
.../operator/schema/source/ISchemaSource.java | 4 +
.../execution/operator/source/SeriesScanUtil.java | 65 +-
.../AbstractApproxPercentileAccumulator.java | 13 +-
...AbstractGroupedApproxPercentileAccumulator.java | 13 +-
.../execution/operator/window/SessionWindow.java | 13 +-
.../execution/operator/window/TimeWindow.java | 9 +-
.../relational/ColumnTransformerBuilder.java | 328 ++
.../queryengine/plan/analyze/AnalyzeVisitor.java | 10 +-
.../plan/analyze/ExpressionAnalyzer.java | 4 +-
.../db/queryengine/plan/analyze/ModelFetcher.java | 23 +-
.../db/queryengine/plan/analyze/TemplatedInfo.java | 6 +-
.../analyze/cache/partition/PartitionCache.java | 2 +-
.../schema/dualkeycache/impl/DualKeyCacheImpl.java | 6 +-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 2 +-
.../analyze/load/LoadTsFileTableSchemaCache.java | 3 +-
.../load/TreeSchemaAutoCreatorAndVerifier.java | 4 +
.../config/executor/ClusterConfigTaskExecutor.java | 26 +-
.../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 +-
.../expression/visitor/ConcatDeviceVisitor.java} | 22 +-
.../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 | 45 +-
.../plan/planner/TableOperatorGenerator.java | 20 +-
.../plan/planner/TemplatedLogicalPlan.java | 2 +-
.../distribution/DistributionPlanContext.java | 2 +-
.../planner/distribution/DistributionPlanner.java | 2 +-
.../plan/planner/distribution/SourceRewriter.java | 76 +-
.../plan/AbstractFragmentParallelPlanner.java | 2 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 4 +-
.../planner/plan/node/process/AggregationNode.java | 2 +-
.../planner/plan/node/process/GroupByTagNode.java | 2 +-
.../plan/node/process/RawDataAggregationNode.java | 2 +-
.../plan/node/source/LastQueryScanNode.java | 2 +-
.../node/source/SeriesAggregationSourceNode.java | 4 +-
.../planner/plan/parameter/IntoPathDescriptor.java | 2 +-
.../parameter/model/ModelInferenceDescriptor.java | 5 +-
.../function/tvf/ForecastTableFunction.java | 14 +-
.../relational/metadata/TableMetadataImpl.java | 469 ++-
.../planner/distribute/SubPlanGenerator.java | 2 +-
.../distribute/TableDistributedPlanGenerator.java | 96 +-
.../planner/iterative/rule/MergeUnion.java | 48 +
.../planner/iterative/rule/SetOperationMerge.java | 144 +
.../relational/planner/node/SetOperationNode.java | 4 +-
.../plan/relational/planner/node/UnionNode.java | 31 +-
.../optimizations/LogicalOptimizeFactory.java | 15 +-
.../relational/security/AccessControlImpl.java | 52 +-
.../relational/security/ITableAuthCheckerImpl.java | 39 +-
.../security/TreeAccessCheckVisitor.java | 55 +-
.../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/sql/parser/AstBuilder.java | 42 +-
.../plan/relational/type/AuthorRType.java | 5 +
.../plan/relational/type/CompatibleResolver.java | 5 +
.../plan/scheduler/AsyncSendPlanNodeHandler.java | 2 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 2 +-
.../scheduler/load/LoadTsFileDispatcherImpl.java | 2 +-
.../db/queryengine/plan/statement/AuthorType.java | 106 +-
.../db/queryengine/plan/statement/Statement.java | 4 +
.../statement/component/GroupByTagComponent.java | 2 +-
.../plan/statement/component/IntoItem.java | 2 +-
.../crud/InsertMultiTabletsStatement.java | 8 +
.../plan/statement/crud/InsertRowStatement.java | 24 +
.../plan/statement/crud/InsertRowsStatement.java | 5 +
.../plan/statement/crud/InsertTabletStatement.java | 51 +-
.../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} | 19 +-
.../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} | 19 +-
.../dag/column/unary/scalar/util/HexUtils.java | 86 +
.../unary/scalar/util/SpookyHashV2Utils.java | 603 ++++
.../unary/scalar/util/TransformerDebugUtils.java | 62 +
.../dag/input/QueryDataSetInputLayer.java | 10 +-
.../dag/intermediate/MultiInputLayer.java | 35 +-
.../SingleInputMultiReferenceLayer.java | 27 +-
.../SingleInputSingleReferenceLayer.java | 27 +-
.../transformation/dag/udf/UDTFExecutor.java | 2 +-
.../transformation/dag/util/LayerCacheUtils.java | 5 +-
.../transformation/datastructure/TVColumns.java | 7 +-
.../tv/ElasticSerializableBinaryTVList.java | 3 +-
.../datastructure/tv/SerializableTVList.java | 6 +-
.../apache/iotdb/db/schemaengine/SchemaEngine.java | 27 +-
.../impl/mem/snapshot/MemMTreeSnapshotUtil.java | 6 +-
.../schemaengine/schemaregion/tag/TagLogFile.java | 2 +-
.../schemaengine/schemaregion/tag/TagManager.java | 2 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 4 +
.../iotdb/db/service/ExternalRPCService.java | 1 -
.../org/apache/iotdb/db/service/RestService.java | 2 +-
.../db/service/TemporaryQueryDataFileService.java | 2 +-
.../iotdb/db/storageengine/StorageEngine.java | 2 +-
.../db/storageengine/dataregion/DataRegion.java | 11 +-
.../exception/CompactionExceptionHandler.java | 2 +-
.../constant/CrossCompactionPerformer.java | 16 +
.../constant/InnerSeqCompactionPerformer.java | 16 +
.../constant/InnerUnseqCompactionPerformer.java | 16 +
.../performer/impl/FastCompactionPerformer.java | 42 +-
.../impl/ReadChunkCompactionPerformer.java | 48 +-
.../impl/ReadPointCompactionPerformer.java | 53 +-
.../RepairUnsortedFileCompactionPerformer.java | 14 +-
.../execute/recover/CompactionRecoverTask.java | 2 +-
.../task/RepairUnsortedFileCompactionTask.java | 7 +-
.../task/subtask/ReadPointPerformerSubTask.java | 8 +-
.../execute/utils/MultiTsFileDeviceIterator.java | 10 +-
...BatchedFastAlignedSeriesCompactionExecutor.java | 8 +-
...edReadChunkAlignedSeriesCompactionExecutor.java | 9 +-
.../FirstBatchCompactionAlignedChunkWriter.java | 51 +-
...FollowingBatchCompactionAlignedChunkWriter.java | 16 +-
.../fast/FastAlignedSeriesCompactionExecutor.java | 6 +-
.../FastNonAlignedSeriesCompactionExecutor.java | 8 +-
.../readchunk/AlignedSeriesCompactionExecutor.java | 5 +-
.../ReadChunkAlignedSeriesCompactionExecutor.java | 4 +-
.../readchunk/SingleSeriesCompactionExecutor.java | 9 +-
.../utils/writer/AbstractCompactionWriter.java | 5 +
.../writer/AbstractCrossCompactionWriter.java | 23 +-
.../writer/AbstractInnerCompactionWriter.java | 30 +-
.../utils/writer/FastCrossCompactionWriter.java | 16 +-
.../utils/writer/FastInnerCompactionWriter.java | 20 +-
.../writer/ReadPointCrossCompactionWriter.java | 14 +-
.../writer/ReadPointInnerCompactionWriter.java | 20 +-
.../writer/RepairUnsortedFileCompactionWriter.java | 12 +-
.../compaction/io/CompactionTsFileReader.java | 17 +-
.../compaction/io/CompactionTsFileWriter.java | 19 +-
.../compaction/repair/RepairDataFileScanUtil.java | 4 +-
.../schedule/CompactionScheduleContext.java | 23 +-
.../compaction/schedule/CompactionScheduler.java | 7 +-
.../estimator/AbstractCompactionEstimator.java | 2 +-
.../estimator/AbstractCrossSpaceEstimator.java | 6 +-
.../estimator/AbstractInnerSpaceEstimator.java | 11 +-
.../estimator/CompactionEstimateUtils.java | 6 +-
.../utils/CrossSpaceCompactionCandidate.java | 1 +
.../compaction/settle/SettleRequestHandler.java | 13 +-
.../compaction/tool/TsFileStatisticReader.java | 6 +-
.../dataregion/flush/CompressionRatio.java | 2 +-
.../dataregion/memtable/AbstractMemTable.java | 10 +-
.../memtable/AbstractWritableMemChunk.java | 4 +
.../memtable/AlignedWritableMemChunk.java | 36 +-
.../memtable/AlignedWritableMemChunkGroup.java | 9 +
.../dataregion/memtable/IWritableMemChunk.java | 3 +
.../memtable/IWritableMemChunkGroup.java | 3 +
.../dataregion/memtable/TsFileProcessor.java | 7 +-
.../dataregion/memtable/WritableMemChunk.java | 25 +-
.../dataregion/memtable/WritableMemChunkGroup.java | 19 +-
.../dataregion/read/control/FileReaderManager.java | 13 +-
.../read/reader/chunk/MemAlignedPageReader.java | 3 +
.../read/reader/chunk/MemPageReader.java | 3 +
.../read/reader/common/NoDataPointReader.java} | 41 +-
.../dataregion/snapshot/SnapshotLoader.java | 2 +-
.../dataregion/utils/TsFileResourceUtils.java | 6 +-
.../dataregion/wal/io/CheckpointReader.java | 6 +
.../dataregion/wal/io/WALInputStream.java | 14 +-
.../storageengine/dataregion/wal/io/WALWriter.java | 4 +
.../file/AbstractTsFileRecoverPerformer.java | 21 +-
.../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 +-
.../db/tools/schema/SRStatementGenerator.java | 4 +-
.../iotdb/db/tools/utils/TsFileSequenceScan.java | 7 +-
.../trigger/service/TriggerManagementService.java | 2 +-
.../org/apache/iotdb/db/utils/CommonUtils.java | 2 +-
.../apache/iotdb/db/utils/DataNodeAuthUtils.java | 6 +-
.../org/apache/iotdb/db/utils/EncryptDBUtils.java | 86 +
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 2 +-
.../db/utils/datastructure/AlignedTVList.java | 100 +-
.../iotdb/db/utils/datastructure/LazyBitMap.java | 93 +
.../db/utils/datastructure/MemPointIterator.java | 3 +
.../MergeSortMultiAlignedTVListIterator.java | 22 +
.../MergeSortMultiTVListIterator.java | 22 +
.../OrderedMultiAlignedTVListIterator.java | 24 +
.../datastructure/OrderedMultiTVListIterator.java | 24 +
.../iotdb/db/utils/datastructure/TVList.java | 229 +-
.../apache/iotdb/db/auth/LoginLockManagerTest.java | 106 +-
.../auth/authorizer/LocalFileAuthorizerTest.java | 2 +-
.../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 +++
.../PipeStatementTreePatternParseVisitorTest.java | 46 +-
.../db/pipe/source/IoTDBDataRegionSourceTest.java | 2 +
.../PipePlanTreePatternParseVisitorTest.java | 256 +-
.../source/SchemaRegionListeningQueueTest.java | 2 +-
.../execution/exchange/SharedTsBlockQueueTest.java | 2 +-
.../execution/operator/TransformOperatorTest.java | 142 +
.../load/TimeseriesMetadataIteratorTest.java | 173 +
.../plan/relational/analyzer/MergeUnionTest.java | 98 +
.../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 +-
.../memtable/AlignedTVListIteratorTest.java | 110 +
.../memtable/NonAlignedTVListIteratorTest.java | 87 +
.../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/authorizer/BasicAuthorizer.java | 26 +-
.../iotdb/commons/auth/authorizer/IAuthorizer.java | 2 -
.../auth/authorizer/LocalFileAuthorizer.java | 5 -
.../commons/auth/authorizer/OpenIdAuthorizer.java | 1 -
.../commons/auth/role/LocalFileRoleAccessor.java | 4 +-
.../iotdb/commons/auth/user/BasicUserManager.java | 9 +
.../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 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 63 +-
.../iotdb/commons/conf/CommonDescriptor.java | 3 +-
.../iotdb/commons/conf/ConfigurationFileUtils.java | 75 +-
.../exception/pipe/PipeNonReportException.java} | 14 +-
.../pipe/PipeRuntimeSinkCriticalException.java | 2 +-
...RuntimeSinkRetryTimesConfigurableException.java | 6 +
.../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 +-
.../commons/file/SystemPropertiesHandler.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 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 53 +-
.../iotdb/commons/pipe/config/PipeDescriptor.java | 20 +-
.../pipe/config/constant/SystemConstant.java | 5 +-
.../datastructure/pattern/IoTDBTreePattern.java | 9 +-
.../datastructure/pattern/PrefixTreePattern.java | 4 +-
.../datastructure/pattern/SingleTreePattern.java} | 47 +-
.../pipe/datastructure/pattern/TreePattern.java | 185 +-
.../pattern/UnionIoTDBTreePattern.java | 161 +
.../datastructure/pattern/UnionTreePattern.java | 95 +
.../listening/AbstractPipeListeningQueue.java | 10 +-
.../commons/pipe/receiver/IoTDBFileReceiver.java | 2 +-
.../commons/pipe/receiver/IoTDBReceiverAgent.java | 2 +-
.../pipe/receiver/PipeReceiverStatusHandler.java | 4 +-
.../pipe/source/IoTDBNonDataRegionSource.java | 19 +-
.../iotdb/commons/schema/SchemaConstant.java | 6 +-
.../schema/column/ColumnHeaderConstant.java | 4 +-
.../iotdb/commons/schema/template/Template.java | 2 +-
.../viewExpression/leaf/ConstantViewOperand.java | 2 +-
.../unary/RegularViewExpression.java | 2 +-
.../service/AbstractThriftServiceThread.java | 45 +-
.../iotdb/commons/service/ThriftServiceThread.java | 3 +-
.../iotdb/commons/service/metric/enums/Metric.java | 3 +
.../meta/consumer/ConsumerGroupMeta.java | 3 +-
.../relational/TableBuiltinScalarFunction.java | 36 +
.../commons/udf/service/UDFExecutableManager.java | 2 +-
.../org/apache/iotdb/commons/utils/FileUtils.java | 23 +-
.../db/relational/grammar/sql/RelationalSql.g4 | 16 +-
.../src/main/thrift/confignode.thrift | 11 +-
.../thrift-datanode/src/main/thrift/client.thrift | 18 -
library-udf/pom.xml | 2 +
pom.xml | 59 +-
scripts/sbin/windows/start-cli-table.bat | 12 +-
731 files changed, 35066 insertions(+), 5362 deletions(-)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/alignbydevice/{IoTDBAlignByDevice3IT.java
=> IoTDBAlignByDevice4IT.java} (58%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/alignbydevice/{IoTDBAlignByDeviceWithTemplate2IT.java
=> IoTDBAlignByDeviceWithTemplate3IT.java} (59%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/alignbydevice/{IoTDBOrderByLimitOffsetAlignByDevice2IT.java
=> IoTDBAlignByDeviceWithTemplateAggregation2IT.java} (56%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/alignbydevice/{IoTDBOrderByLimitOffsetAlignByDevice2IT.java
=> IoTDBOrderByLimitOffsetAlignByDevice3IT.java} (64%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/alignbydevice/{IoTDBOrderByWithAlignByDevice2IT.java
=> IoTDBOrderByWithAlignByDevice4IT.java} (58%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/alignbydevice/{IoTDBOrderByLimitOffsetAlignByDevice2IT.java
=> IoTDBShuffleSink1_2IT.java} (51%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/alignbydevice/{IoTDBOrderByLimitOffsetAlignByDevice2IT.java
=> IoTDBShuffleSink2_2IT.java} (50%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/audit/AuditLogSet.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/schema/IoTDBCountDeviceIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/udf/IoTDBUDFIntermediateBlockSerdeIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeTsFileDecompositionWithModsIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/manual/IoTDBPipeTsFileDecompositionWithModsIT.java
copy
integration-test/src/test/java/org/apache/iotdb/pipe/it/{dual/tablemodel/manual/AbstractPipeTableModelDualManualIT.java
=> triple/AbstractPipeTripleManualIT.java} (57%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/triple/IoTDBPipeForwardIT.java
copy
integration-test/src/test/java/org/apache/iotdb/{db/it/alignbydevice/IoTDBAlignByDevice2IT.java
=> relational/it/query/recent/IoTDBUnionTable2IT.java} (51%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBCRC32FunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBFromBase32ColumnFunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBFromBase64ColumnFunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBFromBase64UrlColumnFunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBFromBigEndian32FunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBFromBigEndian64FunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBFromHexColumnFunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBFromIEEE754_32FunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBFromIEEE754_64FunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBFromLittleEndian32FunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBFromLittleEndian64FunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBHmacMd5FunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBHmacSha1FunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBHmacSha256FunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBHmacSha512FunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBLpadFunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBMd5ColumnFunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBMurmur3ColumnFunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBReverseFunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBRpadFunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBSha1ColumnFunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBSha256ColumnFunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBSha512ColumnFunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBSpookyHashV2_32FunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBSpookyHashV2_64FunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBToBase32ColumnFunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBToBase64ColumnFunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBToBase64UrlColumnFunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBToBigEndian32FunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBToBigEndian64FunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBToHexColumnFunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBToIEEE754_32FunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBToIEEE754_64FunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBToLittleEndian32FunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBToLittleEndian64FunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBXXHash64ColumnFunctionIT.java
copy {iotdb-client/client-py/iotdb =>
iotdb-core/ainode/iotdb/ainode/core/inference/batcher}/__init__.py (100%)
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeRemoveCheck.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/parser/util/ModsOperationUtil.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/disruptor/BatchEventProcessor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/disruptor/Disruptor.java
copy
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/exception/pipe/PipeRuntimeSinkRetryTimesConfigurableException.java
=>
datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/disruptor/EventFactory.java}
(64%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{exception/metadata/AlignedTimeseriesException.java
=> pipe/source/dataregion/realtime/disruptor/EventHandler.java} (55%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{exception/metadata/AlignedTimeseriesException.java
=> pipe/source/dataregion/realtime/disruptor/ExceptionHandler.java} (52%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/disruptor/MultiProducerSequencer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/disruptor/RingBuffer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/disruptor/Sequence.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/disruptor/SequenceBarrier.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/disruptor/SequenceGroups.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/MappingCollectOperator.java
copy
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/exception/pipe/PipeRuntimeSinkRetryTimesConfigurableException.java
=>
datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/expression/visitor/ConcatDeviceVisitor.java}
(58%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/MergeUnion.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/SetOperationMerge.java
rename
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin =>
datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/udf}/BuiltinAggregationFunction.java
(98%)
rename
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin =>
datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/udf}/BuiltinScalarFunction.java
(97%)
rename
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin =>
datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/udf}/BuiltinTimeSeriesGeneratingFunction.java
(65%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/udf/UDTFForecast.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/binary/HmacColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/binary/factory/HmacStrategiesFactory.java
copy
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/exception/pipe/PipeRuntimeSinkRetryTimesConfigurableException.java
=>
datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/binary/strategies/HmacStrategy.java}
(66%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/ternary/LpadColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/ternary/RpadColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/ternary/utils/BytePaddingUtils.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/BytesToDoubleColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/BytesToFloatColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/BytesToIntColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/BytesToLongColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/CRC32Transformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/DoubleToBytesColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/FloatToBytesColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/GenericCodecColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/HmacConstantKeyColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/IntToBytesColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/LongToBytesColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/factory/CodecStrategiesFactory.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/factory/NumericCodecStrategiesFactory.java
copy
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/exception/pipe/PipeRuntimeSinkRetryTimesConfigurableException.java
=>
datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/inteface/CodecStrategy.java}
(66%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/util/HexUtils.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/util/SpookyHashV2Utils.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/util/TransformerDebugUtils.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{pipe/source/dataregion/realtime/assigner/DisruptorQueueExceptionHandler.java
=> storageengine/dataregion/read/reader/common/NoDataPointReader.java} (51%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/EncryptDBUtils.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/datastructure/LazyBitMap.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/event/common/tsfile/parser/util/ModsOperationUtilTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/TransformOperatorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/analyze/load/TimeseriesMetadataIteratorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/MergeUnionTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/PushAggregationThroughUnionTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/binary/hmac/HmacMd5ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/binary/hmac/HmacSha1ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/binary/hmac/HmacSha256ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/binary/hmac/HmacSha512ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/ternary/LpadColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/ternary/RpadColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/IntegerEncoding/FromBigEndian32ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/IntegerEncoding/FromBigEndian64ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/IntegerEncoding/FromIEEE754_32BigEndianColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/IntegerEncoding/FromIEEE754_64BigEndianColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/IntegerEncoding/FromLittleEndian32ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/IntegerEncoding/FromLittleEndian64ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/IntegerEncoding/ToBigEndian32ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/IntegerEncoding/ToBigEndian64ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/IntegerEncoding/ToIEEE754_32BigEndianColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/IntegerEncoding/ToIEEE754_64BigEndianColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/IntegerEncoding/ToLittleEndian32ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/IntegerEncoding/ToLittleEndian64ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/ReverseColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/base64Encoding/FromBase32ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/base64Encoding/FromBase64ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/base64Encoding/FromBase64UrlColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/base64Encoding/ToBase32ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/base64Encoding/ToBase64ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/base64Encoding/ToBase64UrlColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/hashing/Crc32ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/hashing/Md5ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/hashing/Murmur3ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/hashing/Sha1ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/hashing/Sha256ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/hashing/Sha512ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/hashing/SpookyHashV2_32ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/hashing/SpookyHashV2_64ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/hashing/XxHash64ColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/hexEncoding/FromHexColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/hexEncoding/ToHexColumnTransformerTest.java
rename
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/exception/metadata/AlignedTimeseriesException.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/exception/pipe/PipeNonReportException.java}
(65%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/BidiMap.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/IterableSortedMap.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/OrderedBidiMap.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/ResettableListIterator.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/SortedBidiMap.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/bidimap/AbstractDualBidiMap.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/bidimap/DualTreeBidiMap.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/collection/AbstractCollectionDecorator.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/iterators/AbstractIteratorDecorator.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/iterators/AbstractUntypedIteratorDecorator.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/iterators/ListIteratorWrapper.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/keyvalue/AbstractMapEntryDecorator.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/map/AbstractIterableMap.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/map/AbstractMapDecorator.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/map/AbstractSortedMapDecorator.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/map/EntrySetToMapIteratorAdapter.java
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/{path/fa/dfa/transition/DFAWildcardTransition.java
=> pipe/datastructure/pattern/SingleTreePattern.java} (50%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/pattern/UnionIoTDBTreePattern.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/pattern/UnionTreePattern.java
