This is an automated email from the ASF dual-hosted git repository.
Caideyipi pushed a change to branch feature/subscription-column-filter
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from bcf6671fac6 spotless
add bd952e15645 Fix encrypted password pull consumer commit mode (#18044)
add d737f4b301b Stabilize ZSTD compressor level pipe IT (#17917)
add 3bc7b9032f1 Pipe: Fix async sink handshake backoff (#18054)
add b4c4e5483f4 Fix stale deletion resource manager reuse (#18057)
add a76341d9408 Enable show queries can be executed when the available
memory for Operators is insufficient (#18052)
add 6fcbaddc0d6 Add copy fallback for compaction hard links (#18045)
add aabf552629b Avoid copying measurements when updating last cache
(#18059)
add 186ce3672a7 Throttle empty subscription poll logs (#18063)
add b35a575199a Fix deletion visibility in region migration IT (#18065)
add 2fedd8a395d Add degraded status to show pipes (#18047)
add d00ec094a0e Support multiple regions in MIGRATE REGION and multiple
DataNodes in REMOVE DATANODE (#18046)
add 3b7df259b8d Use procedures for region create/delete to fix the
delete-region ghost task (#18033)
add 522c31c7750 Display data partition repair progress by providing a new
SQL statement (#17637)
add 127eff05577 Reduce log level of TsFileGenerator (#18068)
add e9fe467592f Support Thrift client mutual TLS (#18026)
add 4b1d5e50e0b Fix ConfigNode NPE when extend/reconstruct region targets
a non-DataNode id (#18075)
add 383458fb72c Fix JDBC reusing stale statement id after reconnect
(#18078)
add 1c8ed311c95 Support target database in write-back sink (#18058)
add 9554e5d8ef0 Pipe: add ConfigNode memory control for log reducer
(#18069)
add fa194d32bb4 [Pipe] Improve pipe control-flow lock responsiveness
(#18076)
add 220e7a319c2 Fix two flaky multi-DataNode/multi-region ITs from #18046
(remove-DataNode selection + migrate precondition) (#18082)
add 660b0ad1c94 Update version to 2.0.11-SNAPSHOT (#18093)
add 0a3e21231ed Fix region-group cleanup: recover-safe submission + retry
that actually re-runs the delete (#18097)
add 8439807f722 Fix C++ client DATE 1000-01-01 query crash (#18096)
add 5ce95b1e05c Pipe: Remove Ratis data region source restriction (#18089)
add 19a9b15c410 Avoid login lock for pipe auth retry (#18048)
add ef5f4ca6441 Fix stale pipe runtime error messages (#18061)
add 2e099a68eb5 Hot-reload procedure completed-cleaner & disk space
warning threshold (+ fix evict-TTL unit) (#18091)
add 3eddf083968 Fix pipe write reject retry handling (#18098)
add d6751c8d38e Pipe: improve incremental memory estimation (#18049)
add 453cb6e51fd Resolve the problem that will write empty
DataPartitionTable object to consensus when not found any data partition in the
CN (#18104)
add 05e592cdc68 [IOTDB-17797] Support lateral column aliases in table
SELECT list (#17960)
add 71cb6e6592d Complete zh locale i18n: convert leftover literals, review
translations, add zh-compile CI (#18110)
add 017f2104825 Merge branch 'master' of https://github.com/apache/iotdb
into feature/subscription-column-filter
No new revisions were added by this update.
Summary of changes:
...{dependency-check.yml => zh-locale-compile.yml} | 34 +-
CLAUDE.md | 12 +-
code-coverage/pom.xml | 2 +-
distribution/pom.xml | 16 +-
docker/ReadMe.md | 2 +-
example/jdbc/pom.xml | 2 +-
example/mqtt-customize/pom.xml | 2 +-
example/mqtt/pom.xml | 2 +-
example/pipe-count-point-processor/pom.xml | 2 +-
example/pipe-opc-ua-sink/pom.xml | 2 +-
example/pom.xml | 2 +-
example/rest-java-example/pom.xml | 2 +-
example/schema/pom.xml | 2 +-
example/session/pom.xml | 2 +-
example/subscription/pom.xml | 2 +-
example/trigger/pom.xml | 2 +-
example/udf/pom.xml | 2 +-
external-service-impl/mqtt/pom.xml | 12 +-
.../org/apache/iotdb/mqtt/i18n/MqttMessages.java | 16 +
.../org/apache/iotdb/mqtt/i18n/MqttMessages.java | 12 +
.../apache/iotdb/mqtt/LinePayloadFormatter.java | 2 +-
.../org/apache/iotdb/mqtt/MPPPublishHandler.java | 14 +-
.../java/org/apache/iotdb/mqtt/MQTTService.java | 2 +-
.../apache/iotdb/mqtt/PayloadFormatManager.java | 3 +-
external-service-impl/pom.xml | 4 +-
external-service-impl/rest-openapi/pom.xml | 2 +-
external-service-impl/rest/pom.xml | 18 +-
.../org/apache/iotdb/rest/i18n/RestMessages.java | 47 +
.../org/apache/iotdb/rest/i18n/RestMessages.java | 45 +
.../table/v1/handler/RequestValidationHandler.java | 35 +-
.../v1/handler/StatementConstructionHandler.java | 6 +-
.../v1/handler/RequestValidationHandler.java | 27 +-
.../v1/handler/StatementConstructionHandler.java | 6 +-
.../v2/handler/RequestValidationHandler.java | 51 +-
.../v2/handler/StatementConstructionHandler.java | 6 +-
integration-test/pom.xml | 42 +-
.../it/env/cluster/config/MppCommonConfig.java | 6 +
.../env/cluster/config/MppSharedCommonConfig.java | 7 +
.../iotdb/it/env/cluster/env/AbstractEnv.java | 29 +
.../it/env/remote/config/RemoteCommonConfig.java | 5 +
.../org/apache/iotdb/it/utils/TsFileGenerator.java | 6 +-
.../org/apache/iotdb/itbase/env/CommonConfig.java | 2 +
...ataPartitionTableIntegrityCheckProcedureIT.java | 36 +
.../commit/IoTDBMigrateMultiRegionForIoTV1IT.java | 213 ++
.../IoTDBRegionGroupExpandAndShrinkForIoTV1IT.java | 59 +
.../commit/IoTDBRegionReconstructForIoTV1IT.java | 55 +
...TDBRegionMigrateWithDeletionMultiDataDirIT.java | 58 +-
...gionMigrateWithDeletionMultiDataDirTableIT.java | 58 +-
.../daily/iotv1/RegionMigrateFileAssertions.java | 167 ++
.../IoTDBRemoveDataNodeNormalIT.java | 24 +-
.../removedatanode/IoTDBRemoveDataNodeUtils.java | 96 +
.../manual/basic/IoTDBPipeDataSinkIT.java | 4 +-
.../enhanced/IoTDBPipeSinkCompressionIT.java | 4 +-
.../auto/enhanced/IoTDBPipeSinkCompressionIT.java | 180 +-
...RegionIT.java => IoTDBPipeWriteBackSinkIT.java} | 60 +-
.../relational/it/schema/IoTDBDatabaseIT.java | 5 +-
...lientSSLIT.java => IoTDBClientMutualSSLIT.java} | 115 +-
.../IoTDBEncryptedPasswordPullConsumerIT.java | 1 +
iotdb-api/external-api/pom.xml | 2 +-
iotdb-api/external-service-api/pom.xml | 2 +-
iotdb-api/pipe-api/pom.xml | 2 +-
.../iotdb/pipe/api/i18n/PipeApiMessages.java | 9 +
.../iotdb/pipe/api/i18n/PipeApiMessages.java | 9 +
.../parameter/PipeParameterValidator.java | 11 +-
.../PipeAttributeNotProvidedException.java | 7 +-
iotdb-api/pom.xml | 2 +-
iotdb-api/trigger-api/pom.xml | 2 +-
iotdb-api/udf-api/pom.xml | 2 +-
.../apache/iotdb/udf/api/i18n/UdfApiMessages.java | 54 +
.../apache/iotdb/udf/api/i18n/UdfApiMessages.java | 54 +
.../strategy/SessionTimeWindowAccessStrategy.java | 10 +-
.../strategy/SlidingSizeWindowAccessStrategy.java | 9 +-
.../strategy/SlidingTimeWindowAccessStrategy.java | 13 +-
.../strategy/StateWindowAccessStrategy.java | 12 +-
.../UDFAttributeNotProvidedException.java | 7 +-
.../UDFInputSeriesDataTypeNotValidException.java | 15 +-
.../UDFInputSeriesIndexNotValidException.java | 8 +-
.../UDFInputSeriesNumberNotValidException.java | 15 +-
.../UDFOutputSeriesDataTypeNotValidException.java | 8 +-
.../ScalarParameterSpecification.java | 6 +-
iotdb-client/cli/pom.xml | 26 +-
.../en/org/apache/iotdb/cli/i18n/CliMessages.java | 23 +
.../zh/org/apache/iotdb/cli/i18n/CliMessages.java | 19 +
.../java/org/apache/iotdb/cli/AbstractCli.java | 44 +
.../src/main/java/org/apache/iotdb/cli/Cli.java | 23 +-
.../iotdb/tool/backup/IoTDBDataBackTool.java | 36 +-
.../org/apache/iotdb/tool/common/Constants.java | 8 +
.../org/apache/iotdb/tool/common/OptionsUtil.java | 20 +
.../apache/iotdb/tool/data/AbstractDataTool.java | 25 +-
.../iotdb/tool/schema/AbstractSchemaTool.java | 18 +
.../iotdb/tool/tsfile/ImportTsFileRemotely.java | 34 +-
iotdb-client/client-cpp/README.md | 4 +-
iotdb-client/client-cpp/README_zh.md | 4 +-
iotdb-client/client-cpp/pom.xml | 4 +-
iotdb-client/client-cpp/src/include/Common.h | 2 +-
iotdb-client/client-cpp/src/session/Date.cpp | 3 -
iotdb-client/client-cpp/src/session/SessionC.cpp | 4 +-
iotdb-client/client-cpp/test/cpp/sessionCIT.cpp | 30 +
iotdb-client/client-cpp/test/cpp/sessionIT.cpp | 28 +
iotdb-client/client-py/README.md | 36 +-
iotdb-client/client-py/iotdb/Session.py | 28 +-
iotdb-client/client-py/iotdb/SessionPool.py | 8 +
iotdb-client/client-py/iotdb/dbapi/Connection.py | 35 +-
iotdb-client/client-py/iotdb/table_session.py | 6 +
iotdb-client/client-py/iotdb/table_session_pool.py | 4 +
iotdb-client/client-py/pom.xml | 8 +-
iotdb-client/client-py/session_ssl_example.py | 16 +-
.../client-py/tests/unit/test_session_ssl.py | 152 +
iotdb-client/isession/pom.xml | 8 +-
.../iotdb/isession/i18n/ISessionMessages.java | 5 +
.../iotdb/isession/i18n/ISessionMessages.java | 5 +
.../org/apache/iotdb/isession/SessionDataSet.java | 3 +-
iotdb-client/jdbc/pom.xml | 8 +-
.../org/apache/iotdb/jdbc/i18n/JdbcMessages.java | 46 +
.../org/apache/iotdb/jdbc/i18n/JdbcMessages.java | 46 +
.../main/java/org/apache/iotdb/jdbc/Config.java | 4 +
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 35 +-
.../apache/iotdb/jdbc/IoTDBConnectionParams.java | 18 +
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 19 +-
.../java/org/apache/iotdb/jdbc/IoTDBDriver.java | 5 +-
.../apache/iotdb/jdbc/IoTDBPreparedStatement.java | 26 +-
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 63 +-
.../iotdb/jdbc/IoTDBTablePreparedStatement.java | 9 +-
.../src/main/java/org/apache/iotdb/jdbc/Utils.java | 12 +-
.../test/java/org/apache/iotdb/jdbc/UtilsTest.java | 28 +
iotdb-client/pom.xml | 2 +-
iotdb-client/service-rpc/pom.xml | 6 +-
.../en/org/apache/iotdb/rpc/i18n/RpcMessages.java | 18 +
.../zh/org/apache/iotdb/rpc/i18n/RpcMessages.java | 20 +-
.../apache/iotdb/rpc/BaseRpcTransportFactory.java | 24 +-
.../apache/iotdb/rpc/BatchExecutionException.java | 3 +-
.../org/apache/iotdb/rpc/IoTDBJDBCDataSet.java | 3 +-
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 9 +-
.../org/apache/iotdb/rpc/RedirectException.java | 11 +-
.../java/org/apache/iotdb/rpc/RpcSslUtils.java | 86 +-
.../iotdb/rpc/StatementExecutionException.java | 3 +-
.../apache/iotdb/rpc/TElasticFramedTransport.java | 15 +-
.../java/org/apache/iotdb/rpc/RpcUtilsTest.java | 14 +
iotdb-client/session/pom.xml | 10 +-
.../apache/iotdb/session/i18n/SessionMessages.java | 25 +
.../apache/iotdb/session/i18n/SessionMessages.java | 26 +-
.../iotdb/session/AbstractSessionBuilder.java | 2 +
.../org/apache/iotdb/session/NodesSupplier.java | 12 +
.../java/org/apache/iotdb/session/Session.java | 43 +-
.../apache/iotdb/session/SessionConnection.java | 28 +-
.../apache/iotdb/session/TableSessionBuilder.java | 24 +
.../org/apache/iotdb/session/ThriftConnection.java | 11 +-
.../org/apache/iotdb/session/pool/SessionPool.java | 38 +-
.../session/pool/TableSessionPoolBuilder.java | 24 +
.../iotdb/session/pool/TableSessionWrapper.java | 8 +-
.../apache/iotdb/session/util/SessionUtils.java | 14 +-
iotdb-client/subscription/pom.xml | 14 +-
.../subscription/i18n/SubscriptionMessages.java | 165 ++
.../subscription/i18n/SubscriptionMessages.java | 119 +
.../iotdb/rpc/subscription/config/TopicConfig.java | 4 +-
.../subscription/payload/poll/ErrorPayload.java | 4 +-
.../payload/poll/SubscriptionCommitContext.java | 5 +-
.../subscription/AbstractSubscriptionSession.java | 25 +-
.../subscription/SubscriptionSessionWrapper.java | 3 +-
.../base/AbstractSubscriptionConsumer.java | 131 +-
.../base/AbstractSubscriptionConsumerBuilder.java | 7 +-
.../base/AbstractSubscriptionProvider.java | 58 +-
.../base/AbstractSubscriptionProviders.java | 38 +-
.../base/AbstractSubscriptionPullConsumer.java | 39 +-
.../base/AbstractSubscriptionPushConsumer.java | 25 +-
.../consumer/base/ColumnAlignProcessor.java | 3 +-
.../consumer/base/EmptyPollLogThrottler.java | 62 +
.../base/SubscriptionExecutorServiceManager.java | 11 +-
.../subscription/payload/SubscriptionMessage.java | 19 +-
.../payload/SubscriptionRecordHandler.java | 19 +-
.../payload/SubscriptionTsFileHandler.java | 7 +-
.../session/subscription/util/IdentifierUtils.java | 3 +-
.../consumer/base/EmptyPollLogThrottlerTest.java | 63 +
iotdb-core/ainode/pom.xml | 12 +-
iotdb-core/antlr/pom.xml | 2 +-
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 3 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 11 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 6 +-
iotdb-core/calc-commons/pom.xml | 14 +-
.../org/apache/iotdb/calc/i18n/CalcMessages.java | 286 ++
.../org/apache/iotdb/calc/i18n/CalcMessages.java | 271 ++
.../calc/execution/aggregation/Accumulator.java | 4 +-
.../aggregation/CentralMomentAccumulator.java | 20 +-
.../aggregation/CorrelationAccumulator.java | 19 +-
.../aggregation/CovarianceAccumulator.java | 20 +-
.../aggregation/RegressionAccumulator.java | 20 +-
.../execution/aggregation/VarianceAccumulator.java | 16 +-
.../operator/GroupedTopNRowNumberAccumulator.java | 30 +-
.../operator/RowReferenceTsBlockManager.java | 27 +-
.../operator/process/AbstractFillOperator.java | 12 +-
.../process/AbstractLinearFillOperator.java | 9 +-
.../operator/process/AssignUniqueIdOperator.java | 10 +-
.../execution/operator/process/LimitOperator.java | 8 +-
.../execution/operator/process/OffsetOperator.java | 8 +-
.../process/PreviousFillWithGroupOperator.java | 15 +-
.../operator/process/TableNextFillOperator.java | 3 +-
.../execution/operator/process/ValuesOperator.java | 6 +-
.../process/fill/identity/IdentityLinearFill.java | 4 +-
.../operator/process/fill/linear/LinearFill.java | 4 +-
.../process/function/PartitionRecognizer.java | 3 +-
.../process/gapfill/AbstractGapFillOperator.java | 4 +-
.../process/rowpattern/LogicalIndexNavigation.java | 11 +-
.../rowpattern/PatternAggregationTracker.java | 11 +-
.../process/rowpattern/PatternAggregator.java | 14 +-
.../process/rowpattern/PatternAggregators.java | 6 +-
.../rowpattern/PatternPartitionExecutor.java | 7 +-
.../rowpattern/PatternVariableRecognizer.java | 9 +-
.../process/rowpattern/PhysicalValuePointer.java | 7 +-
.../rowpattern/expression/CastComputation.java | 2 +-
.../rowpattern/expression/ComparisonOperator.java | 5 +-
.../process/rowpattern/expression/Computation.java | 3 +-
.../process/rowpattern/matcher/ArrayView.java | 13 +-
.../matcher/IrRowPatternToProgramRewriter.java | 17 +-
.../process/rowpattern/matcher/MatchResult.java | 7 +-
.../window/function/WindowFunctionFactory.java | 3 +-
.../function/aggregate/WindowAggregator.java | 11 +-
.../process/window/function/value/LagFunction.java | 3 +-
.../window/function/value/LeadFunction.java | 3 +-
.../source/relational/MarkDistinctOperator.java | 9 +-
.../operator/source/relational/Percentile.java | 4 +-
.../AbstractApproxMostFrequentAccumulator.java | 3 +-
.../AbstractApproxPercentileAccumulator.java | 17 +-
.../relational/aggregation/AccumulatorFactory.java | 26 +-
.../relational/aggregation/AggregationMask.java | 24 +-
.../ApproxCountDistinctAccumulator.java | 10 +-
.../relational/aggregation/AvgAccumulator.java | 24 +-
.../BinaryApproxMostFrequentAccumulator.java | 5 +-
.../BooleanApproxMostFrequentAccumulator.java | 5 +-
.../relational/aggregation/CountAccumulator.java | 10 +-
.../aggregation/CountAllAccumulator.java | 10 +-
.../DoubleApproxMostFrequentAccumulator.java | 5 +-
.../relational/aggregation/FirstAccumulator.java | 23 +-
.../relational/aggregation/FirstByAccumulator.java | 29 +-
.../FloatApproxMostFrequentAccumulator.java | 5 +-
.../IntApproxMostFrequentAccumulator.java | 5 +-
.../relational/aggregation/LastAccumulator.java | 23 +-
.../relational/aggregation/LastByAccumulator.java | 29 +-
.../LongApproxMostFrequentAccumulator.java | 5 +-
.../relational/aggregation/MaxAccumulator.java | 26 +-
.../relational/aggregation/MinAccumulator.java | 26 +-
.../aggregation/PercentileAccumulator.java | 16 +-
.../relational/aggregation/RecordIterator.java | 2 +-
.../relational/aggregation/SumAccumulator.java | 18 +-
.../relational/aggregation/TableAggregator.java | 18 +-
.../aggregation/TableCentralMomentAccumulator.java | 11 +-
.../aggregation/TableCorrelationAccumulator.java | 13 +-
.../aggregation/TableCovarianceAccumulator.java | 14 +-
.../aggregation/TableMaxMinByBaseAccumulator.java | 13 +-
.../aggregation/TableModeAccumulator.java | 9 +-
.../aggregation/TableRegressionAccumulator.java | 12 +-
.../aggregation/TableVarianceAccumulator.java | 13 +-
.../UserDefinedAggregateFunctionAccumulator.java | 6 +-
.../source/relational/aggregation/Utils.java | 4 +-
.../aggregation/approximate/HyperLogLog.java | 12 +-
.../approximate/HyperLogLogStateFactory.java | 3 +-
.../approximate/SpaceSavingStateFactory.java | 3 +-
.../aggregation/approximate/TDigest.java | 3 +-
...AbstractGroupedApproxPercentileAccumulator.java | 12 +-
...BinaryGroupedApproxMostFrequentAccumulator.java | 5 +-
...ooleanGroupedApproxMostFrequentAccumulator.java | 5 +-
...DoubleGroupedApproxMostFrequentAccumulator.java | 5 +-
.../FloatGroupedApproxMostFrequentAccumulator.java | 5 +-
.../aggregation/grouped/GroupedAggregator.java | 18 +-
.../GroupedApproxCountDistinctAccumulator.java | 5 +-
.../aggregation/grouped/GroupedAvgAccumulator.java | 15 +-
.../grouped/GroupedCentralMomentAccumulator.java | 8 +-
.../grouped/GroupedCorrelationAccumulator.java | 9 +-
.../grouped/GroupedCovarianceAccumulator.java | 11 +-
.../grouped/GroupedExtremeAccumulator.java | 33 +-
.../grouped/GroupedFirstAccumulator.java | 39 +-
.../grouped/GroupedFirstByAccumulator.java | 48 +-
.../grouped/GroupedLastAccumulator.java | 39 +-
.../grouped/GroupedLastByAccumulator.java | 48 +-
.../aggregation/grouped/GroupedMaxAccumulator.java | 33 +-
.../grouped/GroupedMaxMinByBaseAccumulator.java | 67 +-
.../aggregation/grouped/GroupedMinAccumulator.java | 33 +-
.../grouped/GroupedModeAccumulator.java | 10 +-
.../grouped/GroupedPercentileAccumulator.java | 13 +-
.../grouped/GroupedRegressionAccumulator.java | 11 +-
.../aggregation/grouped/GroupedSumAccumulator.java | 9 +-
.../GroupedUserDefinedAggregateAccumulator.java | 6 +-
.../grouped/GroupedVarianceAccumulator.java | 9 +-
.../grouped/HashAggregationOperator.java | 4 +-
.../IntGroupedApproxMostFrequentAccumulator.java | 5 +-
.../LongGroupedApproxMostFrequentAccumulator.java | 5 +-
.../grouped/StreamingAggregationOperator.java | 5 +-
.../grouped/StreamingHashAggregationOperator.java | 5 +-
.../relational/ColumnTransformerBuilder.java | 8 +-
.../schedule/queue/IndexedBlockingQueue.java | 3 +-
.../calc/plan/planner/TableOperatorGenerator.java | 48 +-
.../planner/memory/MemoryReservationManager.java | 6 +
.../relational/metadata/CommonMetadataUtils.java | 3 +-
.../plan/relational/utils/matching/Captures.java | 5 +-
.../calc/plan/relational/utils/matching/Match.java | 4 +-
.../plan/relational/utils/matching/Pattern.java | 5 +-
.../plan/relational/utils/matching/Property.java | 5 +-
.../relational/utils/matching/PropertyPattern.java | 6 +-
.../utils/matching/pattern/CapturePattern.java | 3 +-
.../utils/matching/pattern/EqualsPattern.java | 6 +-
.../utils/matching/pattern/FilterPattern.java | 3 +-
.../utils/matching/pattern/TypeOfPattern.java | 4 +-
.../utils/matching/pattern/WithPattern.java | 4 +-
.../AbstractTemporaryQueryDataFileService.java | 10 +-
.../AbstractCaseWhenThenColumnTransformer.java | 5 +-
.../transformation/dag/column/ColumnCache.java | 5 +-
.../dag/column/binary/Like2ColumnTransformer.java | 7 +-
.../binary/factory/HmacStrategiesFactory.java | 13 +-
.../AbstractGreatestLeastColumnTransformer.java | 5 +-
.../multi/LogicalAndMultiColumnTransformer.java | 4 +-
.../multi/LogicalOrMultiColumnTransformer.java | 4 +-
.../dag/column/ternary/Like3ColumnTransformer.java | 10 +-
.../dag/column/ternary/utils/BytePaddingUtils.java | 14 +-
.../udf/UserDefineScalarFunctionTransformer.java | 5 +-
.../unary/ArithmeticNegationColumnTransformer.java | 4 +-
.../dag/column/unary/LikeColumnTransformer.java | 4 +-
.../column/unary/LogicNotColumnTransformer.java | 4 +-
.../dag/column/unary/RegularColumnTransformer.java | 4 +-
.../AbstractCastFunctionColumnTransformer.java | 15 +-
.../scalar/CastFunctionColumnTransformer.java | 4 +-
.../scalar/DateBinFunctionColumnTransformer.java | 7 +-
.../unary/scalar/FormatColumnTransformer.java | 6 +-
.../unary/scalar/RoundColumnTransformer.java | 3 +-
.../scalar/RoundFunctionColumnTransformer.java | 4 +-
.../unary/scalar/SubString2ColumnTransformer.java | 4 +-
.../unary/scalar/SubString3ColumnTransformer.java | 7 +-
.../unary/scalar/SubStringColumnTransformer.java | 7 +-
.../scalar/TryCastFunctionColumnTransformer.java | 3 +-
.../scalar/factory/CodecStrategiesFactory.java | 2 +-
.../factory/NumericCodecStrategiesFactory.java | 15 +-
.../unary/scalar/util/TransformerDebugUtils.java | 5 +-
.../calc/transformation/dag/udf/UDTFExecutor.java | 10 +-
.../calc/transformation/dag/util/BitwiseUtils.java | 10 +-
.../transformation/dag/util/CastFunctionUtils.java | 33 +-
.../org/apache/iotdb/calc/utils/HeapTraversal.java | 8 +-
.../apache/iotdb/calc/utils/ObjectTypeUtils.java | 14 +-
.../apache/iotdb/calc/utils/sort/DiskSpiller.java | 11 +-
.../iotdb/calc/utils/sort/FileSpillerReader.java | 5 +-
.../dag/util/CastFunctionUtilsTest.java | 142 +
iotdb-core/confignode/pom.xml | 30 +-
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 128 +
.../iotdb/confignode/i18n/ManagerMessages.java | 144 +-
.../iotdb/confignode/i18n/ProcedureMessages.java | 220 ++
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 606 ++--
.../iotdb/confignode/i18n/ManagerMessages.java | 580 ++--
.../iotdb/confignode/i18n/ProcedureMessages.java | 932 +++---
.../client/async/CnToDnAsyncRequestType.java | 1 -
.../CnToDnInternalServiceAsyncRequestManager.java | 5 -
.../audit/DataNodeWriteAuditLogHandler.java | 8 +-
.../heartbeat/DataNodeHeartbeatHandler.java | 3 +-
.../subscription/PullCommitProgressRPCHandler.java | 6 +-
.../client/sync/CnToDnSyncRequestType.java | 1 +
.../client/sync/SyncConfigNodeClientPool.java | 3 +-
.../client/sync/SyncDataNodeClientPool.java | 3 +
.../confignode/conf/ConfigNodeDescriptor.java | 74 +-
.../confignode/conf/ConfigNodeMemoryConfig.java | 89 +
.../confignode/conf/ConfigNodeStartupCheck.java | 42 +-
.../confignode/conf/SystemPropertiesUtils.java | 6 +-
.../write/region/CreateRegionGroupsPlan.java | 4 +-
.../response/pipe/task/PipeTableResp.java | 10 +
.../statemachine/ConfigRegionStateMachine.java | 26 +-
.../exception/AddConsensusGroupException.java | 6 +-
.../confignode/exception/AddPeerException.java | 6 +-
.../exception/DatabaseNotExistsException.java | 5 +-
.../exception/NoAvailableAINodeException.java | 5 +-
.../exception/NoAvailableRegionGroupException.java | 12 +-
.../exception/NotEnoughDataNodeException.java | 8 +-
.../physical/UnknownPhysicalPlanTypeException.java | 5 +-
.../confignode/manager/ClusterQuotaManager.java | 7 +-
.../iotdb/confignode/manager/ConfigManager.java | 92 +-
.../apache/iotdb/confignode/manager/IManager.java | 3 +
.../iotdb/confignode/manager/ProcedureManager.java | 268 +-
.../iotdb/confignode/manager/TTLManager.java | 6 +-
.../iotdb/confignode/manager/UDFManager.java | 2 +-
.../manager/consensus/ConsensusManager.java | 22 +-
.../externalservice/ExternalServiceManager.java | 4 +-
.../partition/DataPartitionPolicyTable.java | 5 +-
.../manager/node/ClusterNodeStartUtils.java | 67 +-
.../iotdb/confignode/manager/node/NodeManager.java | 19 +-
.../manager/partition/PartitionManager.java | 361 +--
.../agent/runtime/PipeConfigNodeRuntimeAgent.java | 20 +-
.../pipe/agent/task/PipeConfigNodeTaskAgent.java | 7 +-
.../runtime/PipeRuntimeCoordinator.java | 6 +-
.../runtime/heartbeat/PipeHeartbeat.java | 22 +-
.../runtime/heartbeat/PipeHeartbeatParser.java | 26 +-
.../runtime/heartbeat/PipeHeartbeatScheduler.java | 6 +-
.../pipe/event/PipeConfigRegionSnapshotEvent.java | 12 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 3 +-
.../resource/PipeConfigNodeResourceManager.java | 14 +
.../manager/schema/ClusterSchemaManager.java | 19 +-
.../subscription/SubscriptionMetaSyncer.java | 4 +-
.../subscription/SubscriptionOwnerLeaseSyncer.java | 12 +-
.../confignode/persistence/ProcedureInfo.java | 7 +-
.../iotdb/confignode/persistence/TTLInfo.java | 8 +-
.../persistence/auth/AuthorPlanExecutor.java | 11 +-
.../confignode/persistence/node/NodeInfo.java | 9 +-
.../partition/DatabasePartitionTable.java | 4 +-
.../persistence/partition/PartitionInfo.java | 29 +-
.../confignode/persistence/pipe/PipeInfo.java | 7 +-
.../confignode/persistence/pipe/PipeTaskInfo.java | 55 +-
.../confignode/persistence/quota/QuotaInfo.java | 5 +-
.../schema/CNPhysicalPlanGenerator.java | 21 +-
.../persistence/schema/ClusterSchemaInfo.java | 10 +-
.../schema/TreeDeviceViewFieldDetector.java | 5 +-
.../persistence/subscription/SubscriptionInfo.java | 8 +-
.../procedure/CompletedProcedureRecycler.java | 25 +-
.../iotdb/confignode/procedure/Procedure.java | 5 +-
.../confignode/procedure/ProcedureExecutor.java | 64 +-
.../confignode/procedure/RootProcedureStack.java | 6 +-
.../confignode/procedure/StoppableThread.java | 4 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 15 +-
.../procedure/impl/StateMachineProcedure.java | 9 +-
.../procedure/impl/cq/CreateCQProcedure.java | 3 +-
.../procedure/impl/node/AbstractNodeProcedure.java | 8 +-
.../impl/node/AddConfigNodeProcedure.java | 2 +-
.../impl/node/RemoveConfigNodeProcedure.java | 8 +-
.../impl/node/RemoveDataNodesProcedure.java | 33 +-
.../DataPartitionTableIntegrityCheckProcedure.java | 269 +-
.../impl/pipe/AbstractOperatePipeProcedureV2.java | 24 +-
.../impl/pipe/task/StartPipeProcedureV2.java | 42 +-
.../impl/region/AddRegionPeerProcedure.java | 6 +-
.../impl/region/CreateRegionGroupsProcedure.java | 44 +-
.../impl/region/RemoveRegionGroupProcedure.java | 389 +++
.../impl/schema/DeleteDatabaseProcedure.java | 132 +-
.../procedure/impl/schema/SchemaUtils.java | 2 +-
.../procedure/impl/schema/SetTTLProcedure.java | 13 +-
.../impl/schema/SetTemplateProcedure.java | 3 +-
.../table/AbstractAlterOrDropTableProcedure.java | 8 +-
.../runtime/CommitProgressSyncProcedure.java | 33 +-
.../SubscriptionHandleLeaderChangeProcedure.java | 52 +-
.../subscription/CreateSubscriptionProcedure.java | 10 +-
.../subscription/DropSubscriptionProcedure.java | 5 +-
.../impl/trigger/CreateTriggerProcedure.java | 17 +-
.../impl/trigger/DropTriggerProcedure.java | 5 +-
.../scheduler/AbstractProcedureScheduler.java | 13 +-
...ationState.java => RemoveRegionGroupState.java} | 4 +-
.../state/schema/DeleteDatabaseState.java | 5 +-
.../procedure/store/ConfigProcedureStore.java | 8 +-
.../procedure/store/ProcedureFactory.java | 10 +-
.../confignode/procedure/store/ProcedureType.java | 1 +
.../iotdb/confignode/service/ConfigNode.java | 4 +-
.../confignode/service/ConfigNodeShutdownHook.java | 3 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 24 +-
.../confignode/writelog/io/BatchLogReader.java | 6 +-
.../writelog/io/SingleFileLogReader.java | 7 +-
.../conf/ConfigNodeMemoryConfigTest.java | 61 +
.../consensus/response/pipe/PipeTableRespTest.java | 48 +
.../runtime/heartbeat/PipeHeartbeatParserTest.java | 229 +-
.../confignode/persistence/PartitionInfoTest.java | 27 +
.../pipe/PipeTaskInfoAutoRestartTest.java | 28 +
.../procedure/CompletedProcedureRecyclerTest.java | 76 +
.../procedure/TestProcedureExecutor.java | 14 +
...aPartitionTableIntegrityCheckProcedureTest.java | 13 +
.../pipe/AbstractOperatePipeProcedureV2Test.java | 168 ++
.../region/RemoveRegionGroupProcedureTest.java | 100 +
iotdb-core/consensus/pom.xml | 14 +-
.../iotdb/consensus/i18n/ConsensusMessages.java | 10 +
.../iotdb/consensus/i18n/IoTConsensusMessages.java | 34 +-
.../apache/iotdb/consensus/i18n/RatisMessages.java | 12 +
.../iotdb/consensus/i18n/ConsensusMessages.java | 10 +
.../iotdb/consensus/i18n/IoTConsensusMessages.java | 34 +-
.../apache/iotdb/consensus/i18n/RatisMessages.java | 14 +-
.../exception/RatisReadUnavailableException.java | 7 +-
.../exception/RatisRequestFailedException.java | 16 +-
.../apache/iotdb/consensus/iot/IoTConsensus.java | 8 +-
.../consensus/iot/IoTConsensusServerImpl.java | 36 +-
.../org/apache/iotdb/consensus/iot/WriterMeta.java | 6 +-
.../consensus/iot/WriterSafeFrontierTracker.java | 9 +-
.../consensus/iot/logdispatcher/LogDispatcher.java | 3 +-
.../consensus/iot/logdispatcher/SyncStatus.java | 4 +-
.../subscription/SubscriptionQueueRegistry.java | 15 +-
.../ratis/ApplicationStateMachineProxy.java | 5 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 5 +-
.../iotdb/consensus/ratis/utils/Retriable.java | 14 +-
iotdb-core/datanode/pom.xml | 44 +-
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 461 +++
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 1028 ++++++-
.../iotdb/db/i18n/DataNodeQueryMessages.java | 2183 ++++++++++++++
.../iotdb/db/i18n/DataNodeSchemaMessages.java | 121 +
.../iotdb/db/i18n/StorageEngineMessages.java | 956 ++++++
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 457 ++-
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 1798 +++++++++---
.../iotdb/db/i18n/DataNodeQueryMessages.java | 3057 +++++++++++++++++++-
.../iotdb/db/i18n/DataNodeSchemaMessages.java | 122 +-
.../iotdb/db/i18n/StorageEngineMessages.java | 888 +++++-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 30 +-
.../iotdb/db/auth/ClusterAuthorityFetcher.java | 4 +-
.../org/apache/iotdb/db/auth/LoginLockManager.java | 12 +-
.../apache/iotdb/db/conf/DataNodeMemoryConfig.java | 43 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 35 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 61 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 42 +-
.../db/conf/rest/IoTDBRestServiceDescriptor.java | 4 +-
.../dataregion/DataExecutionVisitor.java | 16 +-
.../dataregion/DataRegionStateMachine.java | 26 +-
.../schemaregion/SchemaExecutionVisitor.java | 16 +-
.../schemaregion/SchemaRegionStateMachine.java | 30 +-
.../db/exception/BadNodeUrlFormatException.java | 6 +-
.../iotdb/db/exception/BatchProcessException.java | 5 +-
.../exception/DataTypeInconsistentException.java | 6 +-
.../exception/QueryInBatchStatementException.java | 3 +-
.../exception/StorageEngineReadonlyException.java | 4 +-
.../exception/StorageGroupNotReadyException.java | 4 +-
.../ainode/AINodeConnectionException.java | 4 +-
.../db/exception/load/LoadReadOnlyException.java | 4 +-
.../load/PartitionViolationException.java | 6 +-
.../load/RegionReplicaSetChangedException.java | 6 +-
.../metadata/AliasAlreadyExistException.java | 3 +-
.../metadata/DataTypeMismatchException.java | 13 +-
.../metadata/DatabaseAlreadySetException.java | 3 +-
.../metadata/DatabaseNotSetException.java | 6 +-
.../metadata/DuplicateInsertException.java | 3 +-
.../metadata/IllegalParameterOfPathException.java | 4 +-
.../metadata/MNodeTypeMismatchException.java | 5 +-
.../metadata/MeasurementAlreadyExistException.java | 3 +-
.../metadata/MeasurementInBlackListException.java | 3 +-
.../metadata/PathAlreadyExistException.java | 3 +-
.../exception/metadata/PathNotExistException.java | 18 +-
.../SchemaDirCreationFailureException.java | 3 +-
.../metadata/SchemaQuotaExceededException.java | 13 +-
.../metadata/SeriesOverflowException.java | 5 +-
.../metadata/cache/MNodeNotCachedException.java | 3 +-
.../metadata/cache/MNodeNotPinnedException.java | 3 +-
.../schemafile/ColossalRecordException.java | 8 +-
.../schemafile/RecordDuplicatedException.java | 3 +-
.../SchemaFileLogCorruptedException.java | 3 +-
.../metadata/schemafile/SchemaFileNotExists.java | 3 +-
.../schemafile/SchemaPageOverflowException.java | 4 +-
.../schemafile/SegmentNotFoundException.java | 7 +-
.../schemafile/SegmentOverflowException.java | 10 +-
.../template/DifferentTemplateException.java | 4 +-
.../template/DuplicatedTemplateException.java | 3 +-
.../template/TemplateIncompatibleException.java | 14 +-
.../template/TemplateIsInUseException.java | 6 +-
.../template/UndefinedTemplateException.java | 3 +-
.../metadata/view/BrokenViewException.java | 9 +-
.../view/InsertNonWritableViewException.java | 7 +-
.../metadata/view/UnsupportedViewException.java | 3 +-
.../view/ViewContainsAggregationException.java | 4 +-
.../metadata/view/ViewNotExistException.java | 8 +-
.../exception/query/KilledByOthersException.java | 3 +-
.../db/exception/query/OutOfTTLException.java | 3 +-
.../query/QueryTimeoutRuntimeException.java | 3 +-
.../runtime/StorageEngineFailureException.java | 4 +-
.../runtime/TableLostRuntimeException.java | 3 +-
.../db/partition/DataPartitionTableGenerator.java | 2 +-
.../dataregion/PipeDataRegionPluginAgent.java | 4 +-
.../db/pipe/agent/runtime/PipeAgentLauncher.java | 6 +-
.../agent/runtime/PipeDataNodeRuntimeAgent.java | 20 +
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 321 +-
.../task/builder/PipeDataNodeTaskBuilder.java | 35 +-
.../pipe/agent/task/stage/PipeTaskSourceStage.java | 5 +-
.../subtask/processor/PipeProcessorSubtask.java | 5 +-
.../agent/task/subtask/sink/PipeSinkSubtask.java | 45 +-
.../task/subtask/sink/PipeSinkSubtaskManager.java | 100 +-
.../deletion/DeletionResourceManager.java | 8 +-
.../iotdb/db/pipe/event/common/row/PipeRow.java | 10 +-
.../schema/PipeSchemaRegionSnapshotEvent.java | 12 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 15 +-
.../pipe/event/common/tablet/PipeTabletUtils.java | 4 +-
.../tablet/parser/TabletInsertionEventParser.java | 6 +-
.../TabletInsertionEventTablePatternParser.java | 4 +-
.../TabletInsertionEventTreePatternParser.java | 5 +-
.../event/common/terminate/PipeTerminateEvent.java | 4 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 22 +-
.../parser/scan/SinglePageWholeChunkReader.java | 21 +-
.../scan/TsFileInsertionEventScanParser.java | 10 +-
.../table/TsFileInsertionEventTableParser.java | 3 +-
.../processor/aggregate/AggregateProcessor.java | 27 +-
.../CustomizedReadableIntermediateResults.java | 25 +-
.../schemachange/RenameDatabaseProcessor.java | 5 +-
.../twostage/plugin/TwoStageCountProcessor.java | 3 +-
.../protocol/airgap/IoTDBAirGapReceiver.java | 10 +-
.../iotconsensusv2/IoTConsensusV2Receiver.java | 39 +-
.../IoTConsensusV2ReceiverAgent.java | 8 +-
.../legacy/IoTDBLegacyPipeReceiverAgent.java | 13 +-
.../protocol/legacy/loader/DeletionLoader.java | 4 +-
.../protocol/legacy/loader/TsFileLoader.java | 5 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 17 +-
.../visitor/PipePlanToStatementVisitor.java | 4 +-
...aNodeHardlinkOrCopiedFileDirStartupCleaner.java | 3 +-
.../db/pipe/resource/memory/PipeMemoryManager.java | 42 +-
.../resource/tsfile/PipeTsFileResourceManager.java | 4 +-
.../client/IoTDBDataNodeAsyncClientManager.java | 3 +-
.../batch/PipeSchemaRegionWritePlanEventBatch.java | 8 +-
.../evolvable/batch/PipeTabletEventPlainBatch.java | 5 +-
.../request/PipeTransferTabletBatchReq.java | 40 +-
.../request/PipeTransferTabletBatchReqV2.java | 7 +-
.../request/PipeTransferTabletBinaryReq.java | 4 +-
.../request/PipeTransferTabletBinaryReqV2.java | 4 +-
.../request/PipeTransferTabletInsertNodeReq.java | 4 +-
.../request/PipeTransferTabletInsertNodeReqV2.java | 4 +-
.../request/PipeTransferTabletRawReq.java | 21 +-
.../protocol/airgap/IoTDBDataRegionAirGapSink.java | 33 +-
.../airgap/IoTDBSchemaRegionAirGapSink.java | 6 +-
.../iotconsensusv2/IoTConsensusV2SyncSink.java | 17 +-
.../IoTConsensusV2TransferBatchReqBuilder.java | 3 +-
.../sink/protocol/legacy/IoTDBLegacyPipeSink.java | 21 +-
.../sink/protocol/opcda/OpcDaServerHandle.java | 25 +-
.../db/pipe/sink/protocol/opcua/OpcUaSink.java | 5 +-
.../sink/protocol/opcua/client/ClientRunner.java | 25 +-
.../protocol/opcua/server/OpcUaKeyStoreLoader.java | 8 +-
.../sink/protocol/opcua/server/OpcUaNameSpace.java | 8 +-
.../protocol/opcua/server/OpcUaServerBuilder.java | 19 +-
.../thrift/async/IoTDBDataRegionAsyncSink.java | 57 +-
.../handler/PipeTransferTrackableHandler.java | 3 +-
.../async/handler/PipeTransferTsFileHandler.java | 4 +-
.../thrift/sync/IoTDBDataRegionSyncSink.java | 43 +-
.../thrift/sync/IoTDBSchemaRegionSink.java | 19 +-
.../sink/protocol/websocket/WebSocketSink.java | 11 +-
.../sink/protocol/writeback/WriteBackSink.java | 406 ++-
.../pipe/sink/util/TabletStatementConverter.java | 51 +-
.../util/builder/PipeTableModelTsFileBuilder.java | 5 +-
.../util/builder/PipeTreeModelTsFileBuilder.java | 5 +-
.../pipe/sink/util/builder/PipeTsFileBuilder.java | 9 +-
.../sink/util/sorter/PipeInsertEventSorter.java | 5 +-
.../source/dataregion/IoTDBDataRegionSource.java | 17 +-
...istoricalDataRegionTsFileAndDeletionSource.java | 24 +-
.../PipeRealtimeDataRegionHybridSource.java | 125 +-
.../realtime/PipeRealtimeDataRegionLogSource.java | 6 +-
.../realtime/PipeRealtimeDataRegionSource.java | 7 +-
.../realtime/assigner/PipeDataRegionAssigner.java | 6 +-
.../schemaregion/IoTDBSchemaRegionSource.java | 4 +-
.../PipeTableStatementToPlanVisitor.java | 4 +-
.../PipeTreeStatementToPlanVisitor.java | 4 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 23 +-
.../iotdb/db/protocol/client/ConfigNodeInfo.java | 4 +-
.../iotdb/db/protocol/client/an/AINodeClient.java | 2 +-
.../iotdb/db/protocol/session/ClientSession.java | 7 +-
.../iotdb/db/protocol/session/IClientSession.java | 5 +-
.../db/protocol/session/InternalClientSession.java | 16 +-
.../db/protocol/session/MqttClientSession.java | 10 +-
.../db/protocol/session/PreparedStatementInfo.java | 13 +-
.../db/protocol/thrift/ProcessorWithMetrics.java | 4 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 8 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 247 +-
.../thrift/impl/PushMultiPipeMetaHelper.java | 86 +
.../db/queryengine/common/MPPQueryContext.java | 5 +-
.../db/queryengine/common/PlanFragmentId.java | 10 +-
.../iotdb/db/queryengine/common/QueryId.java | 19 +-
.../common/header/DatasetHeaderFactory.java | 5 +
.../common/schematree/ClusterSchemaTree.java | 2 +-
.../schematree/node/SchemaMeasurementNode.java | 7 +-
.../queryengine/execution/FutureStateChange.java | 4 +-
.../db/queryengine/execution/QueryIdGenerator.java | 4 +-
.../queryengine/execution/QueryStateMachine.java | 8 +-
.../db/queryengine/execution/StateMachine.java | 42 +-
.../execution/aggregation/AccumulatorFactory.java | 32 +-
.../execution/aggregation/AvgAccumulator.java | 18 +-
.../execution/aggregation/CountAccumulator.java | 12 +-
.../execution/aggregation/CountIfAccumulator.java | 9 +-
.../aggregation/CountTimeAccumulator.java | 9 +-
.../execution/aggregation/ExtremeAccumulator.java | 33 +-
.../aggregation/FirstValueAccumulator.java | 37 +-
.../aggregation/LastValueAccumulator.java | 34 +-
.../aggregation/MaxMinByBaseAccumulator.java | 18 +-
.../execution/aggregation/MaxTimeAccumulator.java | 9 +-
.../execution/aggregation/MaxValueAccumulator.java | 33 +-
.../execution/aggregation/MinTimeAccumulator.java | 9 +-
.../execution/aggregation/MinValueAccumulator.java | 33 +-
.../execution/aggregation/SumAccumulator.java | 17 +-
.../execution/aggregation/TreeAggregator.java | 16 +-
.../execution/aggregation/UDAFAccumulator.java | 22 +-
.../slidingwindow/SlidingWindowAggregator.java | 7 +-
.../timerangeiterator/AggrWindowIterator.java | 4 +-
.../queryengine/execution/driver/DataDriver.java | 4 +-
.../db/queryengine/execution/driver/Driver.java | 31 +-
.../execution/exchange/MPPDataExchangeManager.java | 43 +-
.../execution/exchange/SharedTsBlockQueue.java | 22 +-
.../execution/exchange/sink/LocalSinkChannel.java | 22 +-
.../execution/exchange/sink/ShuffleSinkHandle.java | 20 +-
.../execution/exchange/sink/SinkChannel.java | 52 +-
.../exchange/source/LocalSourceHandle.java | 31 +-
.../execution/exchange/source/SourceHandle.java | 52 +-
.../execution/executor/RegionWriteExecutor.java | 7 +-
.../execution/fragment/DataNodeQueryContext.java | 8 +-
.../fragment/FragmentInstanceContext.java | 33 +-
.../fragment/FragmentInstanceFailureInfo.java | 6 +-
.../fragment/FragmentInstanceManager.java | 16 +-
.../fragment/FragmentInstanceStateMachine.java | 21 +-
.../execution/fragment/FragmentState.java | 7 +-
.../execution/fragment/QueryContext.java | 4 +-
.../queryengine/execution/memory/MemoryPool.java | 85 +-
.../execution/operator/OperatorContext.java | 5 +
.../operator/process/AbstractIntoOperator.java | 4 +-
.../process/InsertTabletStatementGenerator.java | 16 +-
.../operator/process/ProjectOperator.java | 12 +-
.../process/SlidingWindowAggregationOperator.java | 4 +-
.../operator/process/TransformOperator.java | 5 +-
.../operator/process/ai/InferenceOperator.java | 7 +-
.../process/copyto/tsfile/CopyToTsFileOptions.java | 4 +-
.../process/join/FullOuterTimeJoinOperator.java | 6 +-
.../process/join/HorizontallyConcatOperator.java | 5 +-
.../process/join/InnerTimeJoinOperator.java | 7 +-
.../AlignedUpdateViewPathLastCacheOperator.java | 5 +-
.../process/last/UpdateLastCacheOperator.java | 5 +-
.../schema/NodeManageMemoryMergeOperator.java | 8 +-
.../operator/schema/NodePathsConvertOperator.java | 7 +-
.../operator/schema/NodePathsCountOperator.java | 8 +-
.../schema/SchemaQueryOrderByHeatOperator.java | 5 +-
.../schema/source/DeviceAttributeUpdater.java | 13 +-
.../execution/operator/source/FileLoaderUtils.java | 5 +-
.../execution/operator/source/SeriesScanUtil.java | 29 +-
.../relational/AbstractTableScanOperator.java | 5 +-
.../source/relational/CteScanOperator.java | 4 +-
.../relational/DeviceIteratorScanOperator.java | 8 +-
.../InformationSchemaContentSupplierFactory.java | 5 +
.../relational/LastQueryAggTableScanOperator.java | 16 +-
.../MeasurementToTableViewAdaptorUtils.java | 5 +-
...onAlignedDeviceViewAggregationScanOperator.java | 5 +-
.../operator/window/WindowManagerFactory.java | 13 +-
.../execution/schedule/AbstractDriverThread.java | 3 +-
.../execution/schedule/DriverScheduler.java | 9 +-
.../schedule/DriverTaskAbortedException.java | 19 +-
.../schedule/DriverTaskTimeoutSentinelThread.java | 3 +-
.../queue/multilevelqueue/DriverTaskHandle.java | 10 +-
.../multilevelqueue/MultilevelPriorityQueue.java | 16 +-
.../warnings/DefaultWarningCollector.java | 4 +-
.../execution/warnings/IoTDBWarning.java | 8 +-
.../execution/warnings/WarningCode.java | 2 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 6 +-
.../db/queryengine/plan/analyze/Analysis.java | 6 +-
.../db/queryengine/plan/analyze/AnalyzeUtils.java | 28 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 121 +-
.../plan/analyze/ClusterPartitionFetcher.java | 58 +-
.../plan/analyze/ExpressionAnalyzer.java | 15 +-
.../plan/analyze/ExpressionTypeAnalyzer.java | 24 +-
.../queryengine/plan/analyze/ExpressionUtils.java | 5 +-
.../plan/analyze/GroupByLevelHelper.java | 16 +-
.../queryengine/plan/analyze/PredicateUtils.java | 4 +-
.../queryengine/plan/analyze/SelectIntoUtils.java | 6 +-
.../plan/analyze/TemplatedAggregationAnalyze.java | 4 +-
.../queryengine/plan/analyze/TemplatedAnalyze.java | 9 +-
.../db/queryengine/plan/analyze/TypeProvider.java | 11 +-
.../analyze/cache/partition/PartitionCache.java | 53 +-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 41 +-
.../analyze/load/LoadTsFileTableSchemaCache.java | 37 +-
.../analyze/load/LoadTsFileTreeSchemaCache.java | 3 +-
.../load/TreeSchemaAutoCreatorAndVerifier.java | 55 +-
.../analyze/schema/AutoCreateSchemaExecutor.java | 20 +-
.../analyze/schema/ClusterSchemaFetchExecutor.java | 12 +-
.../queryengine/plan/execution/QueryExecution.java | 11 +-
.../plan/execution/config/ConfigExecution.java | 6 +-
.../execution/config/TableConfigTaskVisitor.java | 74 +-
.../execution/config/TreeConfigTaskVisitor.java | 33 +-
.../config/executor/ClusterConfigTaskExecutor.java | 302 +-
.../config/executor/IConfigTaskExecutor.java | 2 +
.../config/metadata/AlterTimeSeriesTask.java | 3 +-
.../config/metadata/region/MigrateRegionTask.java | 2 +-
.../metadata/relational/ShowCreateViewTask.java | 4 +-
.../execution/config/session/DeallocateTask.java | 5 +-
.../plan/execution/config/session/PrepareTask.java | 5 +-
.../config/session/PreparedStatementHelper.java | 5 +-
.../session/PreparedStatementMemoryManager.java | 19 +-
.../ShowRepairDataPartitionTableProgressTask.java} | 54 +-
.../config/sys/pipe/PipeFunctionSupport.java | 4 +-
.../execution/config/sys/pipe/ShowPipeTask.java | 5 +
.../plan/execution/memory/MemorySourceHandle.java | 6 +-
.../BuiltInScalarFunctionHelperFactory.java | 5 +-
.../multi/builtin/helper/DiffFunctionHelper.java | 4 +-
.../builtin/helper/ReplaceFunctionHelper.java | 3 +-
.../multi/builtin/helper/RoundFunctionHelper.java | 4 +-
.../builtin/helper/SubStringFunctionHelper.java | 16 +-
.../expression/other/CaseWhenThenExpression.java | 5 +-
.../plan/expression/unary/RegularExpression.java | 7 +-
.../visitor/ColumnTransformerVisitor.java | 8 +-
.../visitor/ExpressionAnalyzeVisitor.java | 5 +-
.../visitor/IntermediateLayerVisitor.java | 16 +-
.../visitor/TransformToViewExpressionVisitor.java | 7 +-
.../cartesian/BindSchemaForExpressionVisitor.java | 6 +-
.../cartesian/BindSchemaForPredicateVisitor.java | 3 +-
...catDeviceAndBindSchemaForExpressionVisitor.java | 6 +-
.../ConcatDeviceAndBindSchemaForHavingVisitor.java | 4 +-
...ncatDeviceAndBindSchemaForPredicateVisitor.java | 5 +-
.../ConcatExpressionWithSuffixPathsVisitor.java | 3 +-
.../predicate/ConvertPredicateToFilterVisitor.java | 34 +-
.../ConvertPredicateToTimeFilterVisitor.java | 14 +-
.../plan/optimization/AggregationPushDown.java | 18 +-
.../plan/optimization/PredicatePushDown.java | 7 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 169 +-
.../db/queryengine/plan/parser/SqlParseError.java | 9 +-
.../plan/parser/StatementGenerator.java | 9 +-
.../planner/DataNodeTableOperatorGenerator.java | 48 +-
.../plan/planner/LocalExecutionPlanContext.java | 10 +-
.../plan/planner/LocalExecutionPlanner.java | 122 +-
.../plan/planner/LogicalPlanBuilder.java | 3 +-
.../plan/planner/LogicalPlanVisitor.java | 5 +-
.../plan/planner/OperatorTreeGenerator.java | 48 +-
.../plan/planner/PipelineDriverFactory.java | 6 +-
.../distribution/DistributionPlanContext.java | 4 +-
.../planner/distribution/DistributionPlanner.java | 3 +-
.../plan/planner/distribution/SourceRewriter.java | 14 +-
.../distribution/WriteFragmentParallelPlanner.java | 6 +-
.../exceptions/ReplicaSetUnreachableException.java | 3 +-
.../exceptions/RootFIPlacementException.java | 4 +-
.../memory/FakedMemoryReservationManager.java | 3 +
.../NotThreadSafeMemoryReservationManager.java | 111 +-
.../memory/ThreadSafeMemoryReservationManager.java | 5 +
.../plan/AbstractFragmentParallelPlanner.java | 4 +-
.../plan/planner/plan/PlanFragment.java | 8 +-
.../plan/node/DataNodePlanNodeDeserializer.java | 6 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 5 +-
.../plan/node/load/LoadSingleTsFileNode.java | 5 +-
.../plan/node/load/LoadTsFilePieceNode.java | 5 +-
.../metadata/write/view/AlterLogicalViewNode.java | 3 +-
.../metadata/write/view/CreateLogicalViewNode.java | 3 +-
.../planner/plan/node/process/CollectNode.java | 5 +-
.../planner/plan/node/process/DeviceMergeNode.java | 4 +-
.../source/AlignedSeriesAggregationScanNode.java | 3 +-
.../ContinuousSameSearchIndexSeparatorNode.java | 4 +-
.../planner/plan/node/write/DeleteDataNode.java | 3 +-
.../plan/planner/plan/node/write/InsertNode.java | 12 +-
.../planner/plan/node/write/InsertRowNode.java | 7 +-
.../planner/plan/node/write/InsertTabletNode.java | 7 +-
.../plan/node/write/RelationalInsertRowNode.java | 8 +-
.../node/write/RelationalInsertTabletNode.java | 9 +-
.../plan/planner/plan/parameter/OutputColumn.java | 7 +-
.../relational/analyzer/AggregationAnalyzer.java | 57 +-
.../plan/relational/analyzer/Analysis.java | 144 +-
.../plan/relational/analyzer/Analyzer.java | 11 +-
.../relational/analyzer/CanonicalizationAware.java | 3 +-
.../relational/analyzer/ExpressionAnalysis.java | 34 +-
.../relational/analyzer/ExpressionAnalyzer.java | 351 ++-
.../relational/analyzer/ExpressionTreeUtils.java | 7 +-
.../plan/relational/analyzer/Field.java | 34 +-
.../plan/relational/analyzer/FieldId.java | 13 +-
.../analyzer/PatternRecognitionAnalysis.java | 42 +-
.../analyzer/PatternRecognitionAnalyzer.java | 47 +-
.../queryengine/plan/relational/analyzer/README.md | 72 +
.../plan/relational/analyzer/RelationType.java | 12 +-
.../plan/relational/analyzer/ResolvedField.java | 5 +-
.../plan/relational/analyzer/Scope.java | 54 +-
.../analyzer/ScopeReferenceExtractor.java | 3 +-
.../relational/analyzer/StatementAnalyzer.java | 1058 +++++--
.../analyzer/StatementAnalyzerFactory.java | 11 +-
.../predicate/ConvertPredicateToFilterVisitor.java | 70 +-
.../ConvertPredicateToTimeFilterVisitor.java | 22 +-
.../PredicateCombineIntoTableScanChecker.java | 4 +-
.../schema/CheckSchemaPredicateVisitor.java | 10 +-
.../analyzer/tablefunction/ArgumentAnalysis.java | 8 +-
.../analyzer/tablefunction/ArgumentsAnalysis.java | 9 +-
.../tablefunction/TableArgumentAnalysis.java | 15 +-
.../querystats/QueryPlanOptimizerStatistics.java | 4 +-
.../querystats/QueryPlanOptimizerStats.java | 7 +-
.../plan/relational/metadata/DeviceEntry.java | 5 +-
.../metadata/OperatorNotFoundException.java | 17 +-
.../plan/relational/metadata/TableMetadata.java | 7 +-
.../relational/metadata/TableMetadataImpl.java | 445 +--
.../fetcher/DeviceInCacheFilterVisitor.java | 6 +-
.../metadata/fetcher/TableDeviceSchemaFetcher.java | 10 +-
.../fetcher/TableDeviceSchemaValidator.java | 2 +-
.../fetcher/TableHeaderSchemaValidator.java | 87 +-
.../fetcher/cache/TableDeviceCacheEntry.java | 20 +-
.../fetcher/cache/TableDeviceLastCache.java | 44 +-
.../fetcher/cache/TableDeviceSchemaCache.java | 39 +-
.../fetcher/cache/TreeDeviceNormalSchema.java | 13 +-
.../cache/TreeDeviceSchemaCacheManager.java | 6 +-
.../plan/relational/planner/CteMaterializer.java | 9 +-
.../plan/relational/planner/EqualityInference.java | 14 +-
.../relational/planner/ExpressionExtractor.java | 10 +-
.../planner/ExpressionSymbolInliner.java | 6 +-
.../planner/IrExpressionInterpreter.java | 37 +-
.../plan/relational/planner/IrTypeAnalyzer.java | 63 +-
.../plan/relational/planner/LiteralEncoder.java | 14 +-
.../relational/planner/LiteralInterpreter.java | 6 +-
.../plan/relational/planner/NodeAndMappings.java | 5 +-
.../plan/relational/planner/PlanBuilder.java | 13 +-
.../plan/relational/planner/PlanNodeSearcher.java | 22 +-
.../plan/relational/planner/PredicateUtils.java | 6 +-
.../plan/relational/planner/QueryPlanner.java | 163 +-
.../plan/relational/planner/RelationPlan.java | 10 +-
.../plan/relational/planner/RelationPlanner.java | 56 +-
.../plan/relational/planner/ScopeAware.java | 11 +-
.../plan/relational/planner/SubqueryPlanner.java | 38 +-
.../plan/relational/planner/SymbolAllocator.java | 9 +-
.../plan/relational/planner/SymbolsExtractor.java | 5 +-
.../relational/planner/TableLogicalPlanner.java | 20 +-
.../plan/relational/planner/TranslationMap.java | 30 +-
.../planner/distribute/SubPlanGenerator.java | 4 +-
.../distribute/TableDistributedPlanGenerator.java | 49 +-
.../distribute/TableDistributedPlanner.java | 9 +-
.../TableModelTypeProviderExtractor.java | 7 +-
.../relational/planner/ir/ExpressionRewriter.java | 12 +
.../planner/ir/ExpressionTreeRewriter.java | 33 +-
.../plan/relational/planner/ir/IrUtils.java | 10 +-
...ithUncorrelatedScalarSubqueryReconstructor.java | 20 +-
.../planner/ir/SubExpressionExtractor.java | 4 +-
.../planner/iterative/IterativeOptimizer.java | 24 +-
.../plan/relational/planner/iterative/Lookup.java | 3 +-
.../plan/relational/planner/iterative/Memo.java | 18 +-
.../plan/relational/planner/iterative/Plans.java | 5 +-
.../plan/relational/planner/iterative/Rule.java | 5 +-
.../rule/CanonicalizeExpressionRewriter.java | 5 +-
.../iterative/rule/ExpressionRewriteRuleSet.java | 4 +-
.../planner/iterative/rule/ImplementExceptAll.java | 7 +-
.../rule/ImplementExceptDistinctAsUnion.java | 4 +-
.../iterative/rule/ImplementIntersectAll.java | 4 +-
.../rule/ImplementIntersectDistinctAsUnion.java | 4 +-
.../planner/iterative/rule/InlineProjections.java | 5 +-
.../iterative/rule/PruneTableScanColumns.java | 8 +-
.../iterative/rule/PushDownFilterIntoWindow.java | 5 +-
.../rule/PushDownNegationsExpressionRewriter.java | 13 +-
.../iterative/rule/RemoveTrivialFilters.java | 4 +-
.../planner/iterative/rule/SetOperationMerge.java | 11 +-
.../iterative/rule/SetOperationNodeTranslator.java | 37 +-
.../iterative/rule/SimplifyCountOverConstant.java | 5 +-
.../iterative/rule/SimplifyExpressions.java | 9 +-
.../rule/SingleDistinctAggregationToGroupBy.java | 5 +-
...orrelatedDistinctAggregationWithProjection.java | 5 +-
...elatedDistinctAggregationWithoutProjection.java | 5 +-
...mCorrelatedGlobalAggregationWithProjection.java | 7 +-
...rrelatedGlobalAggregationWithoutProjection.java | 7 +-
...CorrelatedGroupedAggregationWithProjection.java | 5 +-
...relatedGroupedAggregationWithoutProjection.java | 5 +-
.../rule/TransformCorrelatedJoinToJoin.java | 7 +-
.../rule/TransformCorrelatedScalarSubquery.java | 6 +-
.../rule/TransformExistsApplyToCorrelatedJoin.java | 7 +-
.../rule/TransformUncorrelatedSubqueryToJoin.java | 4 +-
.../relational/planner/iterative/rule/Util.java | 4 +-
.../planner/node/AggregationTableScanNode.java | 17 +-
.../plan/relational/planner/node/CteScanNode.java | 4 +-
.../plan/relational/planner/node/IntoNode.java | 4 +-
.../planner/node/TreeDeviceViewScanNode.java | 13 +-
.../planner/node/schema/TableDeviceFetchNode.java | 4 +-
.../optimizations/AdaptivePlanOptimizer.java | 7 +-
.../planner/optimizations/Cardinality.java | 6 +-
.../CheckSubqueryNodesAreRewritten.java | 7 +-
.../DataNodeLocationSupplierFactory.java | 22 +-
.../planner/optimizations/JoinUtils.java | 13 +-
.../optimizations/PlanNodeDecorrelator.java | 33 +-
.../planner/optimizations/PlanOptimizer.java | 17 +-
.../PushLimitOffsetIntoTableScan.java | 4 +-
.../optimizations/PushPredicateIntoTableScan.java | 33 +-
.../optimizations/QueryCardinalityUtil.java | 3 +-
.../planner/optimizations/SymbolMapper.java | 8 +-
.../TransformAggregationToStreamable.java | 7 +-
...mQuantifiedComparisonApplyToCorrelatedJoin.java | 29 +-
.../optimizations/UnaliasSymbolReferences.java | 35 +-
.../relational/planner/optimizations/Util.java | 7 +-
.../rowpattern/RowPatternToIrRewriter.java | 7 +-
.../relational/security/ITableAuthCheckerImpl.java | 8 +-
.../security/TreeAccessCheckVisitor.java | 14 +-
.../plan/relational/sql/ParameterExtractor.java | 10 +-
.../plan/relational/sql/ast/AddColumn.java | 8 +-
.../plan/relational/sql/ast/AlterDB.java | 7 +-
.../plan/relational/sql/ast/ColumnDefinition.java | 7 +-
.../plan/relational/sql/ast/CountDB.java | 3 +-
.../plan/relational/sql/ast/CountStatement.java | 3 +-
.../plan/relational/sql/ast/CreateDB.java | 7 +-
.../relational/sql/ast/CreateExternalService.java | 9 +-
.../plan/relational/sql/ast/CreateFunction.java | 20 +-
.../plan/relational/sql/ast/CreateIndex.java | 27 +-
.../plan/relational/sql/ast/CreatePipe.java | 19 +-
.../plan/relational/sql/ast/CreatePipePlugin.java | 12 +-
.../plan/relational/sql/ast/CreateTable.java | 10 +-
.../plan/relational/sql/ast/CreateTopic.java | 10 +-
.../plan/relational/sql/ast/DatabaseStatement.java | 12 +-
.../plan/relational/sql/ast/Deallocate.java | 5 +-
.../plan/relational/sql/ast/Delete.java | 13 +-
.../plan/relational/sql/ast/DescribeTable.java | 5 +-
.../plan/relational/sql/ast/DropColumn.java | 7 +-
.../plan/relational/sql/ast/DropDB.java | 6 +-
.../relational/sql/ast/DropExternalService.java | 6 +-
.../plan/relational/sql/ast/DropFunction.java | 6 +-
.../plan/relational/sql/ast/DropIndex.java | 15 +-
.../plan/relational/sql/ast/DropPipe.java | 5 +-
.../plan/relational/sql/ast/DropPipePlugin.java | 5 +-
.../plan/relational/sql/ast/DropSubscription.java | 6 +-
.../plan/relational/sql/ast/DropTable.java | 6 +-
.../plan/relational/sql/ast/DropTopic.java | 5 +-
.../plan/relational/sql/ast/Execute.java | 10 +-
.../plan/relational/sql/ast/ExecuteImmediate.java | 8 +-
.../plan/relational/sql/ast/Explain.java | 17 +-
.../plan/relational/sql/ast/ExplainAnalyze.java | 9 +-
.../plan/relational/sql/ast/Insert.java | 12 +-
.../plan/relational/sql/ast/LoadTsFile.java | 4 +-
.../plan/relational/sql/ast/MigrateRegion.java | 22 +-
.../plan/relational/sql/ast/Prepare.java | 13 +-
.../plan/relational/sql/ast/Property.java | 20 +-
.../plan/relational/sql/ast/RenameColumn.java | 8 +-
.../plan/relational/sql/ast/RenameTable.java | 8 +-
.../plan/relational/sql/ast/SetColumnComment.java | 7 +-
.../plan/relational/sql/ast/SetProperties.java | 12 +-
.../plan/relational/sql/ast/ShowAINodes.java | 3 +-
.../plan/relational/sql/ast/ShowCluster.java | 11 +-
.../plan/relational/sql/ast/ShowConfigNodes.java | 3 +-
.../plan/relational/sql/ast/ShowDB.java | 3 +-
.../plan/relational/sql/ast/ShowDataNodes.java | 3 +-
.../plan/relational/sql/ast/ShowFunctions.java | 3 +-
.../plan/relational/sql/ast/ShowIndex.java | 9 +-
.../plan/relational/sql/ast/ShowStatement.java | 3 +-
.../plan/relational/sql/ast/ShowTables.java | 7 +-
.../relational/sql/ast/StartExternalService.java | 6 +-
.../plan/relational/sql/ast/StartPipe.java | 5 +-
.../relational/sql/ast/StopExternalService.java | 6 +-
.../plan/relational/sql/ast/StopPipe.java | 5 +-
.../plan/relational/sql/ast/Update.java | 4 +-
.../plan/relational/sql/ast/UpdateAssignment.java | 11 +-
.../queryengine/plan/relational/sql/ast/Use.java | 7 +-
.../relational/sql/ast/WrappedInsertStatement.java | 24 +-
.../relational/sql/parser/AntlrATNCacheFields.java | 20 +-
.../plan/relational/sql/parser/AstBuilder.java | 109 +-
.../plan/relational/sql/parser/ErrorHandler.java | 3 +-
.../plan/relational/sql/parser/SqlParser.java | 12 +-
.../relational/sql/rewrite/StatementRewrite.java | 7 +-
.../plan/relational/sql/util/AstUtil.java | 7 +-
.../plan/relational/type/TypeCoercion.java | 4 +-
.../plan/relational/utils/MoreLists.java | 15 +-
.../plan/scheduler/AsyncPlanNodeSender.java | 6 +-
.../plan/scheduler/ClusterScheduler.java | 3 +-
.../scheduler/FixedRateFragInsStateTracker.java | 12 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 18 +-
.../scheduler/load/LoadTsFileDispatcherImpl.java | 11 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 76 +-
.../queryengine/plan/statement/StatementType.java | 1 +
.../plan/statement/StatementVisitor.java | 7 +
.../plan/statement/component/OrderByComponent.java | 17 +-
.../plan/statement/crud/InsertBaseStatement.java | 6 +-
.../crud/InsertMultiTabletsStatement.java | 4 +-
.../plan/statement/crud/InsertRowStatement.java | 16 +-
.../crud/InsertRowsOfOneDeviceStatement.java | 4 +-
.../plan/statement/crud/InsertRowsStatement.java | 4 +-
.../plan/statement/crud/InsertTabletStatement.java | 14 +-
.../plan/statement/crud/LoadTsFileStatement.java | 16 +-
.../plan/statement/crud/QueryStatement.java | 14 +-
.../metadata/CreateContinuousQueryStatement.java | 10 +-
.../metadata/region/MigrateRegionStatement.java | 14 +-
.../metadata/view/CreateLogicalViewStatement.java | 4 +-
.../statement/sys/SetConfigurationStatement.java | 6 +-
...RepairDataPartitionTableProgressStatement.java} | 11 +-
.../dag/input/ConstantInputReader.java | 4 +-
.../intermediate/ConstantIntermediateLayer.java | 4 +-
.../dag/intermediate/IntermediateLayer.java | 5 +-
.../dag/intermediate/MultiInputLayer.java | 7 +-
.../SingleInputMultiReferenceLayer.java | 4 +-
.../SingleInputSingleReferenceLayer.java | 4 +-
.../unary/scalar/CastFunctionTransformer.java | 29 +-
.../unary/scalar/RoundFunctionTransformer.java | 5 +-
.../dag/udf/UDAFInformationInferrer.java | 4 +-
.../dag/udf/UDTFInformationInferrer.java | 7 +-
.../transformation/dag/util/TransformUtils.java | 7 +-
.../transformation/dag/util/TypeUtils.java | 5 +-
.../db/queryengine/udf/InternalQueryExecutor.java | 7 +-
.../iotdb/db/queryengine/udf/IoTDBLocalImpl.java | 9 +-
.../iotdb/db/queryengine/udf/UDFResultSetImpl.java | 7 +-
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 26 +-
.../mtree/impl/pbtree/MTreeBelowSGCachedImpl.java | 37 +-
.../impl/pbtree/flush/PBTreeFlushExecutor.java | 6 +-
.../schemaregion/mtree/traverser/Traverser.java | 7 +-
.../schemaengine/schemaregion/tag/TagManager.java | 47 +-
.../schemaregion/utils/ResourceByPathUtils.java | 12 +-
.../db/schemaengine/table/DataNodeTableCache.java | 8 +-
.../table/DataNodeTreeViewSchemaUtils.java | 6 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 56 +-
.../iotdb/db/service/DataNodeShutdownHook.java | 12 +-
.../iotdb/db/service/ExternalRPCService.java | 86 +-
.../iotdb/db/service/RegionMigrateService.java | 95 +-
.../org/apache/iotdb/db/service/SettleService.java | 6 +-
.../ExternalServiceManagementService.java | 37 +-
.../metrics/IoTDBInternalLocalReporter.java | 8 +-
.../iotdb/db/storageengine/StorageEngine.java | 42 +-
.../buffer/TimeSeriesMetadataCache.java | 8 +-
.../db/storageengine/dataregion/DataRegion.java | 226 +-
.../BatchCompactionCannotAlignedException.java | 19 +-
.../exception/CompactionExceptionHandler.java | 21 +-
.../CompactionLastTimeCheckFailedException.java | 25 +-
.../CompactionStatisticsCheckFailedException.java | 37 +-
.../CompactionValidationFailedException.java | 6 +-
.../FileCannotTransitToCompactingException.java | 4 +-
.../execute/performer/ICompactionPerformer.java | 7 +-
.../constant/CrossCompactionPerformer.java | 16 +-
.../constant/InnerSeqCompactionPerformer.java | 16 +-
.../constant/InnerUnseqCompactionPerformer.java | 16 +-
.../performer/impl/FastCompactionPerformer.java | 8 +-
.../impl/ReadChunkCompactionPerformer.java | 6 +-
.../impl/ReadPointCompactionPerformer.java | 5 +-
.../RepairUnsortedFileCompactionPerformer.java | 9 +-
.../execute/recover/CompactionRecoverManager.java | 10 +-
.../execute/recover/CompactionRecoverTask.java | 33 +-
.../execute/task/AbstractCompactionTask.java | 30 +-
.../execute/task/CrossSpaceCompactionTask.java | 25 +-
.../execute/task/InnerSpaceCompactionTask.java | 27 +-
.../task/InsertionCrossSpaceCompactionTask.java | 22 +-
.../task/RepairUnsortedFileCompactionTask.java | 9 +-
.../execute/task/SettleCompactionTask.java | 47 +-
.../execute/utils/CompactionTableSchema.java | 7 +-
.../compaction/execute/utils/CompactionUtils.java | 9 +-
...BatchedFastAlignedSeriesCompactionExecutor.java | 4 +-
...edReadChunkAlignedSeriesCompactionExecutor.java | 4 +-
.../fast/reader/CompactionChunkReader.java | 11 +-
.../ReadChunkAlignedSeriesCompactionExecutor.java | 5 +-
.../execute/utils/log/CompactionLogAnalyzer.java | 6 +-
.../execute/utils/log/TsFileIdentifier.java | 11 +-
.../writer/ReadPointCrossCompactionWriter.java | 19 +-
.../compaction/repair/RepairDataFileScanUtil.java | 19 +-
.../repair/RepairTaskRecoverLogParser.java | 3 +-
.../repair/RepairTimePartitionScanTask.java | 21 +-
.../repair/UnsortedFileRepairTaskScheduler.java | 20 +-
.../schedule/CompactionScheduleTaskManager.java | 4 +-
.../schedule/CompactionScheduleTaskWorker.java | 10 +-
.../compaction/schedule/CompactionScheduler.java | 3 +-
.../compaction/schedule/CompactionTaskManager.java | 14 +-
.../compaction/schedule/TTLScheduleTask.java | 8 +-
.../compaction/selector/ICompactionSelector.java | 12 +-
.../estimator/CompactionEstimateUtils.java | 7 +-
.../impl/RewriteCrossSpaceCompactionSelector.java | 28 +-
.../selector/impl/SettleSelectorImpl.java | 6 +-
.../impl/SizeTieredCompactionSelector.java | 3 +-
.../compaction/settle/SettleRequestHandler.java | 4 +-
.../dataregion/compaction/settle/SettleTask.java | 12 +-
.../dataregion/flush/CompressionRatio.java | 12 +-
.../dataregion/flush/MemTableFlushTask.java | 22 +-
.../memtable/AbstractWritableMemChunk.java | 8 +-
.../memtable/AlignedReadOnlyMemChunk.java | 5 +-
.../dataregion/memtable/ReadOnlyMemChunk.java | 12 +-
.../dataregion/memtable/TsFileProcessor.java | 107 +-
.../dataregion/modification/ModificationFile.java | 6 +-
.../modification/v1/ModificationFileV1.java | 6 +-
.../v1/io/LocalTextModificationAccessor.java | 6 +-
.../dataregion/read/QueryDataSource.java | 23 +-
.../dataregion/read/control/FileReaderManager.java | 7 +-
.../read/reader/chunk/MemAlignedPageReader.java | 4 +-
.../read/reader/chunk/MemPageReader.java | 5 +-
.../metadata/DiskAlignedChunkMetadataLoader.java | 2 +-
.../chunk/metadata/DiskChunkMetadataLoader.java | 2 +-
.../read/reader/chunk/metadata/PageMetadata.java | 6 +-
.../dataregion/snapshot/SnapshotLoader.java | 5 +-
.../dataregion/snapshot/SnapshotTaker.java | 4 +-
.../dataregion/tsfile/TsFileResource.java | 46 +-
.../tsfile/generator/TsFileNameGenerator.java | 7 +-
.../dataregion/tsfile/timeindex/FileTimeIndex.java | 38 +-
.../timeindex/FileTimeIndexCacheRecorder.java | 8 +-
.../dataregion/utils/SharedTimeDataBuffer.java | 3 +-
.../dataregion/utils/TsFileResourceUtils.java | 44 +-
.../AbstractTableSizeIndexWriter.java | 5 +-
.../tableDiskUsageIndex/TableDiskUsageIndex.java | 9 +-
.../tsfile/TsFileTableSizeIndexReader.java | 9 +-
.../storageengine/dataregion/wal/WALManager.java | 6 +-
.../allocation/AbstractNodeAllocationStrategy.java | 3 +-
.../dataregion/wal/buffer/WALBuffer.java | 49 +-
.../dataregion/wal/buffer/WALEntry.java | 2 +-
.../wal/checkpoint/CheckpointManager.java | 6 +-
.../wal/exception/BrokenWALFileException.java | 4 +-
.../wal/exception/WALNodeClosedException.java | 4 +-
.../dataregion/wal/io/CheckpointReader.java | 9 +-
.../dataregion/wal/io/WALInputStream.java | 2 +-
.../dataregion/wal/io/WALMetaData.java | 5 +-
.../storageengine/dataregion/wal/node/WALNode.java | 56 +-
.../dataregion/wal/recover/WALNodeRecoverTask.java | 19 +-
.../dataregion/wal/recover/WALRecoverManager.java | 8 +-
.../file/AbstractTsFileRecoverPerformer.java | 3 +-
.../recover/file/SealedTsFileRecoverPerformer.java | 11 +-
.../file/UnsealedTsFileRecoverPerformer.java | 9 +-
.../wal/utils/MemoryControlledWALEntryQueue.java | 12 +-
.../dataregion/wal/utils/WALFileUtils.java | 12 +-
.../db/storageengine/load/LoadTsFileManager.java | 17 +-
.../load/active/ActiveLoadDirScanner.java | 15 +-
.../active/ActiveLoadFailedMessageHandler.java | 18 +-
.../load/active/ActiveLoadPathHelper.java | 5 +-
.../load/active/ActiveLoadTsFileLoader.java | 15 +-
.../load/config/LoadTsFileConfigurator.java | 42 +-
.../LoadConvertedInsertTabletStatement.java | 3 +-
...leStatementDataTypeConvertExecutionVisitor.java | 9 +-
...eeStatementDataTypeConvertExecutionVisitor.java | 17 +-
.../converter/LoadTreeTsFileTabletIterator.java | 20 +-
.../converter/LoadTsFileDataTypeConverter.java | 8 +-
.../db/storageengine/load/disk/MinIOSelector.java | 12 +-
.../memory/LoadTsFileDataCacheMemoryBlock.java | 16 +-
.../load/memory/LoadTsFileMemoryBlock.java | 4 +-
.../load/memory/LoadTsFileMemoryManager.java | 36 +-
.../load/splitter/AlignedChunkData.java | 10 +-
.../splitter/BatchedAlignedValueChunkData.java | 9 +-
.../load/splitter/NonAlignedChunkData.java | 9 +-
.../load/splitter/TsFileSplitter.java | 38 +-
.../rescon/disk/DirectoryChecker.java | 12 +-
.../db/storageengine/rescon/disk/TierManager.java | 4 +-
.../rescon/memory/PrimitiveArrayManager.java | 5 +-
.../db/storageengine/rescon/memory/SystemInfo.java | 69 +-
.../rescon/memory/TimePartitionManager.java | 4 +-
.../storageengine/rescon/quotas/QuotaLimiter.java | 27 +-
.../agent/SubscriptionAgentLauncher.java | 19 +-
.../agent/SubscriptionBrokerAgent.java | 47 +-
.../agent/SubscriptionConsumerAgent.java | 17 +-
.../agent/SubscriptionReceiverAgent.java | 14 +-
.../subscription/agent/SubscriptionTopicAgent.java | 9 +-
.../broker/ConsensusSubscriptionBroker.java | 54 +-
.../db/subscription/broker/SubscriptionBroker.java | 49 +-
.../broker/SubscriptionPrefetchingQueue.java | 70 +-
.../broker/SubscriptionPrefetchingTabletQueue.java | 4 +-
.../broker/SubscriptionPrefetchingTsFileQueue.java | 4 +-
.../TsFileDeduplicationBlockingPendingQueue.java | 4 +-
.../consensus/ConsensusLogToTabletConverter.java | 27 +-
.../consensus/ConsensusPrefetchingQueue.java | 241 +-
.../ConsensusSubscriptionCommitManager.java | 120 +-
.../ConsensusSubscriptionSetupHandler.java | 94 +-
.../broker/consensus/ProgressWALIterator.java | 11 +-
.../event/batch/SubscriptionPipeEventBatch.java | 6 +-
.../SubscriptionPipeEventBatchSegmentLock.java | 3 +-
.../batch/SubscriptionPipeTabletEventBatch.java | 22 +-
.../batch/SubscriptionPipeTsFileEventBatch.java | 4 +-
.../event/cache/SubscriptionPollResponseCache.java | 13 +-
.../response/SubscriptionEventTabletResponse.java | 23 +-
.../response/SubscriptionEventTsFileResponse.java | 21 +-
...nsensusSubscriptionPrefetchingQueueMetrics.java | 12 +-
.../SubscriptionPrefetchingQueueMetrics.java | 10 +-
.../receiver/SubscriptionReceiverV1.java | 130 +-
.../ConsensusSubscriptionPrefetchExecutor.java | 13 +-
.../task/subtask/ConsensusPrefetchSubtask.java | 7 +-
.../task/subtask/SubscriptionSinkSubtask.java | 4 +-
.../subtask/SubscriptionSinkSubtaskLifeCycle.java | 5 +-
.../subtask/SubscriptionSinkSubtaskManager.java | 19 +-
.../org/apache/iotdb/db/tools/DelayAnalyzer.java | 26 +-
.../apache/iotdb/db/tools/IoTDBDataDirViewer.java | 42 +-
.../apache/iotdb/db/tools/TsFileSketchTool.java | 5 +-
.../iotdb/db/tools/TsFileSplitByPartitionTool.java | 16 +-
.../org/apache/iotdb/db/tools/TsFileSplitTool.java | 4 +-
.../db/tools/schema/SRStatementGenerator.java | 10 +-
.../tools/schema/SchemaRegionSnapshotParser.java | 15 +-
.../db/tools/settle/TsFileAndModSettleTool.java | 20 +-
.../iotdb/db/tools/utils/TsFileValidationScan.java | 3 +-
.../iotdb/db/trigger/executor/TriggerExecutor.java | 3 +-
.../db/trigger/executor/TriggerFireVisitor.java | 9 +-
.../trigger/service/TriggerManagementService.java | 5 +-
.../org/apache/iotdb/db/utils/CommonUtils.java | 58 +-
.../iotdb/db/utils/EncodingInferenceUtils.java | 5 +-
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 14 +-
.../org/apache/iotdb/db/utils/ObjectWriter.java | 6 +-
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 18 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 6 +-
.../org/apache/iotdb/db/utils/SetThreadName.java | 4 +-
.../org/apache/iotdb/db/utils/TabletDecoder.java | 2 +-
.../org/apache/iotdb/db/utils/ThreadUtils.java | 6 +-
.../iotdb/db/utils/TimeFilterForDeviceTTL.java | 4 +-
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 21 +-
.../apache/iotdb/db/utils/cte/MemoryReader.java | 18 +-
.../db/utils/datastructure/AlignedTVList.java | 4 +-
.../MergeSortMultiAlignedTVListIterator.java | 5 +-
.../MergeSortMultiTVListIterator.java | 5 +-
.../datastructure/MultiAlignedTVListIterator.java | 5 +-
.../utils/datastructure/MultiTVListIterator.java | 5 +-
.../iotdb/db/utils/datastructure/TVList.java | 8 +-
.../SlidingSizeWindowConfiguration.java | 11 +-
.../SlidingTimeWindowConfiguration.java | 11 +-
.../dataregion/DataRegionStateMachineTest.java | 93 +
.../cache/TreeDeviceSchemaCacheManagerTest.java | 39 +
.../pipe/agent/task/PipeDataNodeTaskAgentTest.java | 159 +
.../task/builder/PipeDataNodeTaskBuilderTest.java | 111 +
.../subtask/sink/PipeSinkSubtaskManagerTest.java | 95 +
.../db/pipe/consensus/DeletionResourceTest.java | 10 +
.../apache/iotdb/db/pipe/sink/PipeSinkTest.java | 213 ++
.../db/pipe/source/PipeRealtimeExtractTest.java | 151 +-
...nternalRPCServiceImplPushMultiPipeMetaTest.java | 246 ++
.../fragment/QueryModificationLoaderTest.java | 3 +
.../execution/operator/CteScanOperatorTest.java | 2 +-
.../config/sys/pipe/ShowPipeTaskTest.java | 72 +
.../parser/MigrateRegionMultiRegionParseTest.java | 63 +
.../parser/RemoveDataNodeMultiNodeParseTest.java | 59 +
.../plan/parser/StatementGeneratorTest.java | 21 +
.../LocalExecutionPlannerOperatorsMemoryTest.java | 164 ++
.../write/InsertNodeIsMeasurementFailedTest.java | 22 +
.../relational/analyzer/SelectAliasReuseTest.java | 413 ++-
... => MigrateRegionMultiRegionStatementTest.java} | 42 +-
...a => RemoveDataNodeMultiNodeStatementTest.java} | 36 +-
iotdb-core/metrics/core/pom.xml | 4 +-
.../metrics/core/i18n/MetricsCoreMessages.java | 5 +
.../metrics/core/i18n/MetricsCoreMessages.java | 5 +
.../apache/iotdb/metrics/core/type/IoTDBTimer.java | 5 +-
iotdb-core/metrics/interface/pom.xml | 8 +-
.../apache/iotdb/metrics/i18n/MetricsMessages.java | 22 +
.../apache/iotdb/metrics/i18n/MetricsMessages.java | 22 +
.../iotdb/metrics/AbstractMetricManager.java | 3 +-
.../apache/iotdb/metrics/CompositeReporter.java | 3 +-
.../metricsets/disk/WindowsDiskMetricsManager.java | 14 +-
.../iotdb/metrics/metricsets/jvm/JvmGcMetrics.java | 10 +-
.../metrics/metricsets/logback/LogbackMetrics.java | 3 +-
.../metrics/metricsets/system/SystemMetrics.java | 5 +-
.../reporter/iotdb/IoTDBSessionReporter.java | 2 +-
.../reporter/prometheus/PrometheusReporter.java | 6 +-
.../org/apache/iotdb/metrics/utils/MetricInfo.java | 5 +-
iotdb-core/metrics/pom.xml | 2 +-
iotdb-core/node-commons/pom.xml | 30 +-
.../conf/iotdb-system.properties.template | 18 +-
.../apache/iotdb/commons/i18n/AuthMessages.java | 7 +
.../apache/iotdb/commons/i18n/ClientMessages.java | 16 +
.../apache/iotdb/commons/i18n/CommonMessages.java | 85 +
.../apache/iotdb/commons/i18n/ConfigMessages.java | 70 +
.../apache/iotdb/commons/i18n/PathMessages.java | 6 +
.../apache/iotdb/commons/i18n/PipeMessages.java | 70 +
.../apache/iotdb/commons/i18n/QueryMessages.java | 292 ++
.../apache/iotdb/commons/i18n/SchemaMessages.java | 15 +
.../apache/iotdb/commons/i18n/UtilMessages.java | 60 +
.../apache/iotdb/commons/i18n/AuthMessages.java | 7 +
.../apache/iotdb/commons/i18n/ClientMessages.java | 16 +
.../apache/iotdb/commons/i18n/CommonMessages.java | 82 +
.../apache/iotdb/commons/i18n/ConfigMessages.java | 70 +
.../apache/iotdb/commons/i18n/PathMessages.java | 6 +
.../apache/iotdb/commons/i18n/PipeMessages.java | 62 +
.../apache/iotdb/commons/i18n/QueryMessages.java | 292 ++
.../apache/iotdb/commons/i18n/SchemaMessages.java | 15 +
.../apache/iotdb/commons/i18n/UtilMessages.java | 62 +-
.../java/org/apache/iotdb/commons/StepTracker.java | 4 +-
.../apache/iotdb/commons/client/ClientManager.java | 8 +-
.../AsyncConfigNodeInternalServiceClient.java | 5 +-
.../async/AsyncDataNodeInternalServiceClient.java | 5 +-
.../client/request/AsyncRequestManager.java | 8 +-
.../sync/SyncThriftClientWithErrorHandler.java | 7 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 180 +-
.../iotdb/commons/conf/CommonDescriptor.java | 28 +
.../iotdb/commons/conf/ConfigurationFileUtils.java | 6 +-
.../iotdb/commons/consensus/ConsensusGroupId.java | 5 +-
.../commons/consensus/index/ProgressIndexType.java | 7 +-
.../index/impl/TimeWindowStateProgressIndex.java | 4 +-
.../commons/disk/strategy/SequenceStrategy.java | 4 +-
.../commons/enums/HandleSystemErrorStrategy.java | 6 +-
.../iotdb/commons/enums/PipeRateAverage.java | 5 +-
... => RepairDataPartitionTableProgressState.java} | 12 +-
.../commons/exception/ConfigurationException.java | 8 +-
.../exception/DiskSpaceInsufficientException.java | 5 +-
.../exception/IllegalPrivilegeException.java | 10 +-
.../commons/exception/ObjectFileNotExist.java | 4 +-
.../commons/exception/PortOccupiedException.java | 8 +-
.../commons/exception/QueryTimeoutException.java | 7 +-
.../exception/auth/AccessDeniedException.java | 3 +-
.../exception/pipe/PipeRuntimeExceptionType.java | 7 +-
.../runtime/SerializationRunTimeException.java | 4 +-
.../exception/table/ColumnNotExistsException.java | 6 +-
.../table/TableAlreadyExistsException.java | 4 +-
.../exception/table/TableNotExistsException.java | 4 +-
.../commons/executable/ExecutableManager.java | 13 +-
.../collections4/bidimap/AbstractDualBidiMap.java | 13 +-
.../collections4/bidimap/DualTreeBidiMap.java | 12 +-
.../commons/file/SystemPropertiesHandler.java | 14 +-
.../commons/memory/AtomicLongMemoryBlock.java | 5 +-
.../apache/iotdb/commons/memory/MemoryManager.java | 42 +-
.../iotdb/commons/partition/DataPartition.java | 3 +-
.../iotdb/commons/partition/SchemaPartition.java | 5 +-
.../executor/SeriesPartitionExecutor.java | 6 +-
.../apache/iotdb/commons/path/MeasurementPath.java | 3 +-
.../org/apache/iotdb/commons/path/PartialPath.java | 3 +-
.../plugin/constructor/PipePluginConstructor.java | 7 +-
.../commons/pipe/agent/task/PipeTaskAgent.java | 50 +-
.../agent/task/execution/PipeSubtaskExecutor.java | 12 +-
.../pipe/agent/task/meta/PipeRuntimeMeta.java | 16 +-
.../commons/pipe/agent/task/meta/PipeTaskMeta.java | 4 +
.../pipe/agent/task/meta/PipeTemporaryMeta.java | 29 +-
.../agent/task/meta/PipeTemporaryMetaInAgent.java | 25 +-
.../task/meta/PipeTemporaryMetaInCoordinator.java | 29 +-
.../task/subtask/PipeAbstractSinkSubtask.java | 57 +-
.../agent/task/subtask/PipeReportableSubtask.java | 40 +-
.../pipe/agent/task/subtask/PipeSubtask.java | 14 +-
.../pipe/datastructure/pattern/TreePattern.java | 4 +-
.../listening/AbstractPipeListeningQueue.java | 4 +-
.../AbstractSerializableListeningQueue.java | 4 +-
.../iotdb/commons/pipe/event/EnrichedEvent.java | 19 +-
.../pipe/receiver/PipeReceiverStatusHandler.java | 4 +-
.../resource/log/PipePeriodicalLogReducer.java | 29 +-
.../pipe/sink/client/IoTDBClientManager.java | 3 +-
.../commons/pipe/sink/client/IoTDBSyncClient.java | 16 +-
.../pipe/sink/client/IoTDBSyncClientManager.java | 6 +-
.../thrift/common/PipeTransferSliceReqHandler.java | 8 +-
.../thrift/request/PipeTransferCompressedReq.java | 6 +-
.../pipe/sink/protocol/IoTDBAirGapSink.java | 7 +-
.../commons/pipe/sink/protocol/IoTDBSink.java | 10 +-
.../pipe/sink/protocol/IoTDBSslSyncSink.java | 4 +-
.../protocol/PipeSinkWithSchedulingDelay.java} | 12 +-
.../pipe/source/IoTDBNonDataRegionSource.java | 3 +-
.../iotdb/commons/pipe/source/IoTDBSource.java | 9 +-
.../iotdb/commons/queryengine/common/NodeRef.java | 4 +-
.../aggregation/grouped/hash/FlatGroupByHash.java | 11 +-
.../aggregation/grouped/hash/FlatHash.java | 12 +-
.../aggregation/grouped/hash/MarkDistinctHash.java | 4 +-
.../grouped/hash/VariableWidthData.java | 4 +-
.../plan/planner/plan/node/PlanNode.java | 2 +-
.../plan/planner/plan/node/TableScanNode.java | 3 +-
.../plan/relational/analyzer/NodeRef.java | 3 +-
.../plan/relational/function/BoundSignature.java | 7 +-
.../plan/relational/function/FunctionId.java | 2 +-
.../function/LongVariableConstraint.java | 7 +-
.../function/ResolvedFunctionCallBuilder.java | 8 +-
.../plan/relational/function/Signature.java | 30 +-
.../function/TypeVariableConstraint.java | 13 +-
.../plan/relational/metadata/ColumnMetadata.java | 18 +-
.../plan/relational/metadata/ColumnSchema.java | 10 +-
.../relational/metadata/FunctionNullability.java | 6 +-
.../plan/relational/metadata/MetadataUtil.java | 13 +-
.../relational/metadata/QualifiedObjectName.java | 11 +-
.../plan/relational/metadata/ResolvedFunction.java | 13 +-
.../plan/relational/planner/Assignments.java | 12 +-
.../planner/DataOrganizationSpecification.java | 5 +-
.../plan/relational/planner/OrderingScheme.java | 15 +-
.../plan/relational/planner/Symbol.java | 10 +-
.../relational/planner/node/AggregationNode.java | 76 +-
.../plan/relational/planner/node/ApplyNode.java | 14 +-
.../relational/planner/node/AssignUniqueId.java | 7 +-
.../plan/relational/planner/node/CollectNode.java | 5 +-
.../planner/node/CorrelatedJoinNode.java | 15 +-
.../plan/relational/planner/node/ExceptNode.java | 7 +-
.../relational/planner/node/IntersectNode.java | 7 +-
.../plan/relational/planner/node/JoinNode.java | 42 +-
.../relational/planner/node/MarkDistinctNode.java | 13 +-
.../plan/relational/planner/node/Measure.java | 7 +-
.../relational/planner/node/MergeSortNode.java | 5 +-
.../plan/relational/planner/node/OutputNode.java | 3 +-
.../planner/node/PatternRecognitionNode.java | 27 +-
.../relational/planner/node/RowNumberNode.java | 4 +-
.../plan/relational/planner/node/SemiJoinNode.java | 19 +-
.../relational/planner/node/SetOperationNode.java | 15 +-
.../relational/planner/node/TableFunctionNode.java | 21 +-
.../planner/node/TableFunctionProcessorNode.java | 11 +-
.../plan/relational/planner/node/TopKNode.java | 5 +-
.../plan/relational/planner/node/ValuesNode.java | 23 +-
.../plan/relational/planner/node/WindowNode.java | 54 +-
.../planner/rowpattern/AggregationLabelSet.java | 4 +-
.../rowpattern/AggregationValuePointer.java | 15 +-
.../planner/rowpattern/ClassifierValuePointer.java | 6 +-
.../rowpattern/ExpressionAndValuePointers.java | 3 +-
.../planner/rowpattern/IrAlternation.java | 7 +-
.../relational/planner/rowpattern/IrAnchor.java | 4 +-
.../planner/rowpattern/IrConcatenation.java | 7 +-
.../relational/planner/rowpattern/IrExclusion.java | 4 +-
.../relational/planner/rowpattern/IrLabel.java | 4 +-
.../rowpattern/IrPatternAlternationOptimizer.java | 3 +-
.../planner/rowpattern/IrPermutation.java | 6 +-
.../planner/rowpattern/IrQuantified.java | 7 +-
.../planner/rowpattern/IrQuantifier.java | 4 +-
.../planner/rowpattern/LogicalIndexPointer.java | 10 +-
.../planner/rowpattern/ScalarValuePointer.java | 8 +-
.../plan/relational/sql/ast/AliasedRelation.java | 12 +-
.../plan/relational/sql/ast/AllColumns.java | 24 +-
.../plan/relational/sql/ast/AllRows.java | 4 +-
.../plan/relational/sql/ast/AnchorPattern.java | 4 +-
.../sql/ast/ArithmeticBinaryExpression.java | 4 +-
.../sql/ast/ArithmeticUnaryExpression.java | 18 +-
.../plan/relational/sql/ast/BetweenPredicate.java | 16 +-
.../plan/relational/sql/ast/BinaryLiteral.java | 8 +-
.../plan/relational/sql/ast/BooleanLiteral.java | 8 +-
.../queryengine/plan/relational/sql/ast/Cast.java | 20 +-
.../relational/sql/ast/CoalesceExpression.java | 14 +-
.../plan/relational/sql/ast/Columns.java | 2 +-
.../relational/sql/ast/ComparisonExpression.java | 14 +-
.../plan/relational/sql/ast/CurrentDatabase.java | 4 +-
.../plan/relational/sql/ast/CurrentTime.java | 12 +-
.../plan/relational/sql/ast/CurrentUser.java | 4 +-
.../plan/relational/sql/ast/DecimalLiteral.java | 8 +-
.../relational/sql/ast/DereferenceExpression.java | 18 +-
.../plan/relational/sql/ast/DoubleLiteral.java | 10 +-
.../plan/relational/sql/ast/Except.java | 12 +-
.../plan/relational/sql/ast/ExcludedPattern.java | 4 +-
.../plan/relational/sql/ast/ExistsPredicate.java | 8 +-
.../plan/relational/sql/ast/Extract.java | 6 +-
.../plan/relational/sql/ast/FieldReference.java | 5 +-
.../queryengine/plan/relational/sql/ast/Fill.java | 12 +-
.../plan/relational/sql/ast/FloatLiteral.java | 3 +-
.../plan/relational/sql/ast/FrameBound.java | 4 +-
.../plan/relational/sql/ast/FunctionCall.java | 40 +-
.../plan/relational/sql/ast/GenericDataType.java | 12 +-
.../plan/relational/sql/ast/GenericLiteral.java | 14 +-
.../plan/relational/sql/ast/GroupBy.java | 4 +-
.../plan/relational/sql/ast/GroupingSets.java | 16 +-
.../plan/relational/sql/ast/Identifier.java | 34 +-
.../plan/relational/sql/ast/IfExpression.java | 12 +-
.../plan/relational/sql/ast/InListExpression.java | 12 +-
.../plan/relational/sql/ast/InPredicate.java | 12 +-
.../plan/relational/sql/ast/Intersect.java | 12 +-
.../relational/sql/ast/IsNotNullPredicate.java | 8 +-
.../plan/relational/sql/ast/IsNullPredicate.java | 8 +-
.../queryengine/plan/relational/sql/ast/Join.java | 38 +-
.../plan/relational/sql/ast/JoinUsing.java | 6 +-
.../plan/relational/sql/ast/LikePredicate.java | 24 +-
.../queryengine/plan/relational/sql/ast/Limit.java | 8 +-
.../plan/relational/sql/ast/LogicalExpression.java | 10 +-
.../plan/relational/sql/ast/LongLiteral.java | 2 +-
.../plan/relational/sql/ast/MeasureDefinition.java | 7 +-
.../plan/relational/sql/ast/NodeLocation.java | 12 +-
.../plan/relational/sql/ast/NotExpression.java | 8 +-
.../plan/relational/sql/ast/NullIfExpression.java | 12 +-
.../plan/relational/sql/ast/NullLiteral.java | 4 +-
.../plan/relational/sql/ast/NumericParameter.java | 8 +-
.../plan/relational/sql/ast/Offset.java | 8 +-
.../plan/relational/sql/ast/OrderBy.java | 14 +-
.../plan/relational/sql/ast/Parameter.java | 4 +-
.../relational/sql/ast/PatternAlternation.java | 6 +-
.../relational/sql/ast/PatternConcatenation.java | 6 +-
.../relational/sql/ast/PatternPermutation.java | 6 +-
.../sql/ast/PatternRecognitionRelation.java | 28 +-
.../plan/relational/sql/ast/PatternVariable.java | 4 +-
.../plan/relational/sql/ast/ProcessingMode.java | 4 +-
.../plan/relational/sql/ast/QualifiedName.java | 12 +-
.../sql/ast/QuantifiedComparisonExpression.java | 22 +-
.../plan/relational/sql/ast/QuantifiedPattern.java | 8 +-
.../queryengine/plan/relational/sql/ast/Query.java | 15 +-
.../relational/sql/ast/QuerySpecification.java | 22 +-
.../plan/relational/sql/ast/RangeQuantifier.java | 6 +-
.../queryengine/plan/relational/sql/ast/Row.java | 10 +-
.../relational/sql/ast/SearchedCaseExpression.java | 32 +-
.../plan/relational/sql/ast/Select.java | 12 +-
.../relational/sql/ast/SimpleCaseExpression.java | 40 +-
.../plan/relational/sql/ast/SimpleGroupBy.java | 12 +-
.../plan/relational/sql/ast/SingleColumn.java | 22 +-
.../plan/relational/sql/ast/SkipTo.java | 10 +-
.../plan/relational/sql/ast/SortItem.java | 4 +-
.../plan/relational/sql/ast/StringLiteral.java | 8 +-
.../relational/sql/ast/SubqueryExpression.java | 8 +-
.../plan/relational/sql/ast/SubsetDefinition.java | 8 +-
.../queryengine/plan/relational/sql/ast/Table.java | 8 +-
.../relational/sql/ast/TableFunctionArgument.java | 6 +-
.../sql/ast/TableFunctionInvocation.java | 6 +-
.../sql/ast/TableFunctionTableArgument.java | 9 +-
.../plan/relational/sql/ast/TableSubquery.java | 4 +-
.../relational/sql/ast/TimeDurationLiteral.java | 8 +-
.../queryengine/plan/relational/sql/ast/Trim.java | 36 +-
.../plan/relational/sql/ast/TypeParameter.java | 4 +-
.../queryengine/plan/relational/sql/ast/Union.java | 12 +-
.../plan/relational/sql/ast/Values.java | 10 +-
.../relational/sql/ast/VariableDefinition.java | 7 +-
.../plan/relational/sql/ast/WhenClause.java | 12 +-
.../plan/relational/sql/ast/WindowDefinition.java | 6 +-
.../plan/relational/sql/ast/WindowFrame.java | 8 +-
.../plan/relational/sql/ast/WindowReference.java | 4 +-
.../relational/sql/ast/WindowSpecification.java | 13 +-
.../queryengine/plan/relational/sql/ast/With.java | 12 +-
.../plan/relational/sql/ast/WithQuery.java | 20 +-
.../relational/sql/parser/ParsingException.java | 5 +-
.../sql/util/CommonQuerySqlFormatter.java | 17 +-
.../relational/sql/util/ExpressionFormatter.java | 8 +-
.../plan/relational/type/NamedTypeSignature.java | 7 +-
.../plan/relational/type/RowFieldName.java | 4 +-
.../queryengine/plan/relational/type/TypeId.java | 4 +-
.../relational/type/TypeNotFoundException.java | 8 +-
.../plan/relational/type/TypeSignature.java | 13 +-
.../relational/type/TypeSignatureParameter.java | 4 +-
.../relational/type/TypeSignatureTranslator.java | 2 +-
.../queryengine/utils/cte/CteDataStore.java | 14 +
.../schema/column/ColumnHeaderConstant.java | 16 +-
.../filter/impl/values/ComparisonFilter.java | 5 +-
.../commons/schema/table/InformationSchema.java | 3 +
.../iotdb/commons/schema/table/TreeViewSchema.java | 10 +-
.../apache/iotdb/commons/schema/ttl/TTLCache.java | 11 +-
.../commons/schema/view/LogicalViewSchema.java | 5 +-
.../security/encrypt/EncryptDecryptException.java | 4 +-
.../service/AbstractThriftServiceThread.java | 8 +-
.../iotdb/commons/service/ThriftService.java | 13 +-
.../subscription/config/SubscriptionConfig.java | 15 +-
.../meta/consumer/CommitProgressKeeper.java | 14 +-
.../meta/consumer/ConsumerGroupMeta.java | 13 +-
.../org/apache/iotdb/commons/sync/PipeInfo.java | 3 +-
.../java/org/apache/iotdb/commons/udf/UDFType.java | 6 +-
.../udf/builtin/UDTFEqualSizeBucketAggSample.java | 4 +-
.../builtin/UDTFEqualSizeBucketOutlierSample.java | 4 +-
.../apache/iotdb/commons/udf/builtin/UDTFM4.java | 11 +-
.../relational/tvf/CumulateTableFunction.java | 4 +-
.../builtin/relational/tvf/M4TableFunction.java | 22 +-
.../relational/tvf/VariationTableFunction.java | 4 +-
.../udf/builtin/relational/tvf/WindowTVFUtils.java | 8 +-
.../commons/udf/service/UDFClassLoaderManager.java | 4 +-
.../org/apache/iotdb/commons/utils/AuthUtils.java | 41 +-
.../org/apache/iotdb/commons/utils/BlobUtils.java | 2 +-
.../org/apache/iotdb/commons/utils/FileUtils.java | 33 +-
.../apache/iotdb/commons/utils/JVMCommonUtils.java | 6 +-
.../apache/iotdb/commons/utils/StatusUtils.java | 79 +-
...monDescriptorDiskSpaceWarningThresholdTest.java | 78 +
.../agent/task/meta/PipeTemporaryMetaTest.java | 92 +
.../resource/log/PipePeriodicalLogReducerTest.java | 65 +
.../iotdb/commons/pipe/task/PipeMetaDeSerTest.java | 26 +
.../commons/pipe/task/PipeSleepIntervalTest.java | 86 +-
iotdb-core/pom.xml | 2 +-
iotdb-core/relational-grammar/pom.xml | 2 +-
.../db/relational/grammar/sql/RelationalSql.g4 | 4 +-
iotdb-protocol/pom.xml | 2 +-
iotdb-protocol/thrift-ainode/pom.xml | 4 +-
iotdb-protocol/thrift-commons/pom.xml | 2 +-
.../thrift-commons/src/main/thrift/common.thrift | 1 +
iotdb-protocol/thrift-confignode/pom.xml | 4 +-
.../src/main/thrift/confignode.thrift | 12 +-
iotdb-protocol/thrift-consensus/pom.xml | 4 +-
iotdb-protocol/thrift-datanode/pom.xml | 4 +-
.../src/main/thrift/datanode.thrift | 14 +
library-udf/pom.xml | 4 +-
.../iotdb/library/i18n/LibraryUdfMessages.java | 35 +
.../iotdb/library/i18n/LibraryUdfMessages.java | 35 +
.../apache/iotdb/library/dlearn/UDTFCluster.java | 16 +-
.../library/dprofile/util/OnePassBucketizer.java | 12 +-
.../library/frequency/UDFEnvelopeAnalysis.java | 3 +-
.../iotdb/library/frequency/util/DWTUtil.java | 6 +-
.../iotdb/library/match/UDAFPatternMatch.java | 5 +-
.../java/org/apache/iotdb/library/util/Util.java | 6 +-
pom.xml | 2 +-
1586 files changed, 37393 insertions(+), 9126 deletions(-)
copy .github/workflows/{dependency-check.yml => zh-locale-compile.yml} (54%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/commit/IoTDBMigrateMultiRegionForIoTV1IT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/iotv1/RegionMigrateFileAssertions.java
copy
integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/manual/{IoTDBPipeMultiSchemaRegionIT.java
=> IoTDBPipeWriteBackSinkIT.java} (60%)
copy
integration-test/src/test/java/org/apache/iotdb/session/it/{IoTDBClientSSLIT.java
=> IoTDBClientMutualSSLIT.java} (62%)
create mode 100644 iotdb-client/client-py/tests/unit/test_session_ssl.py
create mode 100644
iotdb-client/subscription/src/main/java/org/apache/iotdb/session/subscription/consumer/base/EmptyPollLogThrottler.java
create mode 100644
iotdb-client/subscription/src/test/java/org/apache/iotdb/session/subscription/consumer/base/EmptyPollLogThrottlerTest.java
create mode 100644
iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/transformation/dag/util/CastFunctionUtilsTest.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeMemoryConfig.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/region/RemoveRegionGroupProcedure.java
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/{NotifyRegionMigrationState.java
=> RemoveRegionGroupState.java} (93%)
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/conf/ConfigNodeMemoryConfigTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/CompletedProcedureRecyclerTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/pipe/AbstractOperatePipeProcedureV2Test.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/region/RemoveRegionGroupProcedureTest.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/thrift/impl/PushMultiPipeMetaHelper.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/{session/ShowCurrentUserTask.java
=> sys/ShowRepairDataPartitionTableProgressTask.java} (60%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/README.md
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/{RepairDataPartitionTable.java
=> ShowRepairDataPartitionTableProgressStatement.java} (81%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/agent/task/PipeDataNodeTaskAgentTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/agent/task/builder/PipeDataNodeTaskBuilderTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/agent/task/subtask/sink/PipeSinkSubtaskManagerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/protocol/thrift/impl/DataNodeInternalRPCServiceImplPushMultiPipeMetaTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/execution/config/sys/pipe/ShowPipeTaskTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/parser/MigrateRegionMultiRegionParseTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/parser/RemoveDataNodeMultiNodeParseTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/LocalExecutionPlannerOperatorsMemoryTest.java
copy
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/sql/parser/{CountDBStatementTest.java
=> MigrateRegionMultiRegionStatementTest.java} (53%)
copy
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/sql/parser/{CountDBStatementTest.java
=> RemoveDataNodeMultiNodeStatementTest.java} (61%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/enums/{ReadConsistencyLevel.java
=> RepairDataPartitionTableProgressState.java} (76%)
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/distribution/NodeDistributionType.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/sink/protocol/PipeSinkWithSchedulingDelay.java}
(83%)
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/conf/CommonDescriptorDiskSpaceWarningThresholdTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/agent/task/meta/PipeTemporaryMetaTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/resource/log/PipePeriodicalLogReducerTest.java
