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