This is an automated email from the ASF dual-hosted git repository.
Caideyipi pushed a change to branch last-cache-fix
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 47f7180db2e Refactor
add da7056f7777 [IOTDB-17635] Fix window function identity with OVER
clause (#17645)
add e9584eced72 Pipe: Fixed the remaining correctness bug for PR 17661 &&
the replication configuration of IoTDBPipeReceiverAutoCreateDisabledIT (#17678)
add f76571d52b7 Fix snapshot load region replacement (#17684)
add 3145e839f88 Speed up ITs by sharing the cluster across test methods
(#17682)
add e81a4325bde Fix wrong metric name in NetMetrics.unbindFrom for
transmitted bytes (#17688)
add f797f8507a3 feat: add compile-time i18n for log and exception messages
(#17613)
add 2f57fd6270a Speed up AINode CI by consolidating tests and caching
PyInstaller output (#17687)
add 81cab405fd7 Shard Windows IT jobs to speed up 1C1D and Table 1C1D CI
(#17692)
add 9330c7fc0b4 Shard 5 dual-cluster jobs to speed up Multi-Cluster IT
(#17695)
add 1e945dd3a99 Gracefully manage async client threads (#17683)
add 754e500d23c Speed up Codecov CI ~38% with parallel surefire forks
(#17697)
add 402e399ea2e Run datanode unit tests with surefire forkCount=4 (#17698)
add e9087317fc4 Add AGENTS symlink (#17701)
add 4ac0b7ee029 fix error remove type (#17689)
add a8303a5b5e7 Merge branch 'master' of https://github.com/apache/iotdb
into last-cache-fix
No new revisions were added by this update.
Summary of changes:
.github/workflows/cluster-it-1c1d.yml | 80 +-
.github/workflows/compile-check.yml | 4 +
.github/workflows/pipe-it.yml | 115 +-
.github/workflows/sonar-codecov.yml | 2 +-
.github/workflows/table-cluster-it-1c1d.yml | 80 +-
.github/workflows/unit-test.yml | 9 +-
AGENTS.md | 1 +
CLAUDE.md | 8 +
README.md | 10 +
README_ZH.md | 10 +
external-service-impl/mqtt/pom.xml | 4 +
.../org/apache/iotdb/mqtt/i18n/MqttMessages.java | 54 +
.../org/apache/iotdb/mqtt/i18n/MqttMessages.java | 54 +
.../apache/iotdb/mqtt/JSONPayloadFormatter.java | 4 +-
.../apache/iotdb/mqtt/LinePayloadFormatter.java | 12 +-
.../org/apache/iotdb/mqtt/MPPPublishHandler.java | 7 +-
.../java/org/apache/iotdb/mqtt/MQTTService.java | 7 +-
.../apache/iotdb/mqtt/PayloadFormatManager.java | 15 +-
external-service-impl/rest/pom.xml | 4 +
.../org/apache/iotdb/rest/i18n/RestMessages.java | 30 +-
.../org/apache/iotdb/rest/i18n/RestMessages.java | 30 +-
.../java/org/apache/iotdb/rest/RestService.java | 7 +-
.../v1/handler/StatementConstructionHandler.java | 4 +-
.../v1/handler/StatementConstructionHandler.java | 4 +-
.../v2/handler/RequestValidationHandler.java | 3 +-
.../v2/handler/StatementConstructionHandler.java | 4 +-
.../iotdb/ainode/it/AINodeCallInferenceIT.java | 135 --
.../iotdb/ainode/it/AINodeClusterConfigIT.java | 71 +-
.../iotdb/ainode/it/AINodeDeviceManageIT.java | 96 -
.../apache/iotdb/ainode/it/AINodeForecastIT.java | 195 --
.../ainode/it/AINodeInstanceManagementIT.java | 179 --
.../iotdb/ainode/it/AINodeModelManageIT.java | 215 ---
.../iotdb/ainode/it/AINodeSharedClusterIT.java | 552 ++++++
.../apache/iotdb/db/it/GrafanaApiServiceIT.java | 100 +-
.../apache/iotdb/db/it/IoTDBDatetimeFormatIT.java | 90 +-
.../apache/iotdb/db/it/IoTDBDuplicateTimeIT.java | 12 +-
.../apache/iotdb/db/it/IoTDBExecuteBatchIT.java | 263 +--
.../iotdb/db/it/IoTDBInsertWithoutTimeIT.java | 56 +-
.../iotdb/db/it/IoTDBLoadTsFileWithModIT.java | 190 +-
.../org/apache/iotdb/db/it/IoTDBMultiDeviceIT.java | 12 +-
.../iotdb/db/it/IoTDBPartialInsertionIT.java | 236 +--
.../org/apache/iotdb/db/it/IoTDBRestServiceIT.java | 821 +++++----
.../org/apache/iotdb/db/it/IoTDBSimpleQueryIT.java | 1938 +++++++++++---------
.../iotdb/db/it/IoTDBSimpleQueryStandaloneIT.java | 12 +-
.../db/it/IoTDBSyntaxConventionIdentifierIT.java | 643 ++++---
.../it/IoTDBSyntaxConventionStringLiteralIT.java | 683 +++----
.../org/apache/iotdb/db/it/IoTDBTimeZoneIT.java | 14 +-
.../it/aggregation/IoTDBAggregationDeleteIT.java | 14 +-
.../db/it/aligned/IoTDBAlignedMemQueryIT.java | 12 +-
.../db/it/aligned/IoTDBInsertAlignedValues2IT.java | 193 +-
.../db/it/aligned/IoTDBInsertAlignedValues3IT.java | 12 +-
.../db/it/aligned/IoTDBInsertAlignedValues4IT.java | 12 +-
.../db/it/aligned/IoTDBInsertAlignedValuesIT.java | 553 +++---
.../iotdb/db/it/auth/IoTDBClusterAuthorityIT.java | 12 +-
.../it/auth/IoTDBClusterAuthorityRelationalIT.java | 12 +-
.../iotdb/db/it/auth/IoTDBGrantOptionIT.java | 12 +-
.../iotdb/db/it/auth/IoTDBRelationalAuthIT.java | 1092 ++++++-----
.../iotdb/db/it/auth/IoTDBSeriesPermissionIT.java | 138 +-
.../db/it/auth/IoTDBTemplatePermissionIT.java | 222 ++-
.../db/it/fill/IoTDBFillWithNewDataTypeIT.java | 14 +-
.../db/it/fill/IoTDBFillWithThresholdInMSIT.java | 14 +-
.../db/it/fill/IoTDBFillWithThresholdInNSIT.java | 14 +-
.../db/it/fill/IoTDBFillWithThresholdInUSIT.java | 14 +-
.../iotdb/db/it/mqtt/IoTDBMQTTServiceJsonIT.java | 43 +-
.../db/it/schema/IoTDBSortedShowTimeseriesIT.java | 14 +-
.../db/it/specialwords/IoTDBSpecialWordsIT.java | 12 +-
.../db/it/strangepath/IoTDBStrangePathIT.java | 12 +-
.../db/it/trigger/IoTDBTriggerManagementIT.java | 713 +++----
.../iotdb/db/it/udaf/IoTDBUDAFManagementIT.java | 204 ++-
.../iotdb/db/it/udf/IoTDBUDFManagementIT.java | 241 +--
.../IoTDBPipeReceiverAutoCreateDisabledIT.java | 17 +-
.../it/db/it/IoTDBWindowFunction3IT.java | 19 +
iotdb-api/pipe-api/pom.xml | 8 +
.../iotdb/pipe/api/i18n/PipeApiMessages.java | 10 +-
.../iotdb/pipe/api/i18n/PipeApiMessages.java | 10 +-
.../parameter/PipeParameterValidator.java | 4 +-
iotdb-api/trigger-api/pom.xml | 8 +
.../iotdb/trigger/api/i18n/TriggerApiMessages.java | 20 +-
.../iotdb/trigger/api/i18n/TriggerApiMessages.java | 23 +-
.../iotdb/trigger/api/enums/FailureStrategy.java | 4 +-
.../iotdb/trigger/api/enums/TriggerEvent.java | 5 +-
.../iotdb/trigger/api/enums/TriggerType.java | 5 +-
iotdb-api/udf-api/pom.xml | 8 +
.../apache/iotdb/udf/api/i18n/UdfApiMessages.java | 77 +
.../apache/iotdb/udf/api/i18n/UdfApiMessages.java | 76 +
.../analysis/AggregateFunctionAnalysis.java | 4 +-
.../analysis/ScalarFunctionAnalysis.java | 4 +-
.../api/customizer/config/UDFConfigurations.java | 3 +-
.../api/customizer/config/UDTFConfigurations.java | 3 +-
.../strategy/SlidingTimeWindowAccessStrategy.java | 7 +-
.../relational/table/MapTableFunctionHandle.java | 7 +-
.../table/TableFunctionProcessorProvider.java | 7 +-
.../api/relational/table/argument/Argument.java | 4 +-
.../relational/table/argument/DescribedSchema.java | 3 +-
.../relational/table/argument/ScalarArgument.java | 7 +-
.../relational/table/argument/TableArgument.java | 3 +-
.../specification/ParameterSpecification.java | 4 +-
.../java/org/apache/iotdb/udf/api/type/Type.java | 4 +-
.../org/apache/iotdb/udf/api/utils/RowImpl.java | 17 +-
iotdb-client/cli/pom.xml | 4 +
.../en/org/apache/iotdb/cli/i18n/CliMessages.java | 70 +
.../zh/org/apache/iotdb/cli/i18n/CliMessages.java | 70 +
.../java/org/apache/iotdb/cli/AbstractCli.java | 3 +-
.../org/apache/iotdb/cli/utils/CliContext.java | 3 +-
.../iotdb/tool/backup/IoTDBDataBackTool.java | 41 +-
.../apache/iotdb/tool/data/AbstractDataTool.java | 3 +-
.../org/apache/iotdb/tool/data/ImportData.java | 17 +-
.../org/apache/iotdb/tool/schema/ExportSchema.java | 3 +-
.../iotdb/tool/schema/ExportSchemaTable.java | 3 +-
.../apache/iotdb/tool/schema/ExportSchemaTree.java | 3 +-
.../iotdb/tool/schema/ImportSchemaTable.java | 3 +-
.../apache/iotdb/tool/schema/ImportSchemaTree.java | 3 +-
.../iotdb/tool/tsfile/AbstractTsFileTool.java | 3 +-
.../iotdb/tool/tsfile/ImportTsFileRemotely.java | 3 +-
iotdb-client/isession/pom.xml | 8 +
.../iotdb/isession/i18n/ISessionMessages.java | 19 +-
.../iotdb/isession/i18n/ISessionMessages.java | 19 +-
.../org/apache/iotdb/isession/SessionDataSet.java | 5 +-
.../apache/iotdb/isession/template/Template.java | 5 +-
.../org/apache/iotdb/jdbc/i18n/JdbcMessages.java | 184 ++
.../org/apache/iotdb/jdbc/i18n/JdbcMessages.java | 184 ++
.../main/java/org/apache/iotdb/jdbc/Constant.java | 4 +-
.../iotdb/jdbc/GroupedLSBWatermarkEncoder.java | 6 +-
.../iotdb/jdbc/IoTDBAbstractDatabaseMetadata.java | 43 +-
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 68 +-
.../org/apache/iotdb/jdbc/IoTDBDataSource.java | 6 +-
.../apache/iotdb/jdbc/IoTDBDataSourceFactory.java | 4 +-
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 9 +-
.../java/org/apache/iotdb/jdbc/IoTDBDriver.java | 6 +-
.../org/apache/iotdb/jdbc/IoTDBJDBCResultSet.java | 7 +-
.../apache/iotdb/jdbc/IoTDBPreparedStatement.java | 11 +-
.../org/apache/iotdb/jdbc/IoTDBResultMetadata.java | 8 +-
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 44 +-
.../iotdb/jdbc/IoTDBTablePreparedStatement.java | 19 +-
.../org/apache/iotdb/jdbc/IoTDBTracingInfo.java | 5 +-
.../java/org/apache/iotdb/jdbc/StringUtils.java | 6 +-
.../IoTDBRelationalDatabaseMetadata.java | 5 +-
iotdb-client/service-rpc/pom.xml | 4 +
.../en/org/apache/iotdb/rpc/i18n/RpcMessages.java | 82 +
.../zh/org/apache/iotdb/rpc/i18n/RpcMessages.java | 70 +
.../apache/iotdb/rpc/BaseRpcTransportFactory.java | 4 +-
.../apache/iotdb/rpc/ConfigurableTByteBuffer.java | 6 +-
.../org/apache/iotdb/rpc/IoTDBJDBCDataSet.java | 18 +-
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 19 +-
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 5 +-
.../org/apache/iotdb/rpc/SynchronizedHandler.java | 6 +-
.../apache/iotdb/rpc/TElasticFramedTransport.java | 21 +-
.../iotdb/rpc/stmt/PreparedParameterSerde.java | 8 +-
iotdb-client/session/pom.xml | 4 +
.../apache/iotdb/session/i18n/SessionMessages.java | 262 +++
.../apache/iotdb/session/i18n/SessionMessages.java | 261 +++
.../org/apache/iotdb/session/NodesSupplier.java | 5 +-
.../java/org/apache/iotdb/session/Session.java | 64 +-
.../apache/iotdb/session/SessionConnection.java | 20 +-
.../org/apache/iotdb/session/ThriftConnection.java | 3 +-
.../org/apache/iotdb/session/pool/SessionPool.java | 295 +--
.../iotdb/session/template/InternalNode.java | 3 +-
.../apache/iotdb/session/util/SessionUtils.java | 3 +-
iotdb-client/subscription/pom.xml | 8 +
.../subscription/i18n/SubscriptionMessages.java | 95 +
.../subscription/i18n/SubscriptionMessages.java | 95 +
.../rpc/subscription/config/ConsumerConstant.java | 4 +-
.../rpc/subscription/config/TopicConstant.java | 4 +-
.../payload/poll/SubscriptionPollRequest.java | 6 +-
.../payload/poll/SubscriptionPollResponse.java | 6 +-
.../base/AbstractSubscriptionConsumer.java | 14 +-
.../base/AbstractSubscriptionProviders.java | 11 +-
.../base/AbstractSubscriptionPullConsumer.java | 9 +-
.../base/AbstractSubscriptionPushConsumer.java | 9 +-
.../base/SubscriptionExecutorServiceManager.java | 16 +-
.../session/subscription/util/IdentifierUtils.java | 7 +-
.../iotdb/session/subscription/util/PollTimer.java | 4 +-
iotdb-core/ainode/build_binary.py | 115 +-
iotdb-core/calc-commons/pom.xml | 4 +
.../org/apache/iotdb/calc/i18n/CalcMessages.java | 154 ++
.../org/apache/iotdb/calc/i18n/CalcMessages.java | 146 ++
.../calc/execution/operator/AbstractOperator.java | 13 +-
.../operator/process/AbstractSortOperator.java | 5 +-
.../operator/process/FilterAndProjectOperator.java | 3 +-
.../execution/operator/process/TopKOperator.java | 5 +-
.../function/TableFunctionLeafOperator.java | 5 +-
.../operator/process/function/partition/Slice.java | 7 +-
.../process/join/merge/MergeSortComparator.java | 4 +-
.../merge/comparator/JoinKeyComparatorFactory.java | 4 +-
.../rowpattern/PatternPartitionExecutor.java | 3 +-
.../rowpattern/expression/ArithmeticOperator.java | 10 +-
.../rowpattern/expression/CastComputation.java | 3 +-
.../rowpattern/expression/ComparisonOperator.java | 5 +-
.../process/rowpattern/expression/Computation.java | 7 +-
.../rowpattern/expression/LogicalOperator.java | 6 +-
.../expression/PatternExpressionComputation.java | 4 +-
.../matcher/IrRowPatternToProgramRewriter.java | 6 +-
.../process/rowpattern/matcher/Matcher.java | 3 +-
.../process/window/TopKRankingOperator.java | 5 +-
.../process/window/partition/Partition.java | 3 +-
.../window/partition/PartitionExecutor.java | 3 +-
.../process/window/partition/frame/FrameInfo.java | 6 +-
.../window/partition/frame/GroupsFrame.java | 5 +-
.../process/window/partition/frame/RangeFrame.java | 29 +-
.../process/window/partition/frame/RowsFrame.java | 5 +-
.../operator/process/window/utils/ColumnList.java | 4 +-
.../relational/aggregation/AccumulatorFactory.java | 18 +-
.../ApproxPercentileWithWeightAccumulator.java | 21 +-
.../aggregation/CountAllAccumulator.java | 5 +-
.../relational/aggregation/CountIfAccumulator.java | 5 +-
.../relational/aggregation/RecordIterator.java | 7 +-
.../relational/aggregation/TableAccumulator.java | 5 +-
.../UserDefinedAggregateFunctionAccumulator.java | 7 +-
.../aggregation/approximate/HyperLogLog.java | 3 +-
.../aggregation/approximate/TDigest.java | 11 +-
...oupedApproxPercentileWithWeightAccumulator.java | 21 +-
.../GroupedUserDefinedAggregateAccumulator.java | 4 +-
.../grouped/array/IntArrayFIFOQueue.java | 7 +-
.../grouped/array/LongBigArrayFIFOQueue.java | 5 +-
.../relational/ColumnTransformerBuilder.java | 11 +-
.../schedule/queue/IndexedBlockingQueue.java | 4 +-
.../queue/IndexedBlockingReserveQueue.java | 6 +-
.../calc/plan/planner/CommonOperatorUtils.java | 6 +-
.../calc/plan/planner/TableOperatorGenerator.java | 23 +-
.../planner/CastToBlobLiteralVisitor.java | 3 +-
.../planner/CastToBooleanLiteralVisitor.java | 3 +-
.../planner/CastToDateLiteralVisitor.java | 3 +-
.../planner/CastToDoubleLiteralVisitor.java | 3 +-
.../planner/CastToFloatLiteralVisitor.java | 3 +-
.../planner/CastToInt32LiteralVisitor.java | 3 +-
.../planner/CastToInt64LiteralVisitor.java | 3 +-
.../planner/CastToStringLiteralVisitor.java | 3 +-
.../planner/CastToTimestampLiteralVisitor.java | 3 +-
.../ir/GlobalTimePredicateExtractVisitor.java | 3 +-
.../AbstractTemporaryQueryDataFileService.java | 9 +-
.../column/TreeCaseWhenThenColumnTransformer.java | 4 +-
.../binary/ArithmeticBinaryColumnTransformer.java | 3 +-
.../binary/CompareBinaryColumnTransformer.java | 3 +-
.../binary/CompareEqualToColumnTransformer.java | 3 +-
.../binary/CompareNonEqualColumnTransformer.java | 3 +-
.../binary/LogicBinaryColumnTransformer.java | 3 +-
.../multi/LogicalMultiColumnTransformer.java | 3 +-
.../dag/column/unary/InColumnTransformer.java | 9 +-
.../column/unary/scalar/ExtractTransformer.java | 3 +-
.../unary/scalar/RoundColumnTransformer.java | 3 +-
.../scalar/factory/CodecStrategiesFactory.java | 9 +-
.../dag/column/unary/scalar/util/HexUtils.java | 5 +-
.../unary/scalar/util/SpookyHashV2Utils.java | 11 +-
.../transformation/dag/util/CastFunctionUtils.java | 4 +-
.../dag/util/CommonTransformUtils.java | 3 +-
.../transformation/dag/util/InputRowUtils.java | 4 +-
.../row/ElasticSerializableRowList.java | 3 +-
.../datastructure/row/SerializableRowList.java | 3 +-
.../tv/ElasticSerializableBinaryTVList.java | 3 +-
.../datastructure/tv/SerializableTVList.java | 3 +-
.../apache/iotdb/calc/utils/ObjectTypeUtils.java | 7 +-
.../iotdb/calc/utils/sort/SortBufferManager.java | 3 +-
iotdb-core/confignode/pom.xml | 25 +
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 525 ++++++
.../iotdb/confignode/i18n/ManagerMessages.java | 528 ++++++
.../iotdb/confignode/i18n/ProcedureMessages.java | 1090 +++++++++++
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 521 ++++++
.../iotdb/confignode/i18n/ManagerMessages.java | 523 ++++++
.../iotdb/confignode/i18n/ProcedureMessages.java | 1088 +++++++++++
.../async/AsyncAINodeHeartbeatClientPool.java | 15 +-
.../async/AsyncConfigNodeHeartbeatClientPool.java | 15 +-
.../async/AsyncDataNodeHeartbeatClientPool.java | 28 +-
.../CnToDnInternalServiceAsyncRequestManager.java | 4 +-
.../rpc/CheckTimeSeriesExistenceRPCHandler.java | 14 +-
.../handlers/rpc/ConfigNodeTSStatusRPCHandler.java | 6 +-
.../rpc/CountPathsUsingTemplateRPCHandler.java | 14 +-
.../handlers/rpc/DataNodeTSStatusRPCHandler.java | 6 +-
.../rpc/FetchSchemaBlackListRPCHandler.java | 12 +-
.../rpc/GetBuiltInExternalServiceRPCHandler.java | 3 +-
.../handlers/rpc/PipeHeartbeatRPCHandler.java | 5 +-
.../async/handlers/rpc/PipePushMetaRPCHandler.java | 6 +-
.../async/handlers/rpc/SchemaUpdateRPCHandler.java | 10 +-
.../handlers/rpc/TransferLeaderRPCHandler.java | 6 +-
.../rpc/TreeDeviceViewFieldDetectionHandler.java | 6 +-
.../CheckSchemaRegionUsingTemplateRPCHandler.java | 13 +-
.../ConsumerGroupPushMetaRPCHandler.java | 6 +-
.../rpc/subscription/TopicPushMetaRPCHandler.java | 6 +-
.../client/sync/SyncAINodeClientPool.java | 20 +-
.../client/sync/SyncConfigNodeClientPool.java | 12 +-
.../client/sync/SyncDataNodeClientPool.java | 26 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 3 +-
.../confignode/conf/ConfigNodeDescriptor.java | 41 +-
.../confignode/conf/ConfigNodeStartupCheck.java | 42 +-
.../confignode/conf/SystemPropertiesUtils.java | 11 +-
.../consensus/request/ConfigPhysicalPlan.java | 7 +-
.../pipe/task/OperateMultiplePipesPlanV2.java | 6 +-
.../statemachine/ConfigRegionStateMachine.java | 54 +-
.../iotdb/confignode/manager/ClusterManager.java | 5 +-
.../iotdb/confignode/manager/ConfigManager.java | 38 +-
.../confignode/manager/PermissionManager.java | 11 +-
.../iotdb/confignode/manager/ProcedureManager.java | 66 +-
.../confignode/manager/RetryFailedTasksThread.java | 5 +-
.../iotdb/confignode/manager/TTLManager.java | 7 +-
.../iotdb/confignode/manager/TriggerManager.java | 10 +-
.../iotdb/confignode/manager/UDFManager.java | 14 +-
.../manager/consensus/ConsensusManager.java | 16 +-
.../iotdb/confignode/manager/cq/CQManager.java | 10 +-
.../confignode/manager/cq/CQScheduleTask.java | 22 +-
.../externalservice/ExternalServiceInfo.java | 10 +-
.../externalservice/ExternalServiceManager.java | 13 +-
.../manager/load/balancer/PartitionBalancer.java | 11 +-
.../manager/load/balancer/RouteBalancer.java | 25 +-
.../partition/DataPartitionPolicyTable.java | 5 +-
.../region/GreedyRegionGroupAllocator.java | 3 +-
.../PartiteGraphPlacementRegionGroupAllocator.java | 4 +-
.../router/leader/AbstractLeaderBalancer.java | 13 +-
.../confignode/manager/load/cache/LoadCache.java | 15 +-
.../load/cache/detector/PhiAccrualDetector.java | 7 +-
.../load/cache/node/DataNodeHeartbeatCache.java | 3 +-
.../manager/load/service/EventService.java | 23 +-
.../manager/load/service/HeartbeatService.java | 5 +-
.../manager/load/service/StatisticsService.java | 5 +-
.../manager/load/service/TopologyService.java | 9 +-
.../iotdb/confignode/manager/node/NodeManager.java | 41 +-
.../manager/partition/PartitionManager.java | 27 +-
.../manager/partition/PartitionMetrics.java | 7 +-
.../partition/RegionGroupExtensionPolicy.java | 4 +-
.../manager/partition/RegionGroupStatus.java | 5 +-
.../agent/runtime/PipeConfigNodeRuntimeAgent.java | 11 +-
.../pipe/agent/task/PipeConfigNodeSubtask.java | 11 +-
.../pipe/agent/task/PipeConfigNodeTaskAgent.java | 10 +-
.../pipe/agent/task/PipeConfigNodeTaskStage.java | 5 +-
.../coordinator/plugin/PipePluginCoordinator.java | 8 +-
.../pipe/coordinator/runtime/PipeMetaSyncer.java | 22 +-
.../runtime/heartbeat/PipeHeartbeatParser.java | 16 +-
.../runtime/heartbeat/PipeHeartbeatScheduler.java | 11 +-
.../pipe/coordinator/task/PipeTaskCoordinator.java | 16 +-
.../coordinator/task/PipeTaskCoordinatorLock.java | 23 +-
.../pipe/event/PipeConfigRegionSnapshotEvent.java | 3 +-
.../event/PipeConfigSerializableEventType.java | 3 +-
.../PipeConfigNodeRemainingTimeMetrics.java | 10 +-
.../pipe/metric/overview/PipeProcedureMetrics.java | 4 +-
.../PipeTemporaryMetaInCoordinatorMetrics.java | 6 +-
.../metric/sink/PipeConfigRegionSinkMetrics.java | 9 +-
.../source/PipeConfigRegionSourceMetrics.java | 7 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 16 +-
.../PipeConfigNodeCopiedFileDirStartupCleaner.java | 3 +-
.../sink/protocol/IoTDBConfigRegionAirGapSink.java | 17 +-
.../pipe/sink/protocol/IoTDBConfigRegionSink.java | 25 +-
.../pipe/source/ConfigRegionListeningQueue.java | 9 +-
.../pipe/source/IoTDBConfigRegionSource.java | 11 +-
.../source/PipeConfigTreePatternParseVisitor.java | 12 +-
.../PipeConfigTreePrivilegeParseVisitor.java | 38 +-
.../manager/schema/ClusterSchemaManager.java | 34 +-
.../subscription/SubscriptionCoordinator.java | 19 +-
.../subscription/SubscriptionMetaSyncer.java | 14 +-
.../iotdb/confignode/persistence/ClusterInfo.java | 9 +-
.../confignode/persistence/ProcedureInfo.java | 32 +-
.../iotdb/confignode/persistence/TTLInfo.java | 5 +-
.../iotdb/confignode/persistence/TriggerInfo.java | 28 +-
.../iotdb/confignode/persistence/UDFInfo.java | 25 +-
.../confignode/persistence/auth/AuthorInfo.java | 10 +-
.../persistence/auth/AuthorPlanExecutor.java | 6 +-
.../iotdb/confignode/persistence/cq/CQInfo.java | 11 +-
.../persistence/executor/ConfigPlanExecutor.java | 32 +-
.../confignode/persistence/node/NodeInfo.java | 37 +-
.../partition/DatabasePartitionTable.java | 11 +-
.../persistence/partition/PartitionInfo.java | 14 +-
.../partition/maintainer/RegionMaintainTask.java | 9 +-
.../confignode/persistence/pipe/PipeInfo.java | 47 +-
.../persistence/pipe/PipePluginInfo.java | 42 +-
.../confignode/persistence/pipe/PipeTaskInfo.java | 23 +-
.../persistence/schema/ClusterSchemaInfo.java | 33 +-
.../confignode/persistence/schema/ConfigMTree.java | 23 +-
.../schema/ConfigNodeSnapshotParser.java | 5 +-
.../persistence/schema/TemplatePreSetTable.java | 9 +-
.../persistence/schema/TemplateTable.java | 26 +-
.../persistence/schema/mnode/IConfigMNode.java | 7 +-
.../schema/mnode/basic/ConfigBasicMNode.java | 3 +-
.../schema/mnode/factory/ConfigMNodeFactory.java | 3 +-
.../schema/mnode/impl/ConfigTableNode.java | 3 +-
.../persistence/subscription/SubscriptionInfo.java | 16 +-
.../procedure/PartitionTableAutoCleaner.java | 11 +-
.../iotdb/confignode/procedure/Procedure.java | 29 +-
.../confignode/procedure/ProcedureExecutor.java | 75 +-
.../procedure/TimeoutExecutorThread.java | 4 +-
.../procedure/env/RegionMaintainHandler.java | 58 +-
.../procedure/env/RemoveDataNodeHandler.java | 35 +-
.../procedure/impl/cq/CreateCQProcedure.java | 36 +-
.../impl/node/AddConfigNodeProcedure.java | 23 +-
.../procedure/impl/node/RemoveAINodeProcedure.java | 25 +-
.../impl/node/RemoveConfigNodeProcedure.java | 14 +-
.../impl/node/RemoveDataNodesProcedure.java | 7 +-
.../DataPartitionTableIntegrityCheckProcedure.java | 70 +-
.../impl/pipe/AbstractOperatePipeProcedureV2.java | 69 +-
.../pipe/plugin/CreatePipePluginProcedure.java | 47 +-
.../impl/pipe/plugin/DropPipePluginProcedure.java | 36 +-
.../runtime/PipeHandleLeaderChangeProcedure.java | 20 +-
.../runtime/PipeHandleMetaChangeProcedure.java | 22 +-
.../impl/pipe/runtime/PipeMetaSyncProcedure.java | 25 +-
.../impl/pipe/task/AlterPipeProcedureV2.java | 29 +-
.../impl/pipe/task/CreatePipeProcedureV2.java | 32 +-
.../impl/pipe/task/DropPipeProcedureV2.java | 24 +-
.../impl/pipe/task/StartPipeProcedureV2.java | 28 +-
.../impl/pipe/task/StopPipeProcedureV2.java | 28 +-
.../pipe/util/PipeExternalSourceLoadBalancer.java | 8 +-
.../impl/region/AddRegionPeerProcedure.java | 34 +-
.../impl/region/CreateRegionGroupsProcedure.java | 16 +-
.../region/NotifyRegionMigrationProcedure.java | 9 +-
.../impl/region/ReconstructRegionProcedure.java | 18 +-
.../impl/region/RegionMigrateProcedure.java | 16 +-
.../impl/region/RemoveRegionPeerProcedure.java | 34 +-
.../schema/AlterEncodingCompressorProcedure.java | 15 +-
.../impl/schema/AlterLogicalViewProcedure.java | 19 +-
.../schema/AlterTimeSeriesDataTypeProcedure.java | 37 +-
.../impl/schema/DeactivateTemplateProcedure.java | 27 +-
.../impl/schema/DeleteDatabaseProcedure.java | 16 +-
.../impl/schema/DeleteLogicalViewProcedure.java | 27 +-
.../impl/schema/DeleteTimeSeriesProcedure.java | 27 +-
.../procedure/impl/schema/SchemaUtils.java | 16 +-
.../procedure/impl/schema/SetTTLProcedure.java | 16 +-
.../impl/schema/SetTemplateProcedure.java | 73 +-
.../impl/schema/UnsetTemplateProcedure.java | 44 +-
.../table/AbstractAlterOrDropTableProcedure.java | 15 +-
.../impl/schema/table/AddTableColumnProcedure.java | 29 +-
.../table/AlterTableColumnDataTypeProcedure.java | 20 +-
.../impl/schema/table/CreateTableProcedure.java | 46 +-
.../impl/schema/table/DeleteDevicesProcedure.java | 31 +-
.../schema/table/DropTableColumnProcedure.java | 23 +-
.../impl/schema/table/DropTableProcedure.java | 31 +-
.../schema/table/RenameTableColumnProcedure.java | 29 +-
.../impl/schema/table/RenameTableProcedure.java | 30 +-
.../schema/table/SetTablePropertiesProcedure.java | 30 +-
.../table/view/CreateTableViewProcedure.java | 6 +-
.../AbstractOperateSubscriptionProcedure.java | 65 +-
.../consumer/AlterConsumerGroupProcedure.java | 41 +-
.../runtime/ConsumerGroupMetaSyncProcedure.java | 21 +-
...bstractOperateSubscriptionAndPipeProcedure.java | 35 +-
.../subscription/CreateSubscriptionProcedure.java | 42 +-
.../subscription/DropSubscriptionProcedure.java | 28 +-
.../subscription/topic/AlterTopicProcedure.java | 47 +-
.../subscription/topic/CreateTopicProcedure.java | 34 +-
.../subscription/topic/DropTopicProcedure.java | 21 +-
.../topic/runtime/TopicMetaSyncProcedure.java | 21 +-
.../impl/sync/AuthOperationProcedure.java | 19 +-
.../AddNeverFinishSubProcedureProcedure.java | 3 +-
.../testonly/CreateManyDatabasesProcedure.java | 5 +-
.../impl/trigger/CreateTriggerProcedure.java | 29 +-
.../impl/trigger/DropTriggerProcedure.java | 18 +-
.../procedure/store/ConfigProcedureStore.java | 7 +-
.../procedure/store/ProcedureFactory.java | 15 +-
.../iotdb/confignode/service/ConfigNode.java | 64 +-
.../confignode/service/ConfigNodeShutdownHook.java | 8 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 56 +-
.../writelog/io/SingleFileLogReader.java | 15 +-
iotdb-core/consensus/pom.xml | 4 +
.../iotdb/consensus/i18n/ConsensusMessages.java | 168 ++
.../iotdb/consensus/i18n/IoTConsensusMessages.java | 301 +++
.../consensus/i18n/IoTConsensusV2Messages.java | 123 ++
.../apache/iotdb/consensus/i18n/RatisMessages.java | 122 ++
.../iotdb/consensus/i18n/ConsensusMessages.java | 166 ++
.../iotdb/consensus/i18n/IoTConsensusMessages.java | 299 +++
.../consensus/i18n/IoTConsensusV2Messages.java | 122 ++
.../apache/iotdb/consensus/i18n/RatisMessages.java | 121 ++
.../apache/iotdb/consensus/ConsensusFactory.java | 8 +-
.../org/apache/iotdb/consensus/IStateMachine.java | 3 +-
.../org/apache/iotdb/consensus/common/Peer.java | 3 +-
.../org/apache/iotdb/consensus/common/Utils.java | 6 +-
.../ConsensusGroupAlreadyExistException.java | 3 +-
.../exception/ConsensusGroupNotExistException.java | 3 +-
.../exception/IllegalPeerEndpointException.java | 6 +-
.../exception/IllegalPeerNumException.java | 4 +-
.../PeerAlreadyInConsensusGroupException.java | 7 +-
.../PeerNotInConsensusGroupException.java | 3 +-
.../apache/iotdb/consensus/iot/IoTConsensus.java | 60 +-
.../consensus/iot/IoTConsensusServerImpl.java | 152 +-
.../iot/client/AsyncIoTConsensusServiceClient.java | 5 +-
.../consensus/iot/client/DispatchLogHandler.java | 12 +-
.../iot/logdispatcher/IndexController.java | 26 +-
.../logdispatcher/IoTConsensusMemoryManager.java | 19 +-
.../consensus/iot/logdispatcher/LogDispatcher.java | 61 +-
.../service/IoTConsensusRPCServiceProcessor.java | 66 +-
.../iotdb/consensus/pipe/IoTConsensusV2.java | 81 +-
.../consensus/pipe/IoTConsensusV2PeerManager.java | 3 +-
.../consensus/pipe/IoTConsensusV2ServerImpl.java | 70 +-
.../pipe/consensuspipe/ConsensusPipeName.java | 5 +-
.../service/IoTConsensusV2RPCServiceProcessor.java | 28 +-
.../ratis/ApplicationStateMachineProxy.java | 20 +-
.../apache/iotdb/consensus/ratis/DiskGuardian.java | 10 +-
.../apache/iotdb/consensus/ratis/RatisClient.java | 6 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 61 +-
.../iotdb/consensus/ratis/ResponseMessage.java | 3 +-
.../iotdb/consensus/ratis/SnapshotStorage.java | 5 +-
.../ratis/metrics/MetricRegistryManager.java | 8 +-
.../apache/iotdb/consensus/ratis/utils/Utils.java | 7 +-
.../iotdb/consensus/simple/SimpleConsensus.java | 22 +-
iotdb-core/datanode/pom.xml | 1 +
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 970 ++++++++++
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 1378 ++++++++++++++
.../iotdb/db/i18n/DataNodeQueryMessages.java | 1426 ++++++++++++++
.../iotdb/db/i18n/DataNodeSchemaMessages.java | 608 ++++++
.../iotdb/db/i18n/StorageEngineMessages.java | 514 ++++++
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 969 ++++++++++
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 1329 ++++++++++++++
.../iotdb/db/i18n/DataNodeQueryMessages.java | 1425 ++++++++++++++
.../iotdb/db/i18n/DataNodeSchemaMessages.java | 599 ++++++
.../iotdb/db/i18n/StorageEngineMessages.java | 514 ++++++
.../apache/iotdb/db/auth/BasicAuthorityCache.java | 5 +-
.../iotdb/db/auth/ClusterAuthorityFetcher.java | 5 +-
.../org/apache/iotdb/db/auth/LoginLockManager.java | 21 +-
.../apache/iotdb/db/conf/DataNodeMemoryConfig.java | 3 +-
.../apache/iotdb/db/conf/DataNodeStartupCheck.java | 5 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 14 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 36 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 15 +-
.../db/conf/rest/IoTDBRestServiceDescriptor.java | 13 +-
.../consensus/statemachine/BaseStateMachine.java | 11 +-
.../dataregion/DataExecutionVisitor.java | 33 +-
.../dataregion/DataRegionStateMachine.java | 43 +-
.../IoTConsensusDataRegionStateMachine.java | 6 +-
.../schemaregion/SchemaExecutionVisitor.java | 13 +-
.../db/partition/DataPartitionTableGenerator.java | 17 +-
.../pipe/agent/plugin/PipeDataNodePluginAgent.java | 7 +-
.../db/pipe/agent/runtime/PipeAgentLauncher.java | 10 +-
.../agent/runtime/PipeDataNodeRuntimeAgent.java | 5 +-
.../agent/runtime/SimpleProgressIndexAssigner.java | 15 +-
.../iotdb/db/pipe/agent/task/PipeDataNodeTask.java | 9 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 27 +-
.../task/builder/PipeDataNodeTaskBuilder.java | 20 +-
.../agent/task/connection/PipeEventCollector.java | 9 +-
.../subtask/processor/PipeProcessorSubtask.java | 5 +-
.../processor/PipeProcessorSubtaskWorker.java | 5 +-
.../sink/PipeRealtimePriorityBlockingQueue.java | 14 +-
.../agent/task/subtask/sink/PipeSinkSubtask.java | 7 +-
.../subtask/sink/PipeSinkSubtaskLifeCycle.java | 17 +-
.../task/subtask/sink/PipeSinkSubtaskManager.java | 10 +-
.../pipe/consensus/deletion/DeletionResource.java | 5 +-
.../deletion/DeletionResourceManager.java | 27 +-
.../deletion/persist/PageCacheDeletionBuffer.java | 47 +-
.../consensus/deletion/recover/DeletionReader.java | 10 +-
.../db/pipe/event/common/PipeInsertionEvent.java | 3 +-
.../event/common/row/PipeDataTypeTransformer.java | 3 +-
.../db/pipe/event/common/row/PipeRowCollector.java | 3 +-
.../schema/PipeSchemaRegionSnapshotEvent.java | 3 +-
.../schema/PipeSchemaSerializableEventType.java | 3 +-
.../statement/PipeStatementInsertionEvent.java | 7 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 18 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 4 +-
.../tablet/parser/TabletInsertionEventParser.java | 7 +-
.../TabletInsertionEventTablePatternParser.java | 7 +-
.../tsfile/PipeCompactedTsFileInsertionEvent.java | 8 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 23 +-
.../aggregator/TsFileInsertionPointCounter.java | 3 +-
.../tsfile/parser/TsFileInsertionEventParser.java | 9 +-
.../query/TsFileInsertionEventQueryParser.java | 10 +-
...ileInsertionEventQueryParserTabletIterator.java | 5 +-
.../parser/scan/SinglePageWholeChunkReader.java | 6 +-
.../scan/TsFileInsertionEventScanParser.java | 9 +-
.../table/TsFileInsertionEventTableParser.java | 4 +-
...ileInsertionEventTableParserTabletIterator.java | 6 +-
.../tsfile/parser/util/ModsOperationUtil.java | 4 +-
.../overview/PipeDataNodeSinglePipeMetrics.java | 10 +-
.../overview/PipeTsFileToTabletsMetrics.java | 16 +-
.../metric/processor/PipeProcessorMetrics.java | 15 +-
.../schema/PipeSchemaRegionListenerMetrics.java | 7 +-
.../metric/schema/PipeSchemaRegionSinkMetrics.java | 12 +-
.../schema/PipeSchemaRegionSourceMetrics.java | 8 +-
.../metric/sink/PipeDataRegionSinkMetrics.java | 15 +-
.../db/pipe/metric/source/PipeAssignerMetrics.java | 5 +-
.../metric/source/PipeDataRegionSourceMetrics.java | 23 +-
.../aggregate/AbstractFormalProcessor.java | 7 +-
.../processor/aggregate/AggregateProcessor.java | 4 +-
.../numeric/AbstractSameTypeNumericOperator.java | 15 +-
.../doubletype/FractionPoweredSumOperator.java | 9 +-
.../window/datastructure/TimeSeriesWindow.java | 17 +-
.../downsampling/PartialPathLastObjectCache.java | 7 +-
.../changing/ChangingValueSamplingProcessor.java | 3 +-
.../sdt/SwingingDoorTrendingSamplingProcessor.java | 3 +-
.../tumbling/TumblingTimeSamplingProcessor.java | 3 +-
.../pipe/processor/twostage/combiner/Combiner.java | 5 +-
.../twostage/combiner/PipeCombineHandler.java | 12 +-
.../combiner/PipeCombineHandlerManager.java | 7 +-
.../twostage/exchange/payload/CombineRequest.java | 4 +-
.../receiver/TwoStageAggregateReceiver.java | 7 +-
.../exchange/sender/TwoStageAggregateSender.java | 30 +-
.../twostage/plugin/TwoStageCountProcessor.java | 30 +-
.../protocol/airgap/IoTDBAirGapReceiver.java | 38 +-
.../protocol/airgap/IoTDBAirGapReceiverAgent.java | 9 +-
.../iotconsensusv2/IoTConsensusV2Receiver.java | 130 +-
.../IoTConsensusV2ReceiverAgent.java | 17 +-
.../legacy/IoTDBLegacyPipeReceiverAgent.java | 38 +-
.../protocol/legacy/loader/DeletionLoader.java | 7 +-
.../protocol/legacy/loader/TsFileLoader.java | 5 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 69 +-
.../transform/converter/ValueConverter.java | 4 +-
.../PipeConvertedInsertTabletStatement.java | 3 +-
...leStatementDataTypeConvertExecutionVisitor.java | 17 +-
...eeStatementDataTypeConvertExecutionVisitor.java | 12 +-
...aNodeHardlinkOrCopiedFileDirStartupCleaner.java | 5 +-
.../resource/log/PipePeriodicalLogReducer.java | 4 +-
.../resource/memory/InsertNodeMemoryEstimator.java | 3 +-
.../pipe/resource/memory/PipeFixedMemoryBlock.java | 10 +-
.../db/pipe/resource/memory/PipeMemoryBlock.java | 9 +-
.../db/pipe/resource/memory/PipeMemoryManager.java | 24 +-
.../pipe/resource/memory/PipeMemoryWeightUtil.java | 3 +-
.../resource/memory/PipeModelFixedMemoryBlock.java | 7 +-
.../resource/tsfile/PipeTsFilePublicResource.java | 16 +-
.../pipe/resource/tsfile/PipeTsFileResource.java | 10 +-
.../resource/tsfile/PipeTsFileResourceManager.java | 3 +-
.../tsfile/PipeTsFileResourceSegmentLock.java | 3 +-
.../client/IoTDBDataNodeAsyncClientManager.java | 28 +-
.../IoTDBDataNodeCacheLeaderClientManager.java | 6 +-
.../client/IoTDBDataNodeSyncClientManager.java | 3 +-
.../evolvable/batch/PipeTabletEventBatch.java | 3 +-
.../batch/PipeTabletEventTsFileBatch.java | 3 +-
.../batch/PipeTransferBatchReqBuilder.java | 7 +-
.../request/PipeTransferTabletRawReq.java | 9 +-
.../request/PipeTransferTabletRawReqV2.java | 3 +-
.../db/pipe/sink/payload/legacy/PipeData.java | 7 +-
.../protocol/airgap/IoTDBDataRegionAirGapSink.java | 17 +-
.../airgap/IoTDBSchemaRegionAirGapSink.java | 13 +-
.../iotconsensusv2/IoTConsensusV2AsyncSink.java | 32 +-
.../iotconsensusv2/IoTConsensusV2SyncSink.java | 7 +-
.../handler/IoTConsensusV2DeleteEventHandler.java | 7 +-
.../IoTConsensusV2TabletBatchEventHandler.java | 5 +-
.../IoTConsensusV2TabletInsertionEventHandler.java | 7 +-
.../IoTConsensusV2TsFileInsertionEventHandler.java | 16 +-
.../IoTConsensusV2TransferBatchReqBuilder.java | 9 +-
.../request/IoTConsensusV2DeleteNodeReq.java | 3 +-
.../request/IoTConsensusV2TabletBinaryReq.java | 3 +-
.../request/IoTConsensusV2TabletInsertNodeReq.java | 5 +-
.../sink/protocol/legacy/IoTDBLegacyPipeSink.java | 11 +-
.../sink/protocol/opcda/OpcDaServerHandle.java | 44 +-
.../db/pipe/sink/protocol/opcda/OpcDaSink.java | 4 +-
.../db/pipe/sink/protocol/opcua/OpcUaSink.java | 20 +-
.../sink/protocol/opcua/client/ClientRunner.java | 19 +-
.../opcua/client/IoTDBKeyStoreLoaderClient.java | 4 +-
.../protocol/opcua/client/IoTDBOpcUaClient.java | 9 +-
.../protocol/opcua/server/OpcUaKeyStoreLoader.java | 5 +-
.../sink/protocol/opcua/server/OpcUaNameSpace.java | 20 +-
.../protocol/opcua/server/OpcUaServerBuilder.java | 7 +-
.../thrift/async/IoTDBDataRegionAsyncSink.java | 28 +-
.../PipeTransferTabletBatchEventHandler.java | 3 +-
.../PipeTransferTabletInsertionEventHandler.java | 3 +-
.../handler/PipeTransferTrackableHandler.java | 9 +-
.../async/handler/PipeTransferTsFileHandler.java | 32 +-
.../thrift/sync/IoTDBDataRegionSyncSink.java | 21 +-
.../thrift/sync/IoTDBSchemaRegionSink.java | 16 +-
.../websocket/WebSocketConnectorServer.java | 65 +-
.../sink/protocol/websocket/WebSocketSink.java | 6 +-
.../sink/protocol/writeback/WriteBackSink.java | 6 +-
.../util/builder/PipeTableModelTsFileBuilder.java | 18 +-
.../builder/PipeTableModelTsFileBuilderV2.java | 8 +-
.../util/builder/PipeTreeModelTsFileBuilder.java | 12 +-
.../util/builder/PipeTreeModelTsFileBuilderV2.java | 8 +-
.../pipe/sink/util/builder/PipeTsFileBuilder.java | 9 +-
.../dataregion/DataRegionWatermarkInjector.java | 3 +-
.../source/dataregion/IoTDBDataRegionSource.java | 41 +-
...istoricalDataRegionTsFileAndDeletionSource.java | 51 +-
.../PipeRealtimeDataRegionHybridSource.java | 3 +-
.../realtime/PipeRealtimeDataRegionSource.java | 10 +-
.../realtime/assigner/DisruptorQueue.java | 3 +-
.../assigner/DisruptorQueueExceptionHandler.java | 7 +-
.../realtime/assigner/PipeDataRegionAssigner.java | 15 +-
.../realtime/disruptor/BatchEventProcessor.java | 14 +-
.../dataregion/realtime/disruptor/Disruptor.java | 15 +-
.../realtime/disruptor/MultiProducerSequencer.java | 8 +-
.../dataregion/realtime/disruptor/RingBuffer.java | 6 +-
.../realtime/epoch/TsFileEpochManager.java | 5 +-
.../matcher/CachedSchemaPatternMatcher.java | 11 +-
.../schemaregion/IoTDBSchemaRegionSource.java | 8 +-
.../PipePlanTreePrivilegeParseVisitor.java | 25 +-
.../schemaregion/SchemaRegionListeningQueue.java | 7 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 26 +-
.../iotdb/db/protocol/client/ConfigNodeInfo.java | 11 +-
.../db/protocol/client/DataNodeInternalClient.java | 11 +-
.../iotdb/db/protocol/client/an/AINodeClient.java | 8 +-
.../cn/AsyncConfigNodeTSStatusRPCHandler.java | 6 +-
.../client/dn/AsyncTSStatusRPCHandler.java | 6 +-
.../client/dn/DataNodeAsyncRequestRPCHandler.java | 4 +-
.../iotdb/db/protocol/session/SessionManager.java | 25 +-
.../thrift/handler/BaseServerContextHandler.java | 5 +-
.../handler/RPCServiceThriftHandlerMetrics.java | 4 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 72 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 121 +-
.../thrift/impl/DataNodeRegionManager.java | 35 +-
.../common/schematree/ClusterSchemaTree.java | 4 +-
.../common/schematree/node/SchemaNode.java | 7 +-
.../db/queryengine/execution/StateMachine.java | 8 +-
.../execution/aggregation/AccumulatorFactory.java | 9 +-
.../SlidingWindowAggregatorFactory.java | 13 +-
.../queryengine/execution/driver/DataDriver.java | 4 +-
.../execution/exchange/MPPDataExchangeManager.java | 95 +-
.../execution/exchange/MPPDataExchangeService.java | 3 +-
.../execution/exchange/SharedTsBlockQueue.java | 9 +-
.../execution/exchange/sink/LocalSinkChannel.java | 19 +-
.../execution/exchange/sink/ShuffleSinkHandle.java | 18 +-
.../execution/exchange/sink/SinkChannel.java | 34 +-
.../exchange/source/LocalSourceHandle.java | 19 +-
.../execution/exchange/source/SourceHandle.java | 31 +-
.../execution/executor/RegionReadExecutor.java | 9 +-
.../execution/executor/RegionWriteExecutor.java | 5 +-
.../fragment/FragmentInstanceContext.java | 5 +-
.../fragment/FragmentInstanceExecution.java | 23 +-
.../fragment/FragmentInstanceManager.java | 10 +-
.../fragment/FragmentInstanceStateMachine.java | 3 +-
.../queryengine/execution/memory/MemoryPool.java | 4 +-
.../execution/operator/AggregationUtil.java | 4 +-
.../execution/operator/ExplainAnalyzeOperator.java | 9 +-
.../TableInsertTabletStatementGenerator.java | 4 +-
.../TreeInsertTabletStatementGenerator.java | 3 +-
.../operator/process/copyto/CopyToOptions.java | 4 +-
.../process/copyto/TableCopyToOperator.java | 8 +-
.../process/copyto/tsfile/CopyToTsFileOptions.java | 11 +-
.../process/join/InnerTimeJoinOperator.java | 4 +-
.../last/AlignedUpdateLastCacheOperator.java | 4 +-
.../operator/schema/NodePathsConvertOperator.java | 3 +-
.../AbstractRegionScanDataSourceOperator.java | 3 +-
.../AbstractSeriesAggregationScanOperator.java | 3 +-
.../source/AbstractSeriesScanOperator.java | 4 +-
.../execution/operator/source/SeriesScanUtil.java | 23 +-
.../relational/AbstractAggTableScanOperator.java | 9 +-
.../relational/AbstractTableScanOperator.java | 3 +-
.../source/relational/CteScanOperator.java | 3 +-
.../InformationSchemaContentSupplierFactory.java | 5 +-
.../relational/LastQueryAggTableScanOperator.java | 7 +-
.../window/ainode/InferenceWindowParameter.java | 4 +-
.../execution/schedule/AbstractDriverThread.java | 10 +-
.../execution/schedule/DriverScheduler.java | 5 +-
.../execution/warnings/WarningCode.java | 4 +-
.../queryengine/metric/QueryPlanCostMetricSet.java | 7 +-
.../iotdb/db/queryengine/plan/ClusterTopology.java | 5 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 15 +-
.../db/queryengine/plan/analyze/AnalyzeUtils.java | 24 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 35 +-
.../plan/analyze/ClusterPartitionFetcher.java | 7 +-
.../plan/analyze/ConcatPathRewriter.java | 7 +-
.../plan/analyze/ExpressionAnalyzer.java | 3 +-
.../plan/analyze/ExpressionTypeAnalyzer.java | 5 +-
.../queryengine/plan/analyze/SelectIntoUtils.java | 3 +-
.../analyze/cache/partition/PartitionCache.java | 13 +-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 13 +-
.../analyze/load/LoadTsFileTableSchemaCache.java | 8 +-
.../load/TreeSchemaAutoCreatorAndVerifier.java | 3 +-
.../queryengine/plan/execution/QueryExecution.java | 21 +-
.../execution/config/TableConfigTaskVisitor.java | 26 +-
.../execution/config/TreeConfigTaskVisitor.java | 4 +-
.../config/executor/ClusterConfigTaskExecutor.java | 54 +-
.../config/metadata/AlterTimeSeriesTask.java | 3 +-
.../metadata/relational/ShowCreateTableTask.java | 3 +-
.../metadata/relational/ShowCreateViewTask.java | 3 +-
.../config/sys/quota/ShowThrottleQuotaTask.java | 7 +-
.../db/queryengine/plan/expression/Expression.java | 3 +-
.../expression/UnknownExpressionTypeException.java | 4 +-
.../expression/binary/CompareBinaryExpression.java | 4 +-
.../multi/builtin/helper/CastFunctionHelper.java | 4 +-
.../builtin/helper/ReplaceFunctionHelper.java | 4 +-
.../BindTypeForTimeSeriesOperandVisitor.java | 4 +-
.../visitor/IntermediateLayerVisitor.java | 7 +-
...ncatDeviceAndBindSchemaForPredicateVisitor.java | 4 +-
.../predicate/ConvertPredicateToFilterVisitor.java | 15 +-
.../ConvertPredicateToTimeFilterVisitor.java | 10 +-
.../predicate/PredicatePushIntoScanChecker.java | 15 +-
.../visitor/predicate/PredicateVisitor.java | 3 +-
.../visitor/predicate/ReversePredicateVisitor.java | 3 +-
.../plan/optimization/AggregationPushDown.java | 5 +-
.../plan/optimization/PredicatePushDown.java | 6 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 195 +-
.../plan/parser/StatementGenerator.java | 3 +-
.../planner/DataNodeTableOperatorGenerator.java | 9 +-
.../plan/planner/LocalExecutionPlanner.java | 4 +-
.../plan/planner/LogicalPlanBuilder.java | 3 +-
.../plan/planner/OperatorTreeGenerator.java | 29 +-
.../planner/distribution/DistributionPlanner.java | 3 +-
.../plan/planner/distribution/SourceRewriter.java | 4 +-
.../plan/AbstractFragmentParallelPlanner.java | 3 +-
.../plan/planner/plan/FragmentInstance.java | 4 +-
.../plan/node/DataNodePlanNodeDeserializer.java | 14 +-
.../plan/planner/plan/node/ExplainAnalyzeNode.java | 7 +-
.../plan/node/load/LoadSingleTsFileNode.java | 9 +-
.../planner/plan/node/load/LoadTsFileNode.java | 7 +-
.../plan/node/load/LoadTsFilePieceNode.java | 14 +-
.../plan/node/metadata/read/DevicesCountNode.java | 4 +-
.../node/metadata/read/DevicesSchemaScanNode.java | 4 +-
.../metadata/read/LevelTimeSeriesCountNode.java | 4 +-
.../metadata/read/LogicalViewSchemaScanNode.java | 4 +-
.../node/metadata/read/TimeSeriesCountNode.java | 4 +-
.../metadata/read/TimeSeriesSchemaScanNode.java | 4 +-
.../node/metadata/write/AlterTimeSeriesNode.java | 7 +-
.../write/CreateAlignedTimeSeriesNode.java | 7 +-
.../metadata/write/CreateMultiTimeSeriesNode.java | 4 +-
.../node/metadata/write/CreateTimeSeriesNode.java | 7 +-
.../write/InternalCreateTimeSeriesNode.java | 4 +-
.../metadata/write/view/AlterLogicalViewNode.java | 4 +-
.../metadata/write/view/CreateLogicalViewNode.java | 4 +-
.../source/AlignedSeriesAggregationScanNode.java | 4 +-
.../plan/node/source/AlignedSeriesScanNode.java | 4 +-
.../plan/node/source/DeviceRegionScanNode.java | 4 +-
.../plan/node/source/LastQueryScanNode.java | 4 +-
.../node/source/SeriesAggregationScanNode.java | 4 +-
.../plan/node/source/SeriesScanSourceNode.java | 4 +-
.../plan/node/source/ShowDiskUsageNode.java | 4 +-
.../planner/plan/node/source/ShowQueriesNode.java | 4 +-
.../plan/node/source/TimeseriesRegionScanNode.java | 4 +-
.../plan/node/write/AbstractDeleteDataNode.java | 3 +-
.../planner/plan/node/write/DeleteDataNode.java | 12 +-
.../planner/plan/node/write/DeleteNodeType.java | 4 +-
.../plan/node/write/InsertMultiTabletsNode.java | 6 +-
.../plan/planner/plan/node/write/InsertNode.java | 9 +-
.../planner/plan/node/write/InsertRowNode.java | 8 +-
.../planner/plan/node/write/InsertRowsNode.java | 3 +-
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 9 +-
.../planner/plan/node/write/InsertTabletNode.java | 12 +-
.../plan/planner/plan/node/write/ObjectNode.java | 6 +-
.../plan/node/write/RelationalDeleteDataNode.java | 5 +-
.../planner/plan/parameter/AggregationStep.java | 5 +-
.../planner/plan/parameter/GroupByParameter.java | 3 +-
.../relational/analyzer/AggregationAnalyzer.java | 4 +-
.../plan/relational/analyzer/Analysis.java | 5 +-
.../plan/relational/analyzer/Analyzer.java | 4 +-
.../relational/analyzer/ExpressionAnalyzer.java | 79 +-
.../plan/relational/analyzer/Scope.java | 6 +-
.../relational/analyzer/StatementAnalyzer.java | 164 +-
.../predicate/ConvertPredicateToFilterVisitor.java | 18 +-
.../ConvertPredicateToTimeFilterVisitor.java | 32 +-
.../PredicatePushIntoMetadataChecker.java | 3 +-
.../predicate/PredicatePushIntoScanChecker.java | 6 +-
.../analyzer/predicate/PredicateVisitor.java | 3 +-
.../ConvertSchemaPredicateToFilterVisitor.java | 4 +-
.../schema/ExtractPredicateColumnNameVisitor.java | 7 +-
.../metadata/OperatorNotFoundException.java | 6 +-
.../relational/metadata/TableMetadataImpl.java | 30 +-
.../fetcher/TableDeviceSchemaValidator.java | 6 +-
.../fetcher/TableHeaderSchemaValidator.java | 35 +-
.../plan/relational/planner/CteMaterializer.java | 3 +-
.../planner/IrExpressionInterpreter.java | 9 +-
.../plan/relational/planner/IrTypeAnalyzer.java | 10 +-
.../plan/relational/planner/LiteralEncoder.java | 3 +-
.../relational/planner/LiteralInterpreter.java | 8 +-
.../plan/relational/planner/QueryPlanner.java | 18 +-
.../plan/relational/planner/RelationPlanner.java | 27 +-
.../plan/relational/planner/TranslationMap.java | 8 +-
.../distribute/TableDistributedPlanGenerator.java | 12 +-
.../ir/GapFillStartAndEndTimeExtractVisitor.java | 4 +-
.../plan/relational/planner/ir/IrUtils.java | 4 +-
.../planner/ir/NormalizeOrExpressionRewriter.java | 3 +-
...ithUncorrelatedScalarSubqueryReconstructor.java | 3 +-
.../relational/planner/iterative/RuleIndex.java | 3 +-
.../rule/ImplementTableFunctionSource.java | 4 +-
.../planner/node/AggregationTableScanNode.java | 7 +-
.../node/AggregationTreeDeviceViewScanNode.java | 3 +-
.../plan/relational/planner/node/CopyToNode.java | 7 +-
.../planner/node/ExplainAnalyzeNode.java | 7 +-
.../DataNodeLocationSupplierFactory.java | 3 +-
.../optimizations/PlanNodeDecorrelator.java | 4 +-
.../planner/optimizations/SymbolMapper.java | 3 +-
...mQuantifiedComparisonApplyToCorrelatedJoin.java | 5 +-
.../rowpattern/RowPatternToIrRewriter.java | 3 +-
.../relational/security/AccessControlImpl.java | 6 +-
.../relational/security/ITableAuthCheckerImpl.java | 9 +-
.../relational/security/TableModelPrivilege.java | 7 +-
.../security/TreeAccessCheckVisitor.java | 9 +-
.../sql/ast/RelationalAuthorStatement.java | 4 +-
.../plan/relational/sql/ast/RenameColumn.java | 4 +-
.../plan/relational/sql/ast/RenameTable.java | 4 +-
.../plan/relational/sql/parser/AstBuilder.java | 90 +-
.../plan/relational/sql/parser/ErrorHandler.java | 4 +-
.../plan/relational/sql/parser/SqlParser.java | 4 +-
.../plan/relational/sql/util/AstUtil.java | 7 +-
.../relational/sql/util/DataNodeSqlFormatter.java | 9 +-
.../scheduler/FixedRateFragInsStateTracker.java | 10 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 9 +-
.../plan/scheduler/SimpleQueryTerminator.java | 6 +-
.../scheduler/load/LoadTsFileDispatcherImpl.java | 13 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 22 +-
.../db/queryengine/plan/statement/Statement.java | 3 +-
.../plan/statement/crud/InsertBaseStatement.java | 4 +-
.../plan/statement/crud/InsertRowStatement.java | 4 +-
.../plan/statement/crud/InsertTabletStatement.java | 4 +-
.../plan/statement/crud/QueryStatement.java | 62 +-
.../plan/statement/literal/Literal.java | 4 +-
.../metadata/CountTimeSlotListStatement.java | 3 +-
.../metadata/CreateContinuousQueryStatement.java | 10 +-
.../metadata/DeleteDatabaseStatement.java | 3 +-
.../statement/metadata/GetRegionIdStatement.java | 3 +-
.../metadata/GetTimeSlotListStatement.java | 3 +-
.../plan/statement/sys/AuthorStatement.java | 5 +-
...izableRowRecordListBackedMultiColumnWindow.java | 3 +-
...SerializableTVListBackedSingleColumnWindow.java | 3 +-
.../dag/adapter/EmptyRowIterator.java | 4 +-
.../dag/input/ConstantInputReader.java | 6 +-
.../transformer/binary/LogicBinaryTransformer.java | 4 +-
.../unary/ArithmeticNegationTransformer.java | 4 +-
.../dag/transformer/unary/InTransformer.java | 7 +-
.../dag/transformer/unary/LikeTransformer.java | 4 +-
.../dag/transformer/unary/LogicNotTransformer.java | 3 +-
.../dag/transformer/unary/RegularTransformer.java | 4 +-
.../unary/scalar/DiffFunctionTransformer.java | 4 +-
.../unary/scalar/ReplaceFunctionTransformer.java | 4 +-
.../unary/scalar/SubStringFunctionTransformer.java | 4 +-
.../dag/udf/UDAFInformationInferrer.java | 3 +-
.../dag/udf/UDTFInformationInferrer.java | 5 +-
.../transformation/dag/util/TransformUtils.java | 6 +-
.../transformation/dag/util/TypeUtils.java | 3 +-
.../apache/iotdb/db/schemaengine/SchemaEngine.java | 29 +-
.../rescon/MemSchemaEngineStatistics.java | 14 +-
.../rescon/MemSchemaRegionStatistics.java | 4 +-
.../schemaregion/SchemaRegionLoader.java | 18 +-
.../schemaregion/SchemaRegionPlanType.java | 5 +-
.../schemaregion/SchemaRegionUtils.java | 31 +-
.../attribute/DeviceAttributeStore.java | 14 +-
.../update/DeviceAttributeCacheUpdater.java | 20 +-
.../GeneralRegionAttributeSecurityService.java | 5 +-
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 91 +-
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 111 +-
.../logfile/FakeCRC32Deserializer.java | 6 +-
.../logfile/MLogDescriptionWriter.java | 4 +-
.../schemaregion/logfile/SchemaLogReader.java | 10 +-
.../schemaregion/logfile/SchemaLogWriter.java | 5 +-
.../visitor/SchemaRegionPlanDeserializer.java | 20 +-
.../visitor/SchemaRegionPlanSerializer.java | 4 +-
.../visitor/SchemaRegionPlanTxtSerializer.java | 4 +-
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 28 +-
.../mtree/impl/mem/mnode/basic/BasicMNode.java | 9 +-
.../impl/mem/mnode/factory/MemMNodeFactory.java | 3 +-
.../impl/mem/mnode/impl/BasicInternalMNode.java | 3 +-
.../mtree/impl/mem/mnode/info/LogicalViewInfo.java | 5 +-
.../mnode/iterator/AbstractTraverserIterator.java | 4 +-
.../impl/mem/snapshot/MemMTreeSnapshotUtil.java | 13 +-
.../mtree/impl/pbtree/CachedMTreeStore.java | 9 +-
.../mtree/impl/pbtree/MTreeBelowSGCachedImpl.java | 5 +-
.../pbtree/ReentrantReadOnlyCachedMTreeStore.java | 19 +-
.../impl/pbtree/flush/PBTreeFlushExecutor.java | 9 +-
.../mtree/impl/pbtree/flush/Scheduler.java | 7 +-
.../mtree/impl/pbtree/memory/MemoryManager.java | 4 +-
.../impl/pbtree/memory/ReleaseFlushMonitor.java | 6 +-
.../impl/pbtree/mnode/basic/CachedBasicMNode.java | 9 +-
.../mnode/container/CachedMNodeContainer.java | 4 +-
.../pbtree/mnode/factory/CacheMNodeFactory.java | 3 +-
.../mnode/impl/CachedBasicInternalMNode.java | 3 +-
.../impl/pbtree/schemafile/AliasIndexPage.java | 9 +-
.../mtree/impl/pbtree/schemafile/ISchemaPage.java | 4 +-
.../mtree/impl/pbtree/schemafile/InternalPage.java | 9 +-
.../mtree/impl/pbtree/schemafile/RecordUtils.java | 3 +-
.../mtree/impl/pbtree/schemafile/SchemaFile.java | 18 +-
.../impl/pbtree/schemafile/SegmentedPage.java | 10 +-
.../impl/pbtree/schemafile/WrappedSegment.java | 15 +-
.../pbtree/schemafile/log/SchemaFileLogReader.java | 11 +-
.../schemafile/pagemgr/BTreePageManager.java | 10 +-
.../pbtree/schemafile/pagemgr/PageManager.java | 15 +-
.../impl/pbtree/schemafile/pagemgr/PagePool.java | 5 +-
.../schemafile/pagemgr/SchemaPageContext.java | 9 +-
.../mtree/loader/MNodeFactoryLoader.java | 3 +-
.../schemaengine/schemaregion/tag/TagLogFile.java | 8 +-
.../schemaengine/schemaregion/tag/TagManager.java | 34 +-
.../schemaregion/utils/MetaFormatUtils.java | 27 +-
.../schemaengine/schemaregion/utils/MetaUtils.java | 6 +-
.../schemaregion/utils/ResourceByPathUtils.java | 5 +-
.../view/visitor/TransformToExpressionVisitor.java | 18 +-
.../write/req/SchemaRegionWritePlanFactory.java | 4 +-
.../db/schemaengine/table/DataNodeTableCache.java | 42 +-
.../schemaengine/table/InformationSchemaUtils.java | 5 +-
.../template/ClusterTemplateManager.java | 25 +-
.../template/TemplateAlterOperationType.java | 5 +-
.../template/TemplateInternalRPCUpdateType.java | 5 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 85 +-
.../iotdb/db/service/DataNodeShutdownHook.java | 11 +-
.../iotdb/db/service/RegionMigrateService.java | 26 +-
.../org/apache/iotdb/db/service/SettleService.java | 7 +-
.../ExternalServiceClassLoader.java | 3 +-
.../ExternalServiceManagementService.java | 3 +-
.../metrics/IoTDBInternalLocalReporter.java | 15 +-
.../iotdb/db/service/metrics/ProcessMetrics.java | 3 +-
.../metrics/file/SystemRelatedFileMetrics.java | 3 +-
.../db/service/metrics/file/TsFileMetrics.java | 5 +-
.../iotdb/db/storageengine/StorageEngine.java | 76 +-
.../db/storageengine/buffer/BloomFilterCache.java | 7 +-
.../storageengine/buffer/CacheHitRatioMonitor.java | 4 +-
.../iotdb/db/storageengine/buffer/ChunkCache.java | 6 +-
.../buffer/TimeSeriesMetadataCache.java | 10 +-
.../db/storageengine/dataregion/DataRegion.java | 124 +-
.../performer/impl/FastCompactionPerformer.java | 3 +-
.../execute/recover/CompactionRecoverManager.java | 5 +-
.../execute/recover/CompactionRecoverTask.java | 5 +-
.../execute/task/CrossSpaceCompactionTask.java | 5 +-
.../execute/task/InnerSpaceCompactionTask.java | 10 +-
.../task/InsertionCrossSpaceCompactionTask.java | 8 +-
.../task/RepairUnsortedFileCompactionTask.java | 4 +-
.../execute/task/SettleCompactionTask.java | 3 +-
.../compaction/execute/utils/CompactionUtils.java | 12 +-
...FollowingBatchCompactionAlignedChunkWriter.java | 15 +-
.../readchunk/SingleSeriesCompactionExecutor.java | 4 +-
.../utils/reader/SeriesDataBlockReader.java | 5 +-
.../utils/writer/AbstractCompactionWriter.java | 3 +-
.../utils/writer/FastCrossCompactionWriter.java | 7 +-
.../utils/writer/FastInnerCompactionWriter.java | 3 +-
.../writer/ReadPointInnerCompactionWriter.java | 13 +-
.../compaction/repair/RepairDataFileScanUtil.java | 3 +-
.../repair/RepairTaskRecoverLogParser.java | 13 +-
.../repair/RepairTimePartitionScanTask.java | 5 +-
.../repair/UnsortedFileRepairTaskScheduler.java | 17 +-
.../schedule/CompactionScheduleTaskManager.java | 17 +-
.../compaction/schedule/CompactionScheduler.java | 3 +-
.../compaction/schedule/CompactionTaskManager.java | 21 +-
.../compaction/schedule/CompactionWorker.java | 7 +-
.../compaction/schedule/TTLScheduleTask.java | 3 +-
.../compaction/selector/ICompactionSelector.java | 7 +-
.../selector/constant/CrossCompactionSelector.java | 4 +-
.../constant/InnerSequenceCompactionSelector.java | 4 +-
.../InnerUnsequenceCompactionSelector.java | 4 +-
.../RepairUnsortedFileCompactionEstimator.java | 3 +-
.../impl/RewriteCrossSpaceCompactionSelector.java | 8 +-
.../impl/SizeTieredCompactionSelector.java | 6 +-
.../dataregion/compaction/settle/SettleLog.java | 9 +-
.../dataregion/compaction/settle/SettleTask.java | 7 +-
.../dataregion/compaction/tool/Interval.java | 4 +-
.../compaction/tool/OverlapStatisticTool.java | 3 +-
.../compaction/tool/SingleSequenceFileTask.java | 6 +-
.../compaction/tool/TimePartitionProcessTask.java | 8 +-
.../dataregion/flush/CompressionRatio.java | 7 +-
.../dataregion/flush/MemTableFlushTask.java | 7 +-
.../flush/pool/FlushSubTaskPoolManager.java | 5 +-
.../flush/pool/FlushTaskPoolManager.java | 5 +-
.../dataregion/memtable/AbstractMemTable.java | 4 +-
.../memtable/AlignedWritableMemChunk.java | 3 +-
.../dataregion/memtable/DeviceIDFactory.java | 3 +-
.../dataregion/memtable/TsFileProcessor.java | 38 +-
.../dataregion/memtable/WritableMemChunk.java | 6 +-
.../dataregion/modification/IDPredicate.java | 5 +-
.../dataregion/modification/ModEntry.java | 7 +-
.../dataregion/modification/ModificationFile.java | 12 +-
.../modification/v1/ModificationFileV1.java | 11 +-
.../v1/io/LocalTextModificationAccessor.java | 23 +-
.../dataregion/read/control/FileReaderManager.java | 6 +-
.../dataregion/read/control/QueryFileManager.java | 17 +-
.../filescan/impl/DiskAlignedChunkHandleImpl.java | 3 +-
.../read/reader/chunk/MemAlignedChunkReader.java | 5 +-
.../read/reader/chunk/MemAlignedPageReader.java | 4 +-
.../metadata/DiskAlignedChunkMetadataLoader.java | 5 +-
.../chunk/metadata/DiskChunkMetadataLoader.java | 5 +-
.../dataregion/snapshot/SnapshotLoader.java | 27 +-
.../dataregion/snapshot/SnapshotLogAnalyzer.java | 4 +-
.../dataregion/snapshot/SnapshotLogger.java | 7 +-
.../dataregion/snapshot/SnapshotTaker.java | 53 +-
.../dataregion/tsfile/TsFileResource.java | 30 +-
.../dataregion/tsfile/TsFileResourceBlockType.java | 4 +-
.../tsfile/generator/TsFileNameGenerator.java | 13 +-
.../tsfile/timeindex/ArrayDeviceTimeIndex.java | 6 +-
.../dataregion/tsfile/timeindex/FileTimeIndex.java | 6 +-
.../timeindex/FileTimeIndexCacheRecorder.java | 17 +-
.../dataregion/tsfile/timeindex/ITimeIndex.java | 3 +-
.../tsfile/timeindex/TimeIndexLevel.java | 7 +-
.../dataregion/utils/DiskUsageStatisticUtil.java | 9 +-
.../dataregion/utils/SharedTimeDataBuffer.java | 5 +-
.../utils/TableDiskUsageStatisticUtil.java | 3 +-
.../dataregion/utils/TsFileResourceUtils.java | 14 +-
.../FileTimeIndexCacheWriter.java | 6 +-
.../tableDiskUsageIndex/TableDiskUsageIndex.java | 13 +-
.../tsfile/TsFileTableDiskUsageIndexWriter.java | 7 +-
.../tsfile/TsFileTableSizeIndexReader.java | 7 +-
.../storageengine/dataregion/wal/WALManager.java | 25 +-
.../allocation/AbstractNodeAllocationStrategy.java | 9 +-
.../dataregion/wal/buffer/AbstractWALBuffer.java | 6 +-
.../dataregion/wal/buffer/WALBuffer.java | 19 +-
.../dataregion/wal/buffer/WALEntry.java | 5 +-
.../dataregion/wal/buffer/WALEntryType.java | 4 +-
.../dataregion/wal/buffer/WALInfoEntry.java | 7 +-
.../dataregion/wal/buffer/WALSignalEntry.java | 4 +-
.../dataregion/wal/checkpoint/Checkpoint.java | 3 +-
.../wal/checkpoint/CheckpointManager.java | 11 +-
.../storageengine/dataregion/wal/io/LogWriter.java | 3 +-
.../dataregion/wal/io/WALInputStream.java | 11 +-
.../dataregion/wal/io/WALMetaData.java | 3 +-
.../storageengine/dataregion/wal/io/WALReader.java | 5 +-
.../dataregion/wal/node/WALFakeNode.java | 3 +-
.../storageengine/dataregion/wal/node/WALNode.java | 17 +-
.../dataregion/wal/recover/WALNodeRecoverTask.java | 13 +-
.../dataregion/wal/recover/WALRecoverManager.java | 19 +-
.../file/AbstractTsFileRecoverPerformer.java | 3 +-
.../file/UnsealedTsFileRecoverPerformer.java | 5 +-
.../dataregion/wal/utils/CheckpointFileUtils.java | 4 +-
.../dataregion/wal/utils/WALFileUtils.java | 8 +-
.../wal/utils/listener/AbstractResultListener.java | 4 +-
.../db/storageengine/load/LoadTsFileManager.java | 26 +-
.../storageengine/load/active/ActiveLoadAgent.java | 14 +-
.../load/active/ActiveLoadDirScanner.java | 17 +-
.../load/active/ActiveLoadMetricsCollector.java | 3 +-
.../load/active/ActiveLoadPathHelper.java | 5 +-
.../active/ActiveLoadScheduledExecutorService.java | 7 +-
.../load/active/ActiveLoadTsFileLoader.java | 7 +-
.../load/config/LoadTsFileConfigurator.java | 6 +-
...leStatementDataTypeConvertExecutionVisitor.java | 3 +-
...eeStatementDataTypeConvertExecutionVisitor.java | 3 +-
.../db/storageengine/load/disk/MinIOSelector.java | 5 +-
.../load/memory/LoadTsFileAbstractMemoryBlock.java | 4 +-
.../memory/LoadTsFileDataCacheMemoryBlock.java | 3 +-
.../load/memory/LoadTsFileMemoryBlock.java | 5 +-
.../load/memory/LoadTsFileMemoryManager.java | 7 +-
.../load/metrics/ActiveLoadingFilesMetricsSet.java | 3 +-
.../load/metrics/LoadTsFileCostMetricsSet.java | 3 +-
.../load/splitter/AlignedChunkData.java | 3 +-
.../db/storageengine/load/splitter/TsFileData.java | 4 +-
.../load/splitter/TsFileSplitter.java | 7 +-
.../iotdb/db/storageengine/load/util/LoadUtil.java | 16 +-
.../rescon/disk/DirectoryChecker.java | 3 +-
.../storageengine/rescon/disk/FolderManager.java | 9 +-
.../db/storageengine/rescon/disk/TierManager.java | 17 +-
.../rescon/disk/strategy/DirectoryStrategy.java | 3 +-
.../MinFolderOccupiedSpaceFirstStrategy.java | 3 +-
.../rescon/memory/AbstractPoolManager.java | 9 +-
.../rescon/memory/PrimitiveArrayManager.java | 4 +-
.../db/storageengine/rescon/memory/SystemInfo.java | 3 +-
.../rescon/memory/TsFileResourceManager.java | 7 +-
.../rescon/quotas/DataNodeSpaceQuotaManager.java | 5 +-
.../quotas/DataNodeThrottleQuotaManager.java | 5 +-
.../rescon/quotas/DefaultOperationQuota.java | 3 +-
.../agent/SubscriptionAgentLauncher.java | 5 +-
.../agent/SubscriptionBrokerAgent.java | 5 +-
.../agent/SubscriptionConsumerAgent.java | 3 +-
.../subscription/agent/SubscriptionTopicAgent.java | 3 +-
.../broker/SubscriptionPrefetchingQueue.java | 7 +-
.../broker/SubscriptionPrefetchingTabletQueue.java | 8 +-
.../broker/SubscriptionPrefetchingTsFileQueue.java | 6 +-
.../db/subscription/event/SubscriptionEvent.java | 3 +-
.../event/batch/SubscriptionPipeEventBatches.java | 7 +-
.../event/cache/SubscriptionPollResponseCache.java | 7 +-
.../response/SubscriptionEventTsFileResponse.java | 5 +-
.../receiver/SubscriptionReceiverV1.java | 31 +-
.../subtask/SubscriptionSinkSubtaskLifeCycle.java | 5 +-
.../subtask/SubscriptionSinkSubtaskManager.java | 4 +-
.../org/apache/iotdb/db/tools/DelayAnalyzer.java | 4 +-
.../apache/iotdb/db/tools/IoTDBDataDirViewer.java | 3 +-
.../apache/iotdb/db/tools/TsFileSelfCheckTool.java | 11 +-
.../apache/iotdb/db/tools/TsFileSketchTool.java | 14 +-
.../iotdb/db/tools/TsFileSplitByPartitionTool.java | 13 +-
.../org/apache/iotdb/db/tools/TsFileSplitTool.java | 9 +-
.../java/org/apache/iotdb/db/tools/WalChecker.java | 17 +-
.../apache/iotdb/db/tools/schema/MLogParser.java | 9 +-
.../db/tools/schema/PBTreeFileSketchTool.java | 9 +-
.../db/tools/schema/SRStatementGenerator.java | 7 +-
.../tools/schema/SchemaRegionSnapshotParser.java | 3 +-
.../db/tools/settle/TsFileAndModSettleTool.java | 16 +-
.../tools/settle/TsFileSettleByCompactionTool.java | 7 +-
.../iotdb/db/tools/utils/TsFileStatisticScan.java | 4 +-
.../iotdb/db/tools/utils/TsFileValidationScan.java | 3 +-
.../TsFileResourcePipeStatisticsSetTool.java | 43 +-
.../db/tools/validate/TsFileValidationTool.java | 3 +-
.../db/trigger/executor/TriggerFireResult.java | 5 +-
.../db/trigger/executor/TriggerFireVisitor.java | 3 +-
.../db/trigger/service/TriggerClassLoader.java | 3 +-
.../trigger/service/TriggerClassLoaderManager.java | 3 +-
.../trigger/service/TriggerInformationUpdater.java | 7 +-
.../trigger/service/TriggerManagementService.java | 3 +-
.../org/apache/iotdb/db/utils/CommonUtils.java | 9 +-
.../iotdb/db/utils/DataNodeObjectFileService.java | 10 +-
.../java/org/apache/iotdb/db/utils/MathUtils.java | 4 +-
.../java/org/apache/iotdb/db/utils/MemUtils.java | 3 +-
.../apache/iotdb/db/utils/ModificationUtils.java | 3 +-
.../org/apache/iotdb/db/utils/ObjectWriter.java | 6 +-
.../org/apache/iotdb/db/utils/OpenFileNumUtil.java | 7 +-
.../org/apache/iotdb/db/utils/ParameterUtils.java | 5 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 6 +-
.../org/apache/iotdb/db/utils/TabletDecoder.java | 3 +-
.../org/apache/iotdb/db/utils/ThreadUtils.java | 5 +-
.../apache/iotdb/db/utils/TimeValuePairUtils.java | 5 +-
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 15 +-
.../parameter/ColumnGeneratorParameter.java | 5 +-
.../iotdb/db/utils/concurrent/FiniteSemaphore.java | 4 +-
.../db/utils/datastructure/AlignedTVList.java | 7 +-
.../iotdb/db/utils/datastructure/BackwardSort.java | 3 +-
.../iotdb/db/utils/datastructure/LazyBitMap.java | 12 +-
.../iotdb/db/utils/datastructure/TVList.java | 7 +-
.../runtime/WindowEvaluationTaskPoolManager.java | 3 +-
.../apache/iotdb/db/utils/writelog/LogWriter.java | 4 +-
.../planner/WindowFunctionOptimizationTest.java | 14 +-
iotdb-core/metrics/core/pom.xml | 8 +
.../metrics/core/i18n/MetricsCoreMessages.java | 39 +
.../metrics/core/i18n/MetricsCoreMessages.java | 39 +
.../metrics/core/reporter/IoTDBJmxReporter.java | 17 +-
.../core/utils/IoTDBMetricObjNameFactory.java | 4 +-
iotdb-core/metrics/interface/pom.xml | 4 +
.../apache/iotdb/metrics/i18n/MetricsMessages.java | 110 ++
.../apache/iotdb/metrics/i18n/MetricsMessages.java | 106 ++
.../iotdb/metrics/AbstractMetricService.java | 3 +-
.../apache/iotdb/metrics/CompositeReporter.java | 9 +-
.../apache/iotdb/metrics/config/MetricConfig.java | 3 +-
.../metricsets/disk/LinuxDiskMetricsManager.java | 11 +-
.../metricsets/disk/WindowsDiskMetricsManager.java | 15 +-
.../metricsets/net/LinuxNetMetricManager.java | 15 +-
.../iotdb/metrics/metricsets/net/NetMetrics.java | 2 +-
.../metricsets/net/WindowsNetMetricManager.java | 13 +-
.../reporter/iotdb/IoTDBSessionReporter.java | 15 +-
.../reporter/prometheus/PrometheusReporter.java | 13 +-
.../apache/iotdb/metrics/utils/FileStoreUtils.java | 6 +-
iotdb-core/node-commons/pom.xml | 18 +
.../apache/iotdb/commons/i18n/AuthMessages.java | 119 ++
.../apache/iotdb/commons/i18n/ClientMessages.java | 95 +
.../apache/iotdb/commons/i18n/CommonMessages.java | 129 ++
.../apache/iotdb/commons/i18n/ConfigMessages.java | 77 +
.../apache/iotdb/commons/i18n/PathMessages.java | 52 +
.../apache/iotdb/commons/i18n/PipeMessages.java | 866 +++++++++
.../apache/iotdb/commons/i18n/QueryMessages.java | 265 +++
.../apache/iotdb/commons/i18n/SchemaMessages.java | 79 +
.../apache/iotdb/commons/i18n/ServiceMessages.java | 143 ++
.../apache/iotdb/commons/i18n/UtilMessages.java | 186 ++
.../apache/iotdb/commons/i18n/AuthMessages.java | 106 ++
.../apache/iotdb/commons/i18n/ClientMessages.java | 93 +
.../apache/iotdb/commons/i18n/CommonMessages.java | 125 ++
.../apache/iotdb/commons/i18n/ConfigMessages.java | 77 +
.../apache/iotdb/commons/i18n/PathMessages.java | 51 +
.../apache/iotdb/commons/i18n/PipeMessages.java | 842 +++++++++
.../apache/iotdb/commons/i18n/QueryMessages.java | 265 +++
.../apache/iotdb/commons/i18n/SchemaMessages.java | 79 +
.../apache/iotdb/commons/i18n/ServiceMessages.java | 143 ++
.../apache/iotdb/commons/i18n/UtilMessages.java | 184 ++
.../commons/auth/authorizer/BasicAuthorizer.java | 74 +-
.../iotdb/commons/auth/entity/PrivilegeType.java | 3 +-
.../iotdb/commons/auth/role/BasicRoleManager.java | 9 +-
.../commons/auth/role/LocalFileRoleAccessor.java | 25 +-
.../iotdb/commons/auth/user/BasicUserManager.java | 25 +-
.../commons/auth/user/LocalFileUserAccessor.java | 7 +-
.../commons/binaryallocator/BinaryAllocator.java | 9 +-
.../binaryallocator/autoreleaser/Releaser.java | 6 +-
.../commons/binaryallocator/evictor/Evictor.java | 5 +-
.../apache/iotdb/commons/client/ClientManager.java | 7 +-
.../apache/iotdb/commons/client/ThriftClient.java | 11 +-
.../async/AsyncAINodeInternalServiceClient.java | 5 +-
.../AsyncConfigNodeInternalServiceClient.java | 7 +-
.../async/AsyncDataNodeExternalServiceClient.java | 5 +-
.../async/AsyncDataNodeInternalServiceClient.java | 7 +-
.../AsyncDataNodeMPPDataExchangeServiceClient.java | 5 +-
.../async/AsyncIoTConsensusV2ServiceClient.java | 5 +-
.../async/AsyncPipeDataTransferServiceClient.java | 13 +-
.../BorrowNullClientManagerException.java | 4 +-
.../client/factory/AsyncThriftClientFactory.java | 3 +-
.../client/request/AsyncRequestManager.java | 25 +-
.../apache/iotdb/commons/cluster/NodeStatus.java | 7 +-
.../org/apache/iotdb/commons/cluster/NodeType.java | 4 +-
.../iotdb/commons/concurrent/ConditionAwaiter.java | 8 +-
.../IoTDBDefaultThreadExceptionHandler.java | 4 +-
.../iotdb/commons/concurrent/ThreadName.java | 4 +-
.../threadpool/ScheduledExecutorUtil.java | 8 +-
.../threadpool/WrappedThreadPoolExecutor.java | 5 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 168 +-
.../iotdb/commons/conf/ConfigurationFileUtils.java | 13 +-
.../iotdb/commons/consensus/ConsensusGroupId.java | 4 +-
.../container/IoTV2GlobalComponentContainer.java | 5 +-
.../java/org/apache/iotdb/commons/cq/CQState.java | 4 +-
.../org/apache/iotdb/commons/cq/TimeoutPolicy.java | 4 +-
.../commons/enums/HandleSystemErrorStrategy.java | 5 +-
.../commons/exception/BadNodeUrlException.java | 4 +-
.../commons/exception/IllegalPathException.java | 5 +-
.../iotdb/commons/exception/StartupException.java | 3 +-
.../exception/UncheckedStartupException.java | 3 +-
.../pipe/PipeRuntimeCriticalException.java | 7 +-
.../pipe/PipeRuntimeNonCriticalException.java | 7 +-
.../PipeRuntimeOutOfMemoryCriticalException.java | 7 +-
.../pipe/PipeRuntimeSinkCriticalException.java | 7 +-
.../collections4/bidimap/AbstractDualBidiMap.java | 9 +-
.../collection/AbstractCollectionDecorator.java | 4 +-
.../AbstractUntypedIteratorDecorator.java | 4 +-
.../iterators/ListIteratorWrapper.java | 3 +-
.../keyvalue/AbstractMapEntryDecorator.java | 4 +-
.../collections4/map/AbstractMapDecorator.java | 4 +-
.../iotdb/commons/externalservice/ServiceInfo.java | 5 +-
.../commons/file/SystemPropertiesHandler.java | 3 +-
.../apache/iotdb/commons/memory/MemoryManager.java | 9 +-
.../org/apache/iotdb/commons/path/AlignedPath.java | 7 +-
.../org/apache/iotdb/commons/path/IFullPath.java | 4 +-
.../apache/iotdb/commons/path/MeasurementPath.java | 11 +-
.../org/apache/iotdb/commons/path/PartialPath.java | 14 +-
.../iotdb/commons/path/PathDeserializeUtil.java | 4 +-
.../commons/pipe/agent/plugin/PipePluginAgent.java | 12 +-
.../throwing/ThrowingExceptionProcessor.java | 13 +-
.../service/PipePluginExecutableManager.java | 8 +-
.../runtime/AbstractPipePeriodicalJobExecutor.java | 11 +-
.../commons/pipe/agent/task/PipeTaskAgent.java | 192 +-
.../task/connection/BlockingPendingQueue.java | 5 +-
.../agent/task/execution/PipeSubtaskExecutor.java | 15 +-
.../commons/pipe/agent/task/meta/PipeStatus.java | 4 +-
.../task/progress/PipeEventCommitManager.java | 15 +-
.../task/subtask/PipeAbstractSinkSubtask.java | 45 +-
.../agent/task/subtask/PipeReportableSubtask.java | 26 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 267 ++-
.../config/constant/PipeProcessorConstant.java | 4 +-
.../config/constant/PipeRPCMessageConstant.java | 4 +-
.../pipe/config/constant/PipeSinkConstant.java | 3 +-
.../pipe/config/constant/PipeSourceConstant.java | 4 +-
.../pipe/config/constant/SystemConstant.java | 3 +-
.../options/PipeInclusionOptions.java | 12 +-
.../datastructure/pattern/IoTDBTreePattern.java | 3 +-
.../pipe/datastructure/pattern/TablePattern.java | 3 +-
.../queue/ConcurrentIterableLinkedQueue.java | 12 +-
.../AbstractSerializableListeningQueue.java | 6 +-
.../queue/serializer/PlainQueueSerializer.java | 3 +-
.../iotdb/commons/pipe/event/EnrichedEvent.java | 3 +-
.../pipe/metric/PipeEventCommitMetrics.java | 7 +-
.../commons/pipe/receiver/IoTDBFileReceiver.java | 229 +--
.../commons/pipe/receiver/IoTDBReceiverAgent.java | 19 +-
.../pipe/receiver/PipeReceiverFilePathUtils.java | 4 +-
.../pipe/receiver/PipeReceiverStatusHandler.java | 28 +-
.../resource/ref/PipePhantomReferenceManager.java | 7 +-
.../snapshot/PipeSnapshotResourceManager.java | 6 +-
.../pipe/sink/client/IoTDBSyncClientManager.java | 34 +-
.../sink/compressor/PipeCompressorFactory.java | 14 +-
.../thrift/common/PipeTransferSliceReqHandler.java | 7 +-
.../pipe/sink/protocol/IoTDBAirGapSink.java | 51 +-
.../commons/pipe/sink/protocol/IoTDBSink.java | 19 +-
.../pipe/sink/protocol/IoTDBSslSyncSink.java | 10 +-
.../pipe/source/IoTDBNonDataRegionSource.java | 3 +-
.../commons/queryengine/common/SqlDialect.java | 4 +-
.../aggregation/grouped/hash/FlatGroupByHash.java | 5 +-
.../aggregation/grouped/hash/FlatHash.java | 15 +-
.../grouped/hash/NoChannelGroupByHash.java | 8 +-
.../plan/node/CommonPlanNodeDeserializer.java | 7 +-
.../plan/planner/plan/node/PlanNode.java | 14 +-
.../plan/planner/plan/node/PlanNodeType.java | 4 +-
.../plan/node/process/TwoChildProcessNode.java | 3 +-
.../plan/relational/function/FunctionId.java | 8 +-
.../function/InterpretedFunctionInvoker.java | 5 +-
.../function/TableBuiltinTableFunction.java | 4 +-
.../relational/function/TableFunctionFactory.java | 3 +-
.../function/TypeVariableConstraint.java | 4 +-
.../function/tvf/ClassifyTableFunction.java | 25 +-
.../function/tvf/ForecastTableFunction.java | 47 +-
.../function/tvf/PatternMatchTableFunction.java | 9 +-
.../function/tvf/TableFunctionUtils.java | 10 +-
.../function/tvf/match/QetchAlgorithm.java | 8 +-
.../plan/relational/metadata/MetadataUtil.java | 5 +-
.../plan/relational/metadata/TableSchema.java | 8 +-
.../plan/relational/planner/node/JoinNode.java | 6 +-
.../relational/planner/node/TableFunctionNode.java | 4 +-
.../plan/relational/planner/node/WindowNode.java | 4 +-
.../rowpattern/ExpressionAndValuePointers.java | 11 +-
.../rowpattern/IrPatternAlternationOptimizer.java | 4 +-
.../planner/rowpattern/IrRowPattern.java | 7 +-
.../planner/rowpattern/IrRowPatternFlattener.java | 4 +-
.../plan/relational/sql/ast/BinaryLiteral.java | 9 +-
.../plan/relational/sql/ast/Columns.java | 6 +-
.../relational/sql/ast/CommonQueryAstVisitor.java | 3 +-
.../relational/sql/ast/ComparisonExpression.java | 6 +-
.../plan/relational/sql/ast/Expression.java | 7 +-
.../plan/relational/sql/ast/FloatLiteral.java | 3 +-
.../plan/relational/sql/ast/FunctionCall.java | 7 +-
.../plan/relational/sql/ast/GenericLiteral.java | 4 +-
.../plan/relational/sql/ast/LogicalExpression.java | 5 +-
.../plan/relational/sql/ast/LongLiteral.java | 6 +-
.../queryengine/plan/relational/sql/ast/Node.java | 5 +-
.../sql/util/CommonQuerySqlFormatter.java | 15 +-
.../relational/sql/util/ExpressionFormatter.java | 12 +-
.../relational/sql/util/RowPatternFormatter.java | 9 +-
.../plan/relational/type/TypeSignature.java | 4 +-
.../relational/type/TypeSignatureParameter.java | 7 +-
.../relational/type/TypeSignatureTranslator.java | 9 +-
.../relational/utils/ResultColumnAppender.java | 4 +-
.../plan/udf/BuiltinAggregationFunction.java | 8 +-
.../queryengine/plan/udf/TableUDFUtils.java | 6 +-
.../queryengine/plan/udf/UDFManagementService.java | 28 +-
.../commons/queryengine/plan/udf/UDTFForecast.java | 28 +-
.../commons/queryengine/utils/DateTimeUtils.java | 23 +-
.../queryengine/utils/TimestampPrecisionUtils.java | 17 +-
.../iotdb/commons/schema/SchemaConstant.java | 3 +-
.../iotdb/commons/schema/filter/SchemaFilter.java | 3 +-
.../commons/schema/filter/SchemaFilterType.java | 4 +-
.../schema/filter/impl/DeviceFilterUtil.java | 4 +-
.../iotdb/commons/schema/node/MNodeType.java | 4 +-
.../node/common/AbstractAboveDatabaseMNode.java | 11 +-
.../schema/node/common/AbstractDatabaseMNode.java | 3 +-
.../node/common/AbstractMeasurementMNode.java | 12 +-
.../schema/node/common/DeviceMNodeWrapper.java | 3 +-
.../commons/schema/node/role/IInternalMNode.java | 3 +-
.../apache/iotdb/commons/schema/table/TsTable.java | 7 +-
.../schema/table/TsTableInternalRPCType.java | 4 +-
.../schema/table/column/TsTableColumnCategory.java | 7 +-
.../table/column/TsTableColumnSchemaUtil.java | 4 +-
.../iotdb/commons/schema/template/Template.java | 5 +-
.../commons/schema/view/LogicalViewSchema.java | 16 +-
.../apache/iotdb/commons/schema/view/ViewType.java | 4 +-
.../schema/view/viewExpression/ViewExpression.java | 5 +-
.../viewExpression/unary/LikeViewExpression.java | 7 +-
.../security/encrypt/AsymmetricEncryptFactory.java | 4 +-
.../security/encrypt/MessageDigestEncrypt.java | 4 +-
.../AbstractPeriodicalServiceWithAdvance.java | 8 +-
.../service/AbstractThriftServiceThread.java | 23 +-
.../apache/iotdb/commons/service/JMXService.java | 7 +-
.../iotdb/commons/service/RegisterManager.java | 13 +-
.../iotdb/commons/service/StartupChecks.java | 20 +-
.../iotdb/commons/service/ThriftService.java | 21 +-
.../commons/service/metric/GcTimeAlerter.java | 22 +-
.../service/metric/JvmGcMonitorMetrics.java | 3 +-
.../commons/service/metric/MetricService.java | 32 +-
.../service/metric/cpu/CpuUsageMetrics.java | 3 +-
.../subscription/config/SubscriptionConfig.java | 68 +-
.../org/apache/iotdb/commons/sync/PipeInfo.java | 3 +-
.../org/apache/iotdb/commons/sync/PipeMessage.java | 4 +-
.../org/apache/iotdb/commons/sync/PipeStatus.java | 4 +-
.../java/org/apache/iotdb/commons/udf/UDFType.java | 5 +-
.../apache/iotdb/commons/udf/builtin/UDTFAbs.java | 3 +-
.../relational/tvf/CapacityTableFunction.java | 3 +-
.../relational/tvf/VariationTableFunction.java | 5 +-
.../commons/udf/service/UDFClassLoaderManager.java | 3 +-
.../commons/udf/service/UDFExecutableManager.java | 3 +-
.../iotdb/commons/udf/utils/MasterRepairUtil.java | 5 +-
.../commons/udf/utils/UDFDataTypeTransformer.java | 7 +-
.../org/apache/iotdb/commons/utils/AuthUtils.java | 20 +-
.../commons/utils/BasicStructureSerDeUtil.java | 4 +-
.../org/apache/iotdb/commons/utils/BlobUtils.java | 8 +-
.../iotdb/commons/utils/CommonDateTimeUtils.java | 4 +-
.../org/apache/iotdb/commons/utils/FileUtils.java | 73 +-
.../org/apache/iotdb/commons/utils/IOUtils.java | 6 +-
.../apache/iotdb/commons/utils/JVMCommonUtils.java | 8 +-
.../iotdb/commons/utils/KillPoint/KillPoint.java | 3 +-
.../apache/iotdb/commons/utils/NodeUrlUtils.java | 7 +-
.../org/apache/iotdb/commons/utils/RetryUtils.java | 14 +-
.../commons/utils/ThriftCommonsSerDeUtils.java | 63 +-
.../commons/utils/ThriftConfigNodeSerDeUtils.java | 19 +-
library-udf/pom.xml | 8 +
.../iotdb/library/i18n/LibraryUdfMessages.java | 121 ++
.../iotdb/library/i18n/LibraryUdfMessages.java | 110 ++
.../org/apache/iotdb/library/anomaly/UDTFLOF.java | 5 +-
.../apache/iotdb/library/anomaly/UDTFRange.java | 3 +-
.../iotdb/library/anomaly/UDTFTwoSidedFilter.java | 3 +-
.../org/apache/iotdb/library/dlearn/UDTFAR.java | 3 +-
.../apache/iotdb/library/dlearn/UDTFCluster.java | 5 +-
.../iotdb/library/dlearn/util/cluster/KMeans.java | 12 +-
.../iotdb/library/dlearn/util/cluster/KShape.java | 12 +-
.../library/dlearn/util/cluster/MedoidShape.java | 20 +-
.../library/dmatch/util/CrossCorrelation.java | 4 +-
.../library/dprofile/util/CrossCorrelation.java | 4 +-
.../iotdb/library/dprofile/util/MADSketch.java | 4 +-
.../iotdb/library/dprofile/util/Resampler.java | 5 +-
.../iotdb/library/dprofile/util/Segment.java | 3 +-
.../library/dprofile/util/SlidingCollector.java | 4 +-
.../library/dquality/util/TimeSeriesQuality.java | 3 +-
.../iotdb/library/drepair/UDTFTimestampRepair.java | 5 +-
.../iotdb/library/drepair/UDTFValueFill.java | 3 +-
.../iotdb/library/drepair/UDTFValueRepair.java | 3 +-
.../apache/iotdb/library/drepair/util/ARFill.java | 5 +-
.../iotdb/library/drepair/util/ValueFill.java | 3 +-
.../iotdb/library/drepair/util/ValueRepair.java | 3 +-
.../library/frequency/UDFEnvelopeAnalysis.java | 3 +-
.../apache/iotdb/library/frequency/UDTFDeconv.java | 3 +-
.../iotdb/library/frequency/util/DWTUtil.java | 6 +-
.../iotdb/library/frequency/util/FFTUtil.java | 3 +-
.../apache/iotdb/library/match/UDAFDTWMatch.java | 4 +-
.../iotdb/library/match/UDAFPatternMatch.java | 4 +-
.../iotdb/library/match/utils/LinearScale.java | 7 +-
.../iotdb/library/util/BooleanCircularQueue.java | 6 +-
.../apache/iotdb/library/util/CircularQueue.java | 6 +-
.../iotdb/library/util/DoubleCircularQueue.java | 6 +-
.../iotdb/library/util/LinearRegression.java | 9 +-
.../iotdb/library/util/LongCircularQueue.java | 6 +-
.../java/org/apache/iotdb/library/util/Util.java | 5 +-
pom.xml | 21 +
1444 files changed, 37569 insertions(+), 11930 deletions(-)
create mode 120000 AGENTS.md
create mode 100644
external-service-impl/mqtt/src/main/i18n/en/org/apache/iotdb/mqtt/i18n/MqttMessages.java
create mode 100644
external-service-impl/mqtt/src/main/i18n/zh/org/apache/iotdb/mqtt/i18n/MqttMessages.java
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/PipeTaskOperation.java
=>
external-service-impl/rest/src/main/i18n/en/org/apache/iotdb/rest/i18n/RestMessages.java
(57%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/PipeTaskOperation.java
=>
external-service-impl/rest/src/main/i18n/zh/org/apache/iotdb/rest/i18n/RestMessages.java
(58%)
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/ainode/it/AINodeCallInferenceIT.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/ainode/it/AINodeDeviceManageIT.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/ainode/it/AINodeForecastIT.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/ainode/it/AINodeInstanceManagementIT.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/ainode/it/AINodeModelManageIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/ainode/it/AINodeSharedClusterIT.java
copy
integration-test/src/test/java/org/apache/iotdb/confignode/it/removedatanode/SQLModel.java
=>
iotdb-api/pipe-api/src/main/i18n/en/org/apache/iotdb/pipe/api/i18n/PipeApiMessages.java
(78%)
copy
integration-test/src/test/java/org/apache/iotdb/confignode/it/removedatanode/SQLModel.java
=>
iotdb-api/pipe-api/src/main/i18n/zh/org/apache/iotdb/pipe/api/i18n/PipeApiMessages.java
(78%)
copy
iotdb-client/isession/src/main/java/org/apache/iotdb/isession/ISessionDataSet.java
=>
iotdb-api/trigger-api/src/main/i18n/en/org/apache/iotdb/trigger/api/i18n/TriggerApiMessages.java
(63%)
copy
integration-test/src/test/java/org/apache/iotdb/subscription/it/DisplayName.java
=>
iotdb-api/trigger-api/src/main/i18n/zh/org/apache/iotdb/trigger/api/i18n/TriggerApiMessages.java
(62%)
create mode 100644
iotdb-api/udf-api/src/main/i18n/en/org/apache/iotdb/udf/api/i18n/UdfApiMessages.java
create mode 100644
iotdb-api/udf-api/src/main/i18n/zh/org/apache/iotdb/udf/api/i18n/UdfApiMessages.java
create mode 100644
iotdb-client/cli/src/main/i18n/en/org/apache/iotdb/cli/i18n/CliMessages.java
create mode 100644
iotdb-client/cli/src/main/i18n/zh/org/apache/iotdb/cli/i18n/CliMessages.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/metadata/view/ViewContainsAggregationException.java
=>
iotdb-client/isession/src/main/i18n/en/org/apache/iotdb/isession/i18n/ISessionMessages.java
(62%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/metadata/view/ViewContainsAggregationException.java
=>
iotdb-client/isession/src/main/i18n/zh/org/apache/iotdb/isession/i18n/ISessionMessages.java
(62%)
create mode 100644
iotdb-client/jdbc/src/main/i18n/en/org/apache/iotdb/jdbc/i18n/JdbcMessages.java
create mode 100644
iotdb-client/jdbc/src/main/i18n/zh/org/apache/iotdb/jdbc/i18n/JdbcMessages.java
create mode 100644
iotdb-client/service-rpc/src/main/i18n/en/org/apache/iotdb/rpc/i18n/RpcMessages.java
create mode 100644
iotdb-client/service-rpc/src/main/i18n/zh/org/apache/iotdb/rpc/i18n/RpcMessages.java
create mode 100644
iotdb-client/session/src/main/i18n/en/org/apache/iotdb/session/i18n/SessionMessages.java
create mode 100644
iotdb-client/session/src/main/i18n/zh/org/apache/iotdb/session/i18n/SessionMessages.java
create mode 100644
iotdb-client/subscription/src/main/i18n/en/org/apache/iotdb/rpc/subscription/i18n/SubscriptionMessages.java
create mode 100644
iotdb-client/subscription/src/main/i18n/zh/org/apache/iotdb/rpc/subscription/i18n/SubscriptionMessages.java
create mode 100644
iotdb-core/calc-commons/src/main/i18n/en/org/apache/iotdb/calc/i18n/CalcMessages.java
create mode 100644
iotdb-core/calc-commons/src/main/i18n/zh/org/apache/iotdb/calc/i18n/CalcMessages.java
create mode 100644
iotdb-core/confignode/src/main/i18n/en/org/apache/iotdb/confignode/i18n/ConfigNodeMessages.java
create mode 100644
iotdb-core/confignode/src/main/i18n/en/org/apache/iotdb/confignode/i18n/ManagerMessages.java
create mode 100644
iotdb-core/confignode/src/main/i18n/en/org/apache/iotdb/confignode/i18n/ProcedureMessages.java
create mode 100644
iotdb-core/confignode/src/main/i18n/zh/org/apache/iotdb/confignode/i18n/ConfigNodeMessages.java
create mode 100644
iotdb-core/confignode/src/main/i18n/zh/org/apache/iotdb/confignode/i18n/ManagerMessages.java
create mode 100644
iotdb-core/confignode/src/main/i18n/zh/org/apache/iotdb/confignode/i18n/ProcedureMessages.java
create mode 100644
iotdb-core/consensus/src/main/i18n/en/org/apache/iotdb/consensus/i18n/ConsensusMessages.java
create mode 100644
iotdb-core/consensus/src/main/i18n/en/org/apache/iotdb/consensus/i18n/IoTConsensusMessages.java
create mode 100644
iotdb-core/consensus/src/main/i18n/en/org/apache/iotdb/consensus/i18n/IoTConsensusV2Messages.java
create mode 100644
iotdb-core/consensus/src/main/i18n/en/org/apache/iotdb/consensus/i18n/RatisMessages.java
create mode 100644
iotdb-core/consensus/src/main/i18n/zh/org/apache/iotdb/consensus/i18n/ConsensusMessages.java
create mode 100644
iotdb-core/consensus/src/main/i18n/zh/org/apache/iotdb/consensus/i18n/IoTConsensusMessages.java
create mode 100644
iotdb-core/consensus/src/main/i18n/zh/org/apache/iotdb/consensus/i18n/IoTConsensusV2Messages.java
create mode 100644
iotdb-core/consensus/src/main/i18n/zh/org/apache/iotdb/consensus/i18n/RatisMessages.java
create mode 100644
iotdb-core/datanode/src/main/i18n/en/org/apache/iotdb/db/i18n/DataNodeMiscMessages.java
create mode 100644
iotdb-core/datanode/src/main/i18n/en/org/apache/iotdb/db/i18n/DataNodePipeMessages.java
create mode 100644
iotdb-core/datanode/src/main/i18n/en/org/apache/iotdb/db/i18n/DataNodeQueryMessages.java
create mode 100644
iotdb-core/datanode/src/main/i18n/en/org/apache/iotdb/db/i18n/DataNodeSchemaMessages.java
create mode 100644
iotdb-core/datanode/src/main/i18n/en/org/apache/iotdb/db/i18n/StorageEngineMessages.java
create mode 100644
iotdb-core/datanode/src/main/i18n/zh/org/apache/iotdb/db/i18n/DataNodeMiscMessages.java
create mode 100644
iotdb-core/datanode/src/main/i18n/zh/org/apache/iotdb/db/i18n/DataNodePipeMessages.java
create mode 100644
iotdb-core/datanode/src/main/i18n/zh/org/apache/iotdb/db/i18n/DataNodeQueryMessages.java
create mode 100644
iotdb-core/datanode/src/main/i18n/zh/org/apache/iotdb/db/i18n/DataNodeSchemaMessages.java
create mode 100644
iotdb-core/datanode/src/main/i18n/zh/org/apache/iotdb/db/i18n/StorageEngineMessages.java
create mode 100644
iotdb-core/metrics/core/src/main/i18n/en/org/apache/iotdb/metrics/core/i18n/MetricsCoreMessages.java
create mode 100644
iotdb-core/metrics/core/src/main/i18n/zh/org/apache/iotdb/metrics/core/i18n/MetricsCoreMessages.java
create mode 100644
iotdb-core/metrics/interface/src/main/i18n/en/org/apache/iotdb/metrics/i18n/MetricsMessages.java
create mode 100644
iotdb-core/metrics/interface/src/main/i18n/zh/org/apache/iotdb/metrics/i18n/MetricsMessages.java
create mode 100644
iotdb-core/node-commons/src/main/i18n/en/org/apache/iotdb/commons/i18n/AuthMessages.java
create mode 100644
iotdb-core/node-commons/src/main/i18n/en/org/apache/iotdb/commons/i18n/ClientMessages.java
create mode 100644
iotdb-core/node-commons/src/main/i18n/en/org/apache/iotdb/commons/i18n/CommonMessages.java
create mode 100644
iotdb-core/node-commons/src/main/i18n/en/org/apache/iotdb/commons/i18n/ConfigMessages.java
create mode 100644
iotdb-core/node-commons/src/main/i18n/en/org/apache/iotdb/commons/i18n/PathMessages.java
create mode 100644
iotdb-core/node-commons/src/main/i18n/en/org/apache/iotdb/commons/i18n/PipeMessages.java
create mode 100644
iotdb-core/node-commons/src/main/i18n/en/org/apache/iotdb/commons/i18n/QueryMessages.java
create mode 100644
iotdb-core/node-commons/src/main/i18n/en/org/apache/iotdb/commons/i18n/SchemaMessages.java
create mode 100644
iotdb-core/node-commons/src/main/i18n/en/org/apache/iotdb/commons/i18n/ServiceMessages.java
create mode 100644
iotdb-core/node-commons/src/main/i18n/en/org/apache/iotdb/commons/i18n/UtilMessages.java
create mode 100644
iotdb-core/node-commons/src/main/i18n/zh/org/apache/iotdb/commons/i18n/AuthMessages.java
create mode 100644
iotdb-core/node-commons/src/main/i18n/zh/org/apache/iotdb/commons/i18n/ClientMessages.java
create mode 100644
iotdb-core/node-commons/src/main/i18n/zh/org/apache/iotdb/commons/i18n/CommonMessages.java
create mode 100644
iotdb-core/node-commons/src/main/i18n/zh/org/apache/iotdb/commons/i18n/ConfigMessages.java
create mode 100644
iotdb-core/node-commons/src/main/i18n/zh/org/apache/iotdb/commons/i18n/PathMessages.java
create mode 100644
iotdb-core/node-commons/src/main/i18n/zh/org/apache/iotdb/commons/i18n/PipeMessages.java
create mode 100644
iotdb-core/node-commons/src/main/i18n/zh/org/apache/iotdb/commons/i18n/QueryMessages.java
create mode 100644
iotdb-core/node-commons/src/main/i18n/zh/org/apache/iotdb/commons/i18n/SchemaMessages.java
create mode 100644
iotdb-core/node-commons/src/main/i18n/zh/org/apache/iotdb/commons/i18n/ServiceMessages.java
create mode 100644
iotdb-core/node-commons/src/main/i18n/zh/org/apache/iotdb/commons/i18n/UtilMessages.java
create mode 100644
library-udf/src/main/i18n/en/org/apache/iotdb/library/i18n/LibraryUdfMessages.java
create mode 100644
library-udf/src/main/i18n/zh/org/apache/iotdb/library/i18n/LibraryUdfMessages.java
