This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch test_16968
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from c4b71597e18 try session cpp
add 76d02a58f00 Modify pipeline and automap (#16923)
add b6c13d7e3e8 [AINode] Forecast table function version2 (#16922)
add 5e34c3cffe8 Add IT for GroupNode without partition by (#16924)
add b28786b121f [OBJECT] Support OBJECT type in iotdb (#16925)
add 9386468268e Bump version to 2.0.7-SNAPSHOT (#16926)
add a572c1c9da1 [AINode] Prevent auto_map gets covered and add model_list
for AINodeConcurrentForecastIT (#16928)
add ca26dd36ce4 Pipe: Optimized the key reducer logic & OPC UA sink reuse
logic & value + quality in OPC UA tree client-server model (#16921)
add fd7a3f2c237 Update pyproject.toml (#16931)
add b67f57c2f27 Correct the getObjectPathFromBinary method in
ObjectTypeUtils (#16934)
add 029fbed3d40 fixed the bug that caused incompatible behavior when
comparing int64 or int32 column with double literals in query filter
conditions. (#16917)
add 340a860486f [AINode] Integrate Chronos2 as builtin forecasting model
(#16903)
add 16965de83a0 Implemented the "restrict_object_limit" for object
restriction (#16933)
add 2bdbd41eee8 Pipe: Implemented the processTabletWithCollect api with
tablet collector (#16930)
add ec7fbdaa60c Fix sync objectNode error log (#16939)
add 302864ae1ce Load: Add check for reset memory size to 0 in
LoadTsFileMemoryManager (#16940)
add 7722963223c fix: memory leak during tvlist owner transfer scenario
(#16932)
add 52002e86d2d [AINode] Append model management IT (#16938)
add e9c614eb3ae Add independent ttl check for object file (#16929)
add 609bc289c09 Pipe: Fixed the hardlink bug of plugin meta (#16937)
add 19a4bef273d Support objectLength in Record interface of udf-api
(#16946)
add 9b3bdc40f50 Pipe: Implemented tree auth check for source +
write-back-sink (#16531)
add 8a5e1e3707f feat: add AstMemoryEstimator for SQL AST memory estimation
(#16882)
add c4c8bb76b2f Pipe: support pattern pruning and redundancy removal in
TreePattern parsing (#16789)
add 8e99486f6cd fix: resolve cannot find symbol error in CreatePipe #16951
add 22003b175f2 fix: synchronized method in
ThreadSafeMemoryReservationManager (#16954)
add bd434e37d5c [AINode] Bump version of hmmlearn to 0.3.3 (#16952)
add 1e19eaead87 fix LastQueryScanNode sort #16955
add b4a3e2e52b2 fix: reserve memory for sorting indices during query
execution (#16960)
add 9d9902fa685 Fix insert object segment error when use multiple dirs
(#16965)
add ad0416e00c7 Disabled the repeatable pipe log when the receiver is down
(#16963)
add 82f2dc4c320 Fixed the configMTree deserialisation bug for "root"
database (#16961)
add b75bcc62f9b Pipe: Fixed the bug that batch memory is not visible to
pipe memory management (#16962)
add cb18a95fc01 Pipe: Implemented OPC Sink for outer server & Set
configuration and changed the default value of the server security policies &
Made the default quality configurable and does not throw when non-value/quality
measurement is encountered (#16944)
add fb34acb4756 Support second and third parameter of read_object are not
constant (#16967)
add e879c5497e0 Reduce duplicated DeviceID in compaction selection (#16314)
add a6d65cb36cb Support delete object file (#16945)
add 9478b77da3d fix mem table query bug #16964
add b04f8192231 Pipe: Fixed the unstable OPC UA IT (#16972)
add 4e78cb24959 The grant option check for path privileges was not
correctly logged in the audit log (#16969)
add c3d73e67b04 Pipe: Fixed the unstable OPC UA IT 2 (#16975)
add c5310442e83 Fix insert null object value by tablet error and fix
illegel value insert error message (#16971)
add ebc7d7fdef9 Further optimize the efficiency of memtable region scan
(#16976)
add 0110b34f041 fix the failure message of permission check (#16977)
add ecd7d92f8aa Pipe: Enabled config audit logger & Fixed some checks of
config privilege & keep the tree model show pipes aligned with table model's &
Fixed the bug that password with "-" prefix cannot be directly entered in Cli &
Fixed some pipe ITs & Added the missing source privilege check for
PipeAlterEncodingCompressorPlan (#16957)
add 3ca20a3ce3f Alter column and timeseries datatype with ANSI SQL
statement (#16027)
add 366726f8259 Fixed the path check semantic for object (#16983)
add 3731e34526d Optimized the error log for schema execution (#16982)
add 99ee13dd11e Pipe: Refactored the PipeTaskCoordinatorLock (#16988)
add 0ec2dbda8b7 Pipe: Reduced the log of processor memory control (#16989)
add 412fec5a7c1 [AINode] Update forecast interface (#16978)
add f32f574cd45 Fix incorrect overlap unpack when endTime equals sentinel
value (#16992)
add e7ca49b3998 With clause enhance (#16353)
add d19455db6a0 Apply community-reviewed improvements from Ratis PR #1328
to vulnerability-check workflow (#16995)
add 8dc3a984ef7 [AINode] Upgrade urllib3 (#17002)
add 48dae279e7d No need to init TierManager when using
TsFileResourcePrinter (#17001)
add e78fcbfb54a ignore (#16991)
add 45aff042e02 Detect inconsistent chunk type when querying or compacting
tsfile & fix TsTable(TsTable origin) constructor (#16999)
add c563f9600a4 [AINode] Remove useless groovy check (#17003)
add dab572d24c6 The key cause by load snapshot failure is that nonclude
bytes involved preAlterColumn in these old snapshot data. Due to all data
involved tableNode are stored consecutively in the snapshot file. The content
of each element during serialization is of variable length, making it
impossible to identify the information of preAlteredColumn. So increment a
identify to find the position that can read preAlterColumn. (#17004)
add a524def3c6f Pipe: Fixed the NPE of tree privilege check (#17006)
new 814c6860560 fix
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
LICENSE | 10 +
code-coverage/pom.xml | 2 +-
distribution/pom.xml | 12 +-
example/client-cpp-example/pom.xml | 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 +-
.../apache/iotdb/TableModelSessionPoolExample.java | 2 +-
example/trigger/pom.xml | 2 +-
example/udf/pom.xml | 2 +-
integration-test/pom.xml | 33 +-
.../it/env/cluster/config/MppCommonConfig.java | 18 +
.../env/cluster/config/MppSharedCommonConfig.java | 21 +
.../iotdb/it/env/cluster/node/AINodeWrapper.java | 2 +-
.../iotdb/it/env/cluster/node/DataNodeWrapper.java | 4 +
.../it/env/remote/config/RemoteCommonConfig.java | 15 +
.../org/apache/iotdb/itbase/env/CommonConfig.java | 6 +
.../iotdb/itbase/runtime/ClusterTestResultSet.java | 16 +-
.../iotdb/ainode/it/AINodeCallInferenceIT.java | 24 +-
.../ainode/it/AINodeConcurrentForecastIT.java | 12 +-
.../apache/iotdb/ainode/it/AINodeForecastIT.java | 114 +-
.../iotdb/ainode/it/AINodeModelManageIT.java | 58 +-
.../apache/iotdb/ainode/utils/AINodeTestUtils.java | 48 +-
.../org/apache/iotdb/db/it/IoTDBFlushQueryIT.java | 82 +
.../it/query/IoTDBPredicateConversionTreeIT.java | 293 +++
.../apache/iotdb/db/it/query/IoTDBResultSetIT.java | 11 +-
.../db/it/schema/IoTDBAlterTimeSeriesTypeIT.java | 2736 ++++++++++++++++++++
.../org/apache/iotdb/db/it/utils/TestUtils.java | 30 +-
.../manual/basic/IoTDBPipeLifeCycleIT.java | 230 +-
.../manual/basic/IoTDBPipePermissionIT.java | 4 +-
.../manual/enhanced/IoTDBPipeIdempotentIT.java | 44 +-
.../treemodel/auto/basic/IoTDBPipeDataSinkIT.java | 137 +-
.../treemodel/auto/basic/IoTDBPipeLifeCycleIT.java | 217 +-
.../treemodel/auto/basic/IoTDBPipeProcessorIT.java | 19 +-
.../treemodel/auto/basic/IoTDBPipeProtocolIT.java | 87 +-
.../auto/basic/IoTDBPipeSinkParallelIT.java | 20 +-
.../treemodel/auto/basic/IoTDBPipeSourceIT.java | 460 ++--
.../auto/basic/IoTDBPipeSwitchStatusIT.java | 88 +-
.../treemodel/auto/basic/IoTDBPipeSyntaxIT.java | 376 +--
.../auto/basic/IoTDBTreePatternFormatIT.java | 203 +-
.../auto/enhanced/IoTDBPipeAutoConflictIT.java | 126 +-
.../auto/enhanced/IoTDBPipeAutoDropIT.java | 42 +-
.../auto/enhanced/IoTDBPipeClusterIT.java | 277 +-
.../auto/enhanced/IoTDBPipeIdempotentIT.java | 30 +-
.../auto/enhanced/IoTDBPipeNullValueIT.java | 22 +-
.../auto/enhanced/IoTDBPipeSinkCompressionIT.java | 103 +-
.../auto/enhanced/IoTDBPipeWithLoadIT.java | 17 +-
.../treemodel/auto/enhanced/PipeNowFunctionIT.java | 153 +-
.../treemodel/manual/IoTDBPipeInclusionIT.java | 67 +-
.../manual/IoTDBPipeManualConflictIT.java | 102 +-
.../manual/IoTDBPipeMetaHistoricalIT.java | 67 +-
.../manual/IoTDBPipeMetaLeaderChangeIT.java | 52 +-
.../treemodel/manual/IoTDBPipeMetaRestartIT.java | 52 +-
.../manual/IoTDBPipeMultiSchemaRegionIT.java | 26 +-
.../treemodel/manual/IoTDBPipePermissionIT.java | 204 ++
.../manual/IoTDBPipeTypeConversionISessionIT.java | 10 +-
.../iotdb/pipe/it/single/AbstractPipeSingleIT.java | 2 +-
.../iotdb/pipe/it/single/IoTDBPipeAggregateIT.java | 14 +-
.../iotdb/pipe/it/single/IoTDBPipeOPCUAIT.java | 281 +-
.../pipe/it/single/IoTDBPipePermissionIT.java | 3 +-
.../iotdb/pipe/it/triple/IoTDBPipeForwardIT.java | 2 +
.../relational/it/db/it/IoTDBDeletionTableIT.java | 21 +
.../it/db/it/IoTDBSetSystemStatusTableIT.java | 1 +
.../it/query/object/IoTDBObjectQuery2IT.java | 326 +++
.../it/query/object/IoTDBObjectQueryIT.java | 309 +++
.../it/query/old/IoTDBSimpleQueryTableIT.java | 63 +-
.../scalar/IoTDBScalarFunctionTableIT.java | 16 +-
.../relational/it/query/recent/IoTDBCteIT.java | 531 +++-
.../it/query/recent/IoTDBLengthFunctionIT.java | 2 +-
.../recent/IoTDBPredicateConversionTableIT.java | 379 +++
...BNullValueIT.java => IoTDBTableFunctionIT.java} | 47 +-
.../it/query/recent/IoTExplainAnalyzeIT.java | 264 ++
.../view/recent/IoTDBTableViewAddColumnTest.java | 84 +
.../it/schema/IoTDBAlterColumnTypeIT.java | 2349 +++++++++++++++++
.../iotdb/relational/it/schema/IoTDBTableIT.java | 142 +
.../relational/it/session/IoTDBObjectDeleteIT.java | 363 +++
.../IoTDBObjectDeleteIT2.java} | 20 +-
.../relational/it/session/IoTDBObjectInsertIT.java | 339 +++
.../it/session/IoTDBObjectInsertIT2.java | 170 ++
.../it/session/IoTDBSessionRelationalIT.java | 15 +-
.../IoTDBSubscriptionConsumerGroupIT.java | 68 +-
.../src/test/resources/object-example.pt | Bin 0 -> 1906 bytes
iotdb-api/external-api/pom.xml | 2 +-
iotdb-api/pipe-api/pom.xml | 7 +-
.../{RowCollector.java => DataCollector.java} | 17 +-
.../{RowCollector.java => TabletCollector.java} | 14 +-
.../api/customizer/parameter/PipeParameters.java | 31 +-
.../event/dml/insertion/TabletInsertionEvent.java | 11 +
.../java/org/apache/iotdb/pipe/api/type/Type.java | 5 +-
.../customizer/parameter/PipeParametersTest.java | 19 +-
iotdb-api/pom.xml | 2 +-
iotdb-api/trigger-api/pom.xml | 2 +-
iotdb-api/udf-api/pom.xml | 2 +-
.../iotdb/udf/api/relational/access/Record.java | 52 +-
.../java/org/apache/iotdb/udf/api/type/Type.java | 10 +-
iotdb-client/cli/pom.xml | 22 +-
.../java/org/apache/iotdb/cli/AbstractCli.java | 5 +-
iotdb-client/client-cpp/pom.xml | 4 +-
iotdb-client/client-cpp/src/main/Common.cpp | 1 +
iotdb-client/client-cpp/src/main/Common.h | 3 +-
.../client-cpp/src/main/IoTDBRpcDataSet.cpp | 1 +
iotdb-client/client-cpp/src/main/Session.cpp | 30 +-
iotdb-client/client-cpp/src/main/Session.h | 54 +-
.../client-cpp/src/main/SessionDataSet.cpp | 2 +
.../src/test/cpp/sessionRelationalIT.cpp | 12 +-
iotdb-client/client-py/pom.xml | 8 +-
iotdb-client/isession/pom.xml | 8 +-
.../org/apache/iotdb/isession/SessionDataSet.java | 17 +
iotdb-client/jdbc/pom.xml | 8 +-
.../iotdb/jdbc/IoTDBAbstractDatabaseMetadata.java | 1 +
.../org/apache/iotdb/jdbc/IoTDBJDBCResultSet.java | 29 +-
iotdb-client/pom.xml | 2 +-
iotdb-client/service-rpc/pom.xml | 6 +-
.../org/apache/iotdb/rpc/IoTDBJDBCDataSet.java | 6 +
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 6 +
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 12 +
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 5 +
iotdb-client/session/pom.xml | 10 +-
.../java/org/apache/iotdb/session/Session.java | 8 +-
.../payload/SubscriptionSessionDataSet.java | 1 +
.../apache/iotdb/session/util/SessionUtils.java | 3 +
.../ainode/core/inference/inference_request.py | 19 +-
.../core/inference/inference_request_pool.py | 12 +-
.../core/inference/pipeline/basic_pipeline.py | 174 +-
.../iotdb/ainode/core/manager/inference_manager.py | 62 +-
.../iotdb/ainode/core/manager/model_manager.py | 6 +-
.../iotdb/ainode/core/model/chronos2}/__init__.py | 0
.../iotdb/ainode/core/model/chronos2/base.py | 300 +++
.../ainode/core/model/chronos2/chronos_bolt.py | 703 +++++
.../iotdb/ainode/core/model/chronos2/config.py | 138 +
.../iotdb/ainode/core/model/chronos2/dataset.py | 756 ++++++
.../iotdb/ainode/core/model/chronos2/layers.py | 481 ++++
.../iotdb/ainode/core/model/chronos2/model.py | 909 +++++++
.../core/model/chronos2/pipeline_chronos2.py | 476 ++++
.../iotdb/ainode/core/model/chronos2/utils.py | 242 ++
.../ainode/iotdb/ainode/core/model/model_info.py | 36 +-
.../ainode/iotdb/ainode/core/model/model_loader.py | 17 +-
.../iotdb/ainode/core/model/model_storage.py | 89 +-
.../ainode/core/model/sktime/arima/config.json | 2 +-
.../core/model/sktime/configuration_sktime.py | 8 +-
.../model/sktime/exponential_smoothing/config.json | 2 +-
.../ainode/core/model/sktime/modeling_sktime.py | 18 +-
.../core/model/sktime/naive_forecaster/config.json | 2 +-
.../ainode/core/model/sktime/pipeline_sktime.py | 121 +-
.../core/model/sktime/stl_forecaster/config.json | 2 +-
.../ainode/core/model/sundial/modeling_sundial.py | 13 +-
.../ainode/core/model/sundial/pipeline_sundial.py | 86 +-
.../ainode/core/model/timer_xl/modeling_timer.py | 6 +-
.../ainode/core/model/timer_xl/pipeline_timer.py | 81 +-
iotdb-core/ainode/iotdb/ainode/core/util/serde.py | 24 +-
iotdb-core/ainode/pom.xml | 46 +-
iotdb-core/ainode/pyproject.toml | 6 +-
.../ainode/resources/syncPythonVersion.groovy | 159 --
iotdb-core/antlr/pom.xml | 2 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 40 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 4 +
iotdb-core/confignode/pom.xml | 26 +-
.../client/async/CnToDnAsyncRequestType.java | 1 +
.../CnToDnInternalServiceAsyncRequestManager.java | 6 +
.../rpc/DataNodeAsyncRequestRPCHandler.java | 1 +
.../confignode/conf/SystemPropertiesUtils.java | 15 +
.../consensus/request/ConfigPhysicalPlan.java | 8 +
.../consensus/request/ConfigPhysicalPlanType.java | 3 +
.../request/ConfigPhysicalPlanVisitor.java | 16 +
.../pipe/payload/PipeAlterTimeSeriesPlan.java | 110 +
.../pipe/payload/PipeDeactivateTemplatePlan.java | 2 +-
.../AlterColumnDataTypePlan.java} | 39 +-
.../write/template/CreateSchemaTemplatePlan.java | 2 +-
.../consensus/response/table/DescTableResp.java | 21 +-
.../response/template/TemplateInfoResp.java | 2 +-
.../response/template/TemplateSetInfoResp.java | 2 +-
.../iotdb/confignode/manager/ConfigManager.java | 59 +-
.../apache/iotdb/confignode/manager/IManager.java | 4 +
.../confignode/manager/PermissionManager.java | 7 +-
.../iotdb/confignode/manager/ProcedureManager.java | 39 +-
.../iotdb/confignode/manager/node/NodeManager.java | 1 +
.../pipe/agent/task/PipeConfigNodeTaskStage.java | 8 +-
.../pipe/coordinator/task/PipeTaskCoordinator.java | 16 +-
.../coordinator/task/PipeTaskCoordinatorLock.java | 52 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 513 ++--
.../PipeConfigPhysicalPlanTSStatusVisitor.java | 18 +
.../pipe/source/ConfigRegionListeningFilter.java | 8 +-
.../pipe/source/IoTDBConfigRegionSource.java | 72 +-
...nfigPhysicalPlanTablePrivilegeParseVisitor.java | 389 ---
...ava => PipeConfigTablePatternParseVisitor.java} | 9 +-
.../PipeConfigTablePrivilegeParseVisitor.java | 378 +++
....java => PipeConfigTableScopeParseVisitor.java} | 2 +-
...java => PipeConfigTreePatternParseVisitor.java} | 29 +-
.../PipeConfigTreePrivilegeParseVisitor.java | 610 +++++
...r.java => PipeConfigTreeScopeParseVisitor.java} | 2 +-
.../manager/schema/ClusterSchemaManager.java | 58 +-
.../confignode/persistence/auth/AuthorInfo.java | 7 +
.../persistence/auth/AuthorPlanExecutor.java | 20 +
.../persistence/auth/IAuthorPlanExecutor.java | 5 +
.../persistence/executor/ConfigPlanExecutor.java | 5 +
.../persistence/pipe/PipePluginInfo.java | 33 +-
.../schema/CNPhysicalPlanGenerator.java | 2 +-
.../persistence/schema/ClusterSchemaInfo.java | 70 +-
.../confignode/persistence/schema/ConfigMTree.java | 97 +-
.../persistence/schema/ConfigMTreeStore.java | 2 +-
.../persistence/schema/TemplateTable.java | 2 +-
.../schema/mnode/impl/ConfigTableNode.java | 15 +
.../schema/mnode/info/ConfigTableInfo.java | 16 +
.../schema/AlterEncodingCompressorProcedure.java | 8 +-
.../impl/schema/AlterLogicalViewProcedure.java | 10 +-
.../schema/AlterTimeSeriesDataTypeProcedure.java | 413 +++
.../impl/schema/DataNodeRegionTaskExecutor.java | 17 +-
.../impl/schema/DataNodeTSStatusTaskExecutor.java | 39 +
.../impl/schema/DeactivateTemplateProcedure.java | 34 +-
.../impl/schema/DeleteLogicalViewProcedure.java | 32 +-
.../impl/schema/DeleteTimeSeriesProcedure.java | 25 +-
.../procedure/impl/schema/SchemaUtils.java | 14 +-
.../impl/schema/SetTemplateProcedure.java | 14 +-
.../impl/schema/UnsetTemplateProcedure.java | 2 +-
.../table/AlterTableColumnDataTypeProcedure.java | 212 ++
.../impl/schema/table/DeleteDevicesProcedure.java | 96 +-
.../schema/table/DropTableColumnProcedure.java | 2 +-
...ate.java => AlterTableColumnDataTypeState.java} | 6 +-
...tate.java => AlterTimeSeriesDataTypeState.java} | 8 +-
.../procedure/store/ProcedureFactory.java | 18 +
.../confignode/procedure/store/ProcedureType.java | 5 +
.../thrift/ConfigNodeRPCServiceProcessor.java | 6 +
.../request/ConfigPhysicalPlanSerDeTest.java | 35 +-
...t.java => PipeConfigScopeParseVisitorTest.java} | 2 +-
...=> PipeConfigTablePatternParseVisitorTest.java} | 12 +-
... => PipeConfigTreePatternParseVisitorTest.java} | 25 +-
.../PipeConfigTreePrivilegeParseVisitorTest.java | 316 +++
.../persistence/CNPhysicalPlanGeneratorTest.java | 2 +-
.../iotdb/confignode/persistence/PipeInfoTest.java | 16 +-
.../persistence/schema/ClusterSchemaInfoTest.java | 2 +-
.../persistence/schema/ConfigMTreeTest.java | 2 +-
.../persistence/schema/TemplateTableTest.java | 2 +-
.../pipe/receiver/PipeEnrichedProcedureTest.java | 2 +-
.../schema/DataNodeRegionTaskExecutorTest.java | 81 +
.../schema/DeactivateTemplateProcedureTest.java | 2 +-
.../impl/schema/UnsetTemplateProcedureTest.java | 2 +-
iotdb-core/consensus/pom.xml | 14 +-
iotdb-core/datanode/pom.xml | 52 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 2 +-
.../apache/iotdb/db/conf/DataNodeMemoryConfig.java | 5 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 32 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 48 +
.../dataregion/DataExecutionVisitor.java | 13 +
.../schemaregion/SchemaExecutionVisitor.java | 102 +-
.../ChunkTypeInconsistentException.java} | 30 +-
...ion.java => DataTypeInconsistentException.java} | 9 +-
.../db/pipe/agent/runtime/PipeAgentLauncher.java | 3 +-
.../agent/task/connection/PipeEventCollector.java | 22 +-
.../subtask/processor/PipeProcessorSubtask.java | 28 +-
.../agent/task/subtask/sink/PipeSinkSubtask.java | 2 +-
.../db/pipe/event/common/PipeInsertionEvent.java | 1 +
.../db/pipe/event/common/row/PipeRowCollector.java | 35 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 93 +-
.../common/tablet/PipeRawTabletEventConverter.java | 72 +
.../common/tablet/PipeRawTabletInsertionEvent.java | 34 +-
.../event/common/tablet/PipeTabletCollector.java | 61 +
.../tablet/parser/TabletInsertionEventParser.java | 7 +-
.../TabletInsertionEventTablePatternParser.java | 18 +-
.../TabletInsertionEventTreePatternParser.java | 49 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 124 +-
.../tsfile/parser/TsFileInsertionEventParser.java | 8 +-
.../parser/TsFileInsertionEventParserProvider.java | 26 +-
.../query/TsFileInsertionEventQueryParser.java | 48 +-
.../scan/TsFileInsertionEventScanParser.java | 60 +-
.../table/TsFileInsertionEventTableParser.java | 38 +-
.../processor/aggregate/AggregateProcessor.java | 3 +
.../protocol/thrift/IoTDBDataNodeReceiver.java | 7 +-
.../transform/converter/ValueConverter.java | 6 +-
.../visitor/PipePlanToStatementVisitor.java | 1 +
...leStatementDataTypeConvertExecutionVisitor.java | 2 +-
.../resource/memory/InsertNodeMemoryEstimator.java | 1 +
.../evolvable/batch/PipeTabletEventBatch.java | 6 +
.../batch/PipeTabletEventTsFileBatch.java | 6 +-
.../sink/protocol/legacy/IoTDBLegacyPipeSink.java | 7 +-
.../sink/protocol/opcda/OpcDaServerHandle.java | 2 +
.../db/pipe/sink/protocol/opcua/OpcUaSink.java | 302 ++-
.../sink/protocol/opcua/client/ClientRunner.java | 112 +
.../opcua/client}/IoTDBKeyStoreLoaderClient.java | 35 +-
.../protocol/opcua/client/IoTDBOpcUaClient.java | 301 +++
.../opcua/{ => server}/OpcUaKeyStoreLoader.java | 2 +-
.../opcua/{ => server}/OpcUaNameSpace.java | 171 +-
.../opcua/{ => server}/OpcUaServerBuilder.java | 97 +-
.../thrift/sync/IoTDBSchemaRegionSink.java | 4 +-
.../sink/protocol/writeback/WriteBackSink.java | 68 +-
.../sink/util/sorter/PipeInsertEventSorter.java | 1 +
.../matcher/CachedSchemaPatternMatcher.java | 8 +-
.../schemaregion/IoTDBSchemaRegionSource.java | 80 +-
.../PipePlanTreePrivilegeParseVisitor.java | 355 +++
...r.java => PipeTableStatementToPlanVisitor.java} | 2 +-
.../PipeTreeStatementToPlanVisitor.java | 60 +
.../iotdb/db/protocol/client/ConfigNodeClient.java | 7 +
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 2 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 38 +
.../db/queryengine/common/MPPQueryContext.java | 128 +-
.../common/schematree/ClusterSchemaTree.java | 2 +-
.../queryengine/common/schematree/ISchemaTree.java | 2 +-
.../schematree/visitor/SchemaTreeVisitor.java | 2 +-
.../SchemaTreeVisitorWithLimitOffsetWrapper.java | 2 +-
.../execution/aggregation/AccumulatorFactory.java | 1 +
.../execution/aggregation/AvgAccumulator.java | 1 +
.../execution/aggregation/ExtremeAccumulator.java | 22 +-
.../aggregation/FirstValueAccumulator.java | 37 +-
.../aggregation/LastValueAccumulator.java | 37 +-
.../aggregation/MaxMinByBaseAccumulator.java | 6 +
.../execution/aggregation/MaxValueAccumulator.java | 14 +-
.../execution/aggregation/MinValueAccumulator.java | 14 +-
.../execution/aggregation/SumAccumulator.java | 1 +
.../execution/aggregation/VarianceAccumulator.java | 1 +
.../execution/exchange/SharedTsBlockQueue.java | 4 +
.../exchange/source/LocalSourceHandle.java | 5 +
.../execution/executor/RegionWriteExecutor.java | 27 +-
.../fragment/FragmentInstanceContext.java | 39 +-
.../fragment/FragmentInstanceExecution.java | 33 +-
.../execution/fragment/QueryStatistics.java | 10 +-
.../execution/memory/LocalMemoryManager.java | 1 -
.../execution/operator/AggregationUtil.java | 1 +
.../execution/operator/ExplainAnalyzeOperator.java | 76 +-
.../execution/operator/process/TopKOperator.java | 14 +-
.../operator/process/TransformOperator.java | 1 +
.../operator/process/function/partition/Slice.java | 62 +-
.../process/join/merge/MergeSortComparator.java | 1 +
.../expression/PatternExpressionComputation.java | 5 +-
.../process/window/function/value/LagFunction.java | 1 +
.../window/function/value/LeadFunction.java | 1 +
.../process/window/utils/RowComparator.java | 3 +
.../operator/schema/SchemaFetchScanOperator.java | 2 +-
.../schema/source/SchemaSourceFactory.java | 2 +-
.../schema/source/TimeSeriesSchemaSource.java | 2 +-
.../execution/operator/source/FileLoaderUtils.java | 73 +-
.../execution/operator/source/SeriesScanUtil.java | 715 ++++-
.../source/relational/CteScanOperator.java | 119 +
.../relational/LastQueryAggTableScanOperator.java | 1 +
.../relational/aggregation/AccumulatorFactory.java | 2 +
.../ApproxCountDistinctAccumulator.java | 1 +
.../relational/aggregation/AvgAccumulator.java | 2 +
.../relational/aggregation/ExtremeAccumulator.java | 21 +-
.../relational/aggregation/FirstAccumulator.java | 36 +-
.../relational/aggregation/FirstByAccumulator.java | 22 +-
.../relational/aggregation/LastAccumulator.java | 36 +-
.../relational/aggregation/LastByAccumulator.java | 12 +-
.../aggregation/MaskedRecordIterator.java | 2 -
.../relational/aggregation/MaxAccumulator.java | 22 +-
.../relational/aggregation/MinAccumulator.java | 22 +-
.../relational/aggregation}/RecordIterator.java | 70 +-
.../relational/aggregation/SumAccumulator.java | 2 +
.../aggregation/TableMaxMinByBaseAccumulator.java | 5 +
.../aggregation/TableVarianceAccumulator.java | 2 +
.../UserDefinedAggregateFunctionAccumulator.java | 1 -
.../source/relational/aggregation/Utils.java | 2 +
.../GroupedApproxCountDistinctAccumulator.java | 1 +
.../aggregation/grouped/GroupedAvgAccumulator.java | 1 +
.../grouped/GroupedExtremeAccumulator.java | 8 +
.../grouped/GroupedFirstAccumulator.java | 8 +
.../grouped/GroupedFirstByAccumulator.java | 9 +
.../grouped/GroupedLastAccumulator.java | 8 +
.../grouped/GroupedLastByAccumulator.java | 9 +
.../aggregation/grouped/GroupedMaxAccumulator.java | 8 +
.../grouped/GroupedMaxMinByBaseAccumulator.java | 15 +
.../aggregation/grouped/GroupedMinAccumulator.java | 8 +
.../grouped/GroupedModeAccumulator.java | 4 +
.../aggregation/grouped/GroupedSumAccumulator.java | 1 +
.../GroupedUserDefinedAggregateAccumulator.java | 2 +-
.../grouped/GroupedVarianceAccumulator.java | 1 +
.../operator/window/WindowManagerFactory.java | 2 +
.../relational/ColumnTransformerBuilder.java | 53 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 49 +
.../db/queryengine/plan/analyze/Analysis.java | 2 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 6 +-
.../plan/analyze/ClusterPartitionFetcher.java | 4 +
.../plan/analyze/TemplatedAggregationAnalyze.java | 2 +-
.../queryengine/plan/analyze/TemplatedAnalyze.java | 2 +-
.../analyze/schema/AutoCreateSchemaExecutor.java | 2 +-
.../analyze/schema/ClusterSchemaFetchExecutor.java | 2 +-
.../plan/analyze/schema/ClusterSchemaFetcher.java | 2 +-
.../plan/analyze/schema/ISchemaFetcher.java | 2 +-
.../plan/analyze/schema/TemplateSchemaFetcher.java | 2 +-
.../execution/config/TableConfigTaskVisitor.java | 86 +-
.../execution/config/TreeConfigTaskVisitor.java | 39 +-
.../config/executor/ClusterConfigTaskExecutor.java | 190 +-
.../config/executor/IConfigTaskExecutor.java | 15 +
...ompressorTask.java => AlterTimeSeriesTask.java} | 28 +-
...olumnTask.java => AlterColumnDataTypeTask.java} | 31 +-
.../relational/DescribeTableDetailsTask.java | 14 +-
.../template/ShowNodesInSchemaTemplateTask.java | 2 +-
.../metadata/template/ShowSchemaTemplateTask.java | 2 +-
.../plan/execution/config/session/PrepareTask.java | 3 +-
.../execution/config/sys/pipe/AlterPipeTask.java | 10 +-
.../execution/config/sys/pipe/CreatePipeTask.java | 8 +-
.../execution/config/sys/pipe/ShowPipeTask.java | 5 +-
.../TableModelStatementMemorySourceVisitor.java | 34 +-
.../predicate/ConvertPredicateToFilterVisitor.java | 134 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 126 +-
.../plan/planner/LocalExecutionPlanner.java | 8 +
.../plan/planner/LogicalPlanBuilder.java | 2 +-
.../plan/planner/LogicalPlanVisitor.java | 21 +-
.../plan/planner/OperatorTreeGenerator.java | 2 +
.../plan/planner/TableOperatorGenerator.java | 78 +-
.../plan/planner/distribution/SourceRewriter.java | 7 +-
.../memory/FakedMemoryReservationManager.java | 11 +
.../planner/memory/MemoryReservationManager.java | 29 +
.../NotThreadSafeMemoryReservationManager.java | 23 +
.../memory/ThreadSafeMemoryReservationManager.java | 13 +
.../plan/planner/plan/DistributedQueryPlan.java | 11 +
.../plan/planner/plan/node/PlanGraphPrinter.java | 20 +
.../plan/planner/plan/node/PlanNodeType.java | 8 +
.../plan/planner/plan/node/PlanVisitor.java | 14 +
.../metadata/read/LevelTimeSeriesCountNode.java | 2 +-
.../metadata/read/SeriesSchemaFetchScanNode.java | 2 +-
.../node/metadata/read/TimeSeriesCountNode.java | 2 +-
.../metadata/read/TimeSeriesSchemaScanNode.java | 2 +-
.../node/metadata/write/AlterTimeSeriesNode.java | 87 +-
.../plan/node/pipe/PipeEnrichedInsertNode.java | 7 +
.../plan/node/source/LastQueryScanNode.java | 4 +
.../plan/node/write/InsertMultiTabletsNode.java | 9 +
.../plan/planner/plan/node/write/InsertNode.java | 5 +
.../planner/plan/node/write/InsertRowNode.java | 26 +-
.../planner/plan/node/write/InsertRowsNode.java | 9 +
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 9 +
.../planner/plan/node/write/InsertTabletNode.java | 40 +-
.../plan/planner/plan/node/write/ObjectNode.java | 331 +++
.../plan/node/write/RelationalInsertRowNode.java | 11 +
.../plan/node/write/RelationalInsertRowsNode.java | 57 +-
.../node/write/RelationalInsertTabletNode.java | 147 ++
.../plan/relational/analyzer/Analysis.java | 31 +
.../plan/relational/analyzer/Analyzer.java | 6 +
.../relational/analyzer/ExpressionAnalyzer.java | 8 +-
.../plan/relational/analyzer/Scope.java | 36 +-
.../relational/analyzer/StatementAnalyzer.java | 81 +-
.../analyzer/StatementAnalyzerFactory.java | 4 +
.../predicate/ConvertPredicateToFilterVisitor.java | 116 +-
.../function/TableBuiltinTableFunction.java | 6 +-
.../function/tvf/ClassifyTableFunction.java | 383 +++
.../function/tvf/ForecastTableFunction.java | 325 +--
.../relational/metadata/TableMetadataImpl.java | 45 +-
.../metadata/cache/DeviceSchemaRequestCache.java | 8 +-
.../metadata/fetcher/TableDeviceSchemaFetcher.java | 4 +-
.../fetcher/TableDeviceSchemaValidator.java | 27 +-
.../fetcher/TableHeaderSchemaValidator.java | 13 +-
.../cache/TreeDeviceSchemaCacheManager.java | 2 +-
.../plan/relational/planner/CteMaterializer.java | 355 +++
.../plan/relational/planner/QueryPlanner.java | 50 +-
.../plan/relational/planner/RelationPlanner.java | 135 +-
.../plan/relational/planner/SubqueryPlanner.java | 27 +-
.../relational/planner/TableLogicalPlanner.java | 28 +-
.../planner/distribute/AddExchangeNodes.java | 50 +-
.../distribute/TableDistributedPlanner.java | 17 +-
...ithUncorrelatedScalarSubqueryReconstructor.java | 236 ++
.../plan/relational/planner/node/CteScanNode.java | 132 +
.../PushLimitOffsetIntoTableScan.java | 7 +
.../optimizations/TransformSortToStreamSort.java | 7 +
.../optimizations/UnaliasSymbolReferences.java | 7 +
.../plan/relational/security/AccessControl.java | 10 +
.../relational/security/AccessControlImpl.java | 143 +-
.../relational/security/AllowAllAccessControl.java | 17 +
.../relational/security/ITableAuthCheckerImpl.java | 68 +-
.../security/TreeAccessCheckVisitor.java | 313 ++-
.../plan/relational/sql/AstMemoryEstimator.java | 67 -
.../sql/ast/AbstractQueryDeviceWithCache.java | 21 +
.../relational/sql/ast/AbstractTraverseDevice.java | 48 +
.../plan/relational/sql/ast/AddColumn.java | 13 +
.../plan/relational/sql/ast/AliasedRelation.java | 14 +
.../plan/relational/sql/ast/AllColumns.java | 13 +
.../plan/relational/sql/ast/AllRows.java | 9 +
.../relational/sql/ast/AlterColumnDataType.java | 133 +
.../plan/relational/sql/ast/AlterDB.java | 9 +
.../plan/relational/sql/ast/AlterPipe.java | 15 +
.../plan/relational/sql/ast/AnchorPattern.java | 11 +
.../sql/ast/ArithmeticBinaryExpression.java | 12 +
.../sql/ast/ArithmeticUnaryExpression.java | 11 +
.../plan/relational/sql/ast/AsofJoinOn.java | 11 +
.../sql/ast/AstMemoryEstimationHelper.java | 123 +
.../plan/relational/sql/ast/AstVisitor.java | 4 +
.../plan/relational/sql/ast/BetweenPredicate.java | 13 +
.../plan/relational/sql/ast/BinaryLiteral.java | 11 +
.../plan/relational/sql/ast/BooleanLiteral.java | 10 +
.../queryengine/plan/relational/sql/ast/Cast.java | 12 +
.../plan/relational/sql/ast/ClearCache.java | 11 +
.../relational/sql/ast/CoalesceExpression.java | 11 +
.../plan/relational/sql/ast/ColumnDefinition.java | 15 +
.../plan/relational/sql/ast/Columns.java | 11 +
.../relational/sql/ast/ComparisonExpression.java | 34 +-
.../plan/relational/sql/ast/CountDevice.java | 8 +
.../plan/relational/sql/ast/CountStatement.java | 13 +
.../plan/relational/sql/ast/CreateDB.java | 9 +
.../plan/relational/sql/ast/CreateFunction.java | 13 +
.../plan/relational/sql/ast/CreateIndex.java | 13 +
.../plan/relational/sql/ast/CreateModel.java | 13 +
.../relational/sql/ast/CreateOrUpdateDevice.java | 16 +
.../plan/relational/sql/ast/CreatePipe.java | 52 +-
.../plan/relational/sql/ast/CreatePipePlugin.java | 14 +
.../plan/relational/sql/ast/CreateTable.java | 26 +
.../plan/relational/sql/ast/CreateTopic.java | 13 +
.../plan/relational/sql/ast/CreateTraining.java | 15 +
.../plan/relational/sql/ast/CreateView.java | 14 +
.../plan/relational/sql/ast/CurrentDatabase.java | 11 +
.../plan/relational/sql/ast/CurrentTime.java | 14 +
.../plan/relational/sql/ast/CurrentUser.java | 11 +
.../plan/relational/sql/ast/DatabaseStatement.java | 9 +
.../plan/relational/sql/ast/Deallocate.java | 12 +
.../plan/relational/sql/ast/DecimalLiteral.java | 11 +
.../plan/relational/sql/ast/Delete.java | 12 +
.../plan/relational/sql/ast/DeleteDevice.java | 19 +-
.../relational/sql/ast/DereferenceExpression.java | 13 +
.../plan/relational/sql/ast/DescribeTable.java | 11 +
.../plan/relational/sql/ast/DoubleLiteral.java | 10 +
.../plan/relational/sql/ast/DropColumn.java | 12 +
.../plan/relational/sql/ast/DropDB.java | 11 +
.../plan/relational/sql/ast/DropFunction.java | 11 +
.../plan/relational/sql/ast/DropIndex.java | 12 +
.../plan/relational/sql/ast/DropModel.java | 12 +
.../plan/relational/sql/ast/DropPipe.java | 11 +
.../plan/relational/sql/ast/DropPipePlugin.java | 12 +
.../plan/relational/sql/ast/DropSubscription.java | 12 +
.../plan/relational/sql/ast/DropTable.java | 12 +
.../plan/relational/sql/ast/DropTopic.java | 12 +
.../plan/relational/sql/ast/EmptyPattern.java | 11 +
.../plan/relational/sql/ast/Except.java | 12 +
.../plan/relational/sql/ast/ExcludedPattern.java | 12 +
.../plan/relational/sql/ast/Execute.java | 12 +
.../plan/relational/sql/ast/ExecuteImmediate.java | 13 +
.../plan/relational/sql/ast/ExistsPredicate.java | 12 +
.../plan/relational/sql/ast/Explain.java | 11 +
.../plan/relational/sql/ast/ExplainAnalyze.java | 12 +
.../plan/relational/sql/ast/ExtendRegion.java | 11 +
.../plan/relational/sql/ast/Extract.java | 11 +
.../plan/relational/sql/ast/FetchDevice.java | 19 +
.../plan/relational/sql/ast/FieldReference.java | 11 +
.../queryengine/plan/relational/sql/ast/Fill.java | 16 +
.../plan/relational/sql/ast/FrameBound.java | 13 +
.../plan/relational/sql/ast/FunctionCall.java | 23 +
.../plan/relational/sql/ast/GenericDataType.java | 12 +
.../plan/relational/sql/ast/GenericLiteral.java | 12 +
.../plan/relational/sql/ast/GroupBy.java | 11 +
.../plan/relational/sql/ast/GroupingSets.java | 14 +
.../plan/relational/sql/ast/Identifier.java | 11 +
.../plan/relational/sql/ast/IfExpression.java | 14 +
.../plan/relational/sql/ast/InListExpression.java | 12 +
.../plan/relational/sql/ast/InPredicate.java | 12 +
.../plan/relational/sql/ast/Insert.java | 13 +
.../plan/relational/sql/ast/InsertRow.java | 11 +-
.../plan/relational/sql/ast/InsertRows.java | 14 +-
.../plan/relational/sql/ast/InsertTablet.java | 9 +
.../plan/relational/sql/ast/Intersect.java | 12 +
.../relational/sql/ast/IsNotNullPredicate.java | 11 +
.../plan/relational/sql/ast/IsNullPredicate.java | 11 +
.../queryengine/plan/relational/sql/ast/Join.java | 13 +
.../plan/relational/sql/ast/JoinCriteria.java | 4 +-
.../plan/relational/sql/ast/JoinOn.java | 13 +
.../plan/relational/sql/ast/JoinUsing.java | 11 +
.../plan/relational/sql/ast/KillQuery.java | 12 +
.../plan/relational/sql/ast/LikePredicate.java | 13 +
.../queryengine/plan/relational/sql/ast/Limit.java | 11 +
.../plan/relational/sql/ast/LoadModel.java | 14 +
.../plan/relational/sql/ast/LoadTsFile.java | 36 +
.../plan/relational/sql/ast/LogicalExpression.java | 11 +
.../plan/relational/sql/ast/LongLiteral.java | 13 +-
.../plan/relational/sql/ast/MeasureDefinition.java | 13 +
.../plan/relational/sql/ast/MigrateRegion.java | 10 +
.../plan/relational/sql/ast/NaturalJoin.java | 9 +
.../queryengine/plan/relational/sql/ast/Node.java | 9 +-
.../plan/relational/sql/ast/NotExpression.java | 11 +
.../plan/relational/sql/ast/NullIfExpression.java | 13 +
.../plan/relational/sql/ast/NullLiteral.java | 11 +
.../plan/relational/sql/ast/NumericParameter.java | 11 +
.../plan/relational/sql/ast/Offset.java | 11 +
.../relational/sql/ast/OneOrMoreQuantifier.java | 12 +
.../plan/relational/sql/ast/OrderBy.java | 11 +
.../plan/relational/sql/ast/Parameter.java | 11 +
.../relational/sql/ast/PatternAlternation.java | 12 +
.../relational/sql/ast/PatternConcatenation.java | 12 +
.../relational/sql/ast/PatternPermutation.java | 12 +
.../sql/ast/PatternRecognitionRelation.java | 22 +
.../plan/relational/sql/ast/PatternVariable.java | 12 +
.../plan/relational/sql/ast/PipeEnriched.java | 13 +
.../plan/relational/sql/ast/Prepare.java | 12 +
.../plan/relational/sql/ast/ProcessingMode.java | 11 +
.../plan/relational/sql/ast/Property.java | 12 +
.../plan/relational/sql/ast/QualifiedName.java | 20 +-
.../sql/ast/QuantifiedComparisonExpression.java | 13 +
.../plan/relational/sql/ast/QuantifiedPattern.java | 13 +
.../queryengine/plan/relational/sql/ast/Query.java | 53 +
.../relational/sql/ast/QuerySpecification.java | 22 +
.../plan/relational/sql/ast/RangeQuantifier.java | 14 +
.../plan/relational/sql/ast/ReconstructRegion.java | 11 +
.../sql/ast/RelationalAuthorStatement.java | 19 +
.../plan/relational/sql/ast/RemoveAINode.java | 10 +
.../plan/relational/sql/ast/RemoveConfigNode.java | 10 +
.../plan/relational/sql/ast/RemoveDataNode.java | 11 +
.../plan/relational/sql/ast/RemoveRegion.java | 11 +
.../plan/relational/sql/ast/RenameColumn.java | 14 +
.../plan/relational/sql/ast/RenameTable.java | 13 +
.../queryengine/plan/relational/sql/ast/Row.java | 11 +
.../relational/sql/ast/SearchedCaseExpression.java | 13 +
.../plan/relational/sql/ast/Select.java | 10 +
.../plan/relational/sql/ast/SetColumnComment.java | 13 +
.../plan/relational/sql/ast/SetProperties.java | 12 +
.../plan/relational/sql/ast/SetSqlDialect.java | 10 +
.../plan/relational/sql/ast/SetTableComment.java | 12 +
.../plan/relational/sql/ast/ShowAIDevices.java | 12 +
.../plan/relational/sql/ast/ShowAINodes.java | 11 +
.../plan/relational/sql/ast/ShowAvailableUrls.java | 11 +
.../plan/relational/sql/ast/ShowCluster.java | 11 +
.../plan/relational/sql/ast/ShowClusterId.java | 11 +
.../plan/relational/sql/ast/ShowConfigNodes.java | 11 +
.../plan/relational/sql/ast/ShowConfiguration.java | 1 -
.../relational/sql/ast/ShowCurrentDatabase.java | 11 +
.../relational/sql/ast/ShowCurrentSqlDialect.java | 11 +
.../relational/sql/ast/ShowCurrentTimestamp.java | 11 +
.../plan/relational/sql/ast/ShowCurrentUser.java | 11 +
.../plan/relational/sql/ast/ShowDB.java | 10 +
.../plan/relational/sql/ast/ShowDataNodes.java | 11 +
.../plan/relational/sql/ast/ShowDevice.java | 12 +
.../plan/relational/sql/ast/ShowFunctions.java | 11 +
.../plan/relational/sql/ast/ShowIndex.java | 12 +
.../plan/relational/sql/ast/ShowLoadedModels.java | 13 +
.../plan/relational/sql/ast/ShowModels.java | 12 +
.../plan/relational/sql/ast/ShowPipePlugins.java | 12 +
.../plan/relational/sql/ast/ShowPipes.java | 13 +
.../plan/relational/sql/ast/ShowRegions.java | 13 +
.../plan/relational/sql/ast/ShowStatement.java | 17 +
.../plan/relational/sql/ast/ShowSubscriptions.java | 13 +
.../plan/relational/sql/ast/ShowTables.java | 12 +
.../plan/relational/sql/ast/ShowTopics.java | 13 +
.../plan/relational/sql/ast/ShowVariables.java | 11 +
.../plan/relational/sql/ast/ShowVersion.java | 11 +
.../relational/sql/ast/SimpleCaseExpression.java | 14 +
.../plan/relational/sql/ast/SimpleGroupBy.java | 12 +
.../plan/relational/sql/ast/SingleColumn.java | 15 +
.../plan/relational/sql/ast/SkipTo.java | 12 +
.../plan/relational/sql/ast/SortItem.java | 11 +
.../plan/relational/sql/ast/StartPipe.java | 12 +
.../plan/relational/sql/ast/StopPipe.java | 11 +
.../plan/relational/sql/ast/StringLiteral.java | 11 +
.../relational/sql/ast/SubqueryExpression.java | 12 +
.../plan/relational/sql/ast/SubsetDefinition.java | 14 +
.../plan/relational/sql/ast/SymbolReference.java | 11 +
.../queryengine/plan/relational/sql/ast/Table.java | 11 +
.../relational/sql/ast/TableFunctionArgument.java | 14 +
.../sql/ast/TableFunctionInvocation.java | 14 +
.../sql/ast/TableFunctionTableArgument.java | 15 +
.../plan/relational/sql/ast/TableSubquery.java | 12 +
.../plan/relational/sql/ast/TimeRange.java | 12 +
.../queryengine/plan/relational/sql/ast/Trim.java | 12 +
.../plan/relational/sql/ast/TypeParameter.java | 12 +
.../queryengine/plan/relational/sql/ast/Union.java | 11 +
.../plan/relational/sql/ast/UnloadModel.java | 14 +
.../plan/relational/sql/ast/Update.java | 11 +
.../plan/relational/sql/ast/UpdateAssignment.java | 13 +
.../queryengine/plan/relational/sql/ast/Use.java | 11 +
.../plan/relational/sql/ast/Values.java | 11 +
.../relational/sql/ast/VariableDefinition.java | 13 +
.../plan/relational/sql/ast/WhenClause.java | 12 +
.../plan/relational/sql/ast/WindowDefinition.java | 13 +
.../plan/relational/sql/ast/WindowFrame.java | 14 +
.../plan/relational/sql/ast/WindowReference.java | 12 +
.../relational/sql/ast/WindowSpecification.java | 18 +
.../queryengine/plan/relational/sql/ast/With.java | 11 +
.../plan/relational/sql/ast/WithQuery.java | 42 +-
.../plan/relational/sql/ast/WrappedStatement.java | 5 +
.../relational/sql/ast/ZeroOrMoreQuantifier.java | 12 +
.../relational/sql/ast/ZeroOrOneQuantifier.java | 12 +
.../plan/relational/sql/parser/AstBuilder.java | 31 +-
.../plan/relational/sql/util/AstUtil.java | 30 +
.../plan/relational/sql/util/SqlFormatter.java | 8 +-
.../plan/relational/type/CompatibleResolver.java | 5 +
.../plan/relational/type/InternalTypeManager.java | 6 +
.../relational/utils/ResultColumnAppender.java | 145 ++
.../plan/relational/utils/TypeUtil.java | 13 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 2 +-
.../plan/statement/StatementVisitor.java | 6 +
.../plan/statement/crud/InsertRowStatement.java | 7 +
.../InternalBatchActivateTemplateStatement.java | 2 +-
.../internal/SeriesSchemaFetchStatement.java | 2 +-
....java => AlterTimeSeriesDataTypeStatement.java} | 19 +-
.../metadata/AlterTimeSeriesStatement.java | 15 +-
.../metadata/pipe/AlterPipeStatement.java | 40 +-
.../metadata/pipe/CreatePipeStatement.java | 28 +-
.../template/ActivateTemplateStatement.java | 11 +-
.../template/BatchActivateTemplateStatement.java | 2 +-
.../template/DeactivateTemplateStatement.java | 2 +-
.../db/queryengine/plan/udf/UDTFForecast.java | 2 +
.../FragmentInstanceStatisticsDrawer.java | 26 +-
.../ReadObject2ColumnTransformer.java} | 35 +-
...rmer.java => ReadObject3ColumnTransformer.java} | 77 +-
.../udf/UserDefineScalarFunctionTransformer.java | 2 +-
.../AbstractCastFunctionColumnTransformer.java | 10 +
...r.java => AbstractLengthColumnTransformer.java} | 16 +-
.../unary/scalar/BlobLengthColumnTransformer.java | 25 +-
.../scalar/CastFunctionColumnTransformer.java | 3 +
.../unary/scalar/LengthColumnTransformer.java | 30 +-
.../scalar/ObjectLengthColumnTransformer.java} | 15 +-
.../unary/scalar/ReadObjectColumnTransformer.java | 126 +
.../scalar/TryCastFunctionColumnTransformer.java | 3 +
.../dag/input/ConstantInputReader.java | 1 +
.../unary/ArithmeticNegationTransformer.java | 1 +
.../dag/transformer/unary/InTransformer.java | 2 +
.../unary/scalar/CastFunctionTransformer.java | 7 +
.../unary/scalar/DiffFunctionTransformer.java | 1 +
.../unary/scalar/RoundFunctionTransformer.java | 1 +
.../transformation/dag/util/TransformUtils.java | 2 +
.../transformation/dag/util/TypeUtils.java | 4 +-
.../datastructure/row/SerializableRowList.java | 2 +
.../datastructure/tv/SerializableTVList.java | 1 +
.../rescon/MemSchemaRegionStatistics.java | 2 +-
.../schemaengine/schemaregion/ISchemaRegion.java | 12 +-
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 26 +-
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 19 +-
.../schemaregion/mtree/IMTreeStore.java | 2 +-
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 47 +-
.../schemaregion/mtree/impl/mem/MemMTreeStore.java | 2 +-
.../mtree/impl/mem/mnode/info/LogicalViewInfo.java | 3 +
.../mtree/impl/mem/mnode/info/MeasurementInfo.java | 3 +
.../mnode/iterator/AbstractTraverserIterator.java | 2 +-
.../mnode/iterator/MemoryTraverserIterator.java | 2 +-
.../mtree/impl/pbtree/CachedMTreeStore.java | 2 +-
.../mtree/impl/pbtree/MTreeBelowSGCachedImpl.java | 2 +-
.../pbtree/ReentrantReadOnlyCachedMTreeStore.java | 2 +-
.../mnode/iterator/CachedTraverserIterator.java | 2 +-
.../schemaregion/mtree/traverser/Traverser.java | 2 +-
.../schemaregion/read/req/IShowTimeSeriesPlan.java | 2 +-
.../read/req/SchemaRegionReadPlanFactory.java | 2 +-
.../read/req/impl/ShowTimeSeriesPlanImpl.java | 2 +-
.../read/resp/info/impl/ShowDevicesResult.java | 24 +-
.../schemaregion/utils/MNodeUtils.java | 2 +-
.../schemaregion/utils/ResourceByPathUtils.java | 25 +-
.../template/ClusterTemplateManager.java | 1 +
.../db/schemaengine/template/ITemplateManager.java | 1 +
.../template/TemplateInternalRPCUtil.java | 2 +
.../db/service/metrics/CompactionMetrics.java | 14 +-
.../iotdb/db/service/metrics/FileMetrics.java | 20 +
...ModsFileMetrics.java => ObjectFileMetrics.java} | 44 +-
.../iotdb/db/storageengine/StorageEngine.java | 47 +
.../storageengine/dataregion/Base32ObjectPath.java | 169 ++
.../db/storageengine/dataregion/DataRegion.java | 373 ++-
.../db/storageengine/dataregion/IObjectPath.java | 70 +
.../storageengine/dataregion/PlainObjectPath.java | 126 +
.../performer/impl/FastCompactionPerformer.java | 33 +-
.../impl/ReadChunkCompactionPerformer.java | 7 +-
.../execute/task/AbstractCompactionTask.java | 13 +
.../execute/task/SettleCompactionTask.java | 6 +-
.../subtask/FastCompactionPerformerSubTask.java | 33 +-
.../execute/utils/CompactionSeriesContext.java | 60 +
.../compaction/execute/utils/CompactionUtils.java | 143 +
.../execute/utils/MultiTsFileDeviceIterator.java | 82 +-
.../fast/FastAlignedSeriesCompactionExecutor.java | 31 +-
.../FastNonAlignedSeriesCompactionExecutor.java | 53 +-
.../fast/element/ChunkMetadataElement.java | 10 +-
.../fast/reader/CompactionAlignedChunkReader.java | 8 +-
.../ReadChunkAlignedSeriesCompactionExecutor.java | 31 +-
.../readchunk/SingleSeriesCompactionExecutor.java | 21 +-
.../utils/writer/AbstractCompactionWriter.java | 1 +
.../compaction/repair/RepairDataFileScanUtil.java | 2 +-
.../schedule/CompactionScheduleContext.java | 27 +
.../compaction/schedule/TTLScheduleTask.java | 12 +
.../selector/utils/TsFileResourceCandidate.java | 7 +-
.../dataregion/memtable/AbstractMemTable.java | 12 +-
.../memtable/AbstractWritableMemChunk.java | 4 +-
.../memtable/AlignedReadOnlyMemChunk.java | 39 +-
.../memtable/AlignedWritableMemChunk.java | 133 +-
.../memtable/AlignedWritableMemChunkGroup.java | 7 +
.../dataregion/memtable/IMemTable.java | 4 +
.../memtable/IWritableMemChunkGroup.java | 4 +
.../dataregion/memtable/ReadOnlyMemChunk.java | 37 +-
.../dataregion/memtable/TsFileProcessor.java | 4 +
.../dataregion/memtable/WritableMemChunk.java | 45 +-
.../dataregion/memtable/WritableMemChunkGroup.java | 18 +
.../dataregion/modification/DeletionPredicate.java | 4 +
.../modification/TableDeletionEntry.java | 9 +
.../read/reader/chunk/DiskAlignedChunkLoader.java | 16 +-
.../read/reader/chunk/DiskChunkLoader.java | 17 +
.../read/reader/chunk/MemAlignedPageReader.java | 10 +-
.../read/reader/chunk/MemPageReader.java | 2 +
.../dataregion/tsfile/TsFileResource.java | 13 +-
.../tsfile/timeindex/ArrayDeviceTimeIndex.java | 5 +-
.../dataregion/tsfile/timeindex/FileTimeIndex.java | 3 +-
.../dataregion/tsfile/timeindex/ITimeIndex.java | 10 +-
.../tsfile/timeindex/PlainDeviceTimeIndex.java | 3 +-
.../dataregion/wal/buffer/WALBuffer.java | 3 +
.../dataregion/wal/buffer/WALEntry.java | 6 +
.../dataregion/wal/buffer/WALEntryType.java | 4 +-
.../dataregion/wal/buffer/WALInfoEntry.java | 4 +
.../dataregion/wal/node/IWALNode.java | 3 +
.../dataregion/wal/node/WALFakeNode.java | 6 +
.../storageengine/dataregion/wal/node/WALNode.java | 52 +-
.../file/UnsealedTsFileRecoverPerformer.java | 2 +
...leStatementDataTypeConvertExecutionVisitor.java | 2 +-
.../load/memory/LoadTsFileMemoryManager.java | 19 +-
.../splitter/BatchedAlignedValueChunkData.java | 2 +
.../db/storageengine/rescon/disk/TierManager.java | 99 +
.../rescon/memory/PrimitiveArrayManager.java | 1 +
.../iotdb/db/tools/TsFileResourcePrinter.java | 5 +-
.../iotdb/db/tools/TsFileSplitByPartitionTool.java | 1 +
.../org/apache/iotdb/db/utils/CommonUtils.java | 23 +
.../iotdb/db/utils/EncodingInferenceUtils.java | 1 +
.../java/org/apache/iotdb/db/utils/MemUtils.java | 4 +-
.../org/apache/iotdb/db/utils/ObjectTypeUtils.java | 335 +++
.../org/apache/iotdb/db/utils/ObjectWriter.java | 82 +
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 11 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 266 ++
.../org/apache/iotdb/db/utils/TabletDecoder.java | 1 +
.../apache/iotdb/db/utils/TimeValuePairUtils.java | 2 +
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 1 +
.../apache/iotdb/db/utils/cte/CteDataReader.java | 52 +
.../apache/iotdb/db/utils/cte/CteDataStore.java | 109 +
.../apache/iotdb/db/utils/cte/MemoryReader.java | 75 +
.../db/utils/datastructure/AlignedTVList.java | 162 +-
.../db/utils/datastructure/BackIntTVList.java | 7 +
.../iotdb/db/utils/datastructure/IntTVList.java | 35 +-
.../MergeSortMultiAlignedTVListIterator.java | 1 +
.../MergeSortMultiTVListIterator.java | 1 +
.../datastructure/MultiAlignedTVListIterator.java | 1 +
.../utils/datastructure/MultiTVListIterator.java | 1 +
.../db/utils/datastructure/QuickIntTVList.java | 7 +
.../iotdb/db/utils/datastructure/TVList.java | 41 +-
.../iotdb/db/utils/datastructure/TimIntTVList.java | 7 +
.../db/utils/windowing/window/WindowImpl.java | 1 +
.../schemaregion/SchemaExecutionVisitorTest.java} | 133 +-
.../cache/TreeDeviceSchemaCacheManagerTest.java | 2 +-
.../schemaRegion/SchemaRegionManagementTest.java | 2 +-
.../SchemaRegionSimpleRecoverTest.java | 2 +-
.../schemaRegion/SchemaRegionTemplateTest.java | 2 +-
.../schemaRegion/SchemaRegionTestUtil.java | 2 +-
.../schemaRegion/SchemaStatisticsTest.java | 2 +-
.../pipe/event/PipeTabletInsertionEventTest.java | 91 +-
.../pipe/event/PipeTsFileInsertionEventTest.java | 298 +++
.../pipe/event/TsFileInsertionEventParserTest.java | 41 +-
.../db/pipe/pattern/IoTDBTreePatternTest.java | 36 +
.../db/pipe/pattern/TreePatternPruningTest.java | 156 ++
.../apache/iotdb/db/pipe/sink/PipeSinkTest.java | 102 +
.../source/PipeTreeStatementToPlanVisitorTest.java | 87 +
.../common/schematree/ClusterSchemaTreeTest.java | 2 +-
.../fragment/FragmentInstanceExecutionTest.java | 243 +-
.../execution/operator/CteScanOperatorTest.java | 246 ++
.../predicate/TreePredicateConversionTest.java | 572 ++++
.../plan/analyze/FakeSchemaFetcherImpl.java | 2 +-
.../plan/function/RecordObjectTypeTest.java | 156 ++
.../plan/planner/distribution/LastQueryTest.java | 57 +
.../plan/planner/distribution/Util.java | 2 +-
.../plan/planner/distribution/Util2.java | 2 +-
.../statement/sys/pipe/PipeStatementTest.java | 8 +-
.../plan/relational/analyzer/AnalyzerTest.java | 7 +
.../relational/analyzer/InsertIntoQueryTest.java | 7 +
.../analyzer/LimitOffsetPushDownTest.java | 7 +
.../analyzer/PushAggregationThroughUnionTest.java | 6 +
.../plan/relational/analyzer/SortTest.java | 7 +
.../plan/relational/analyzer/SubQueryTest.java | 7 +
.../relational/analyzer/TableFunctionTest.java | 4 +-
.../relational/planner/CteMaterializerTest.java | 344 +++
.../plan/relational/planner/CteSubqueryTest.java | 168 ++
.../plan/relational/planner/PlanTester.java | 37 +-
.../planner/UncorrelatedSubqueryTest.java | 261 +-
.../planner/assertions/AliasMatcher.java | 8 +
.../planner/assertions/ColumnReference.java | 13 +
.../planner/assertions/CteScanMatcher.java | 86 +
.../planner/assertions/DeviceTableScanMatcher.java | 11 +
.../planner/assertions/PlanMatchPattern.java | 28 +
.../planner/assertions/RvalueMatcher.java | 8 +
.../planner/assertions/TableScanMatcher.java | 17 +
.../predicate/TablePredicateConversionTest.java | 506 ++++
.../relational/sql/AstMemoryEstimatorTest.java | 892 +++++++
.../scalar/BlobLengthColumnTransformerTest.java | 22 +-
.../unary/scalar/ObjectTypeFunctionTest.java | 186 ++
...hTest.java => CompactionDataTypeAlterTest.java} | 136 +-
...tionDataTypeNotMatchAlterableDataTypeTest.java} | 33 +-
.../compaction/CompactionSchedulerTest.java | 35 +
.../FastNonAlignedCrossCompactionTest.java | 5 +
.../ReadPointNonAlignedCrossCompactionTest.java | 4 +
.../object/ObjectTypeCompactionTest.java | 459 ++++
.../memtable/WritableMemChunkRegionScanTest.java | 86 +
.../db/utils/SchemaRegionSnapshotParserTest.java | 2 +-
.../org/apache/iotdb/db/utils/SchemaUtilsTest.java | 39 +
.../db/utils/datastructure/AlignedTVListTest.java | 10 +-
.../db/utils/datastructure/IntTVListTest.java | 11 +-
.../datastructure/PrimitiveArrayManagerTest.java | 1 +
iotdb-core/metrics/core/pom.xml | 4 +-
iotdb-core/metrics/interface/pom.xml | 8 +-
iotdb-core/metrics/pom.xml | 2 +-
iotdb-core/node-commons/pom.xml | 24 +-
.../conf/iotdb-system.properties.template | 25 +
.../iotdb/commons/audit/AbstractAuditLogger.java | 16 +-
.../iotdb/commons/auth/entity/PrivilegeUnion.java | 2 +-
.../iotdb/commons/client/ClientPoolFactory.java | 1 +
.../apache/iotdb/commons/conf/CommonConfig.java | 22 +
.../iotdb/commons/conf/CommonDescriptor.java | 6 +
.../apache/iotdb/commons/conf/IoTDBConstant.java | 6 +
...ntimeException.java => ObjectFileNotExist.java} | 14 +-
.../apache/iotdb/commons/path/MeasurementPath.java | 31 +
.../iotdb/commons/pipe/config/PipeDescriptor.java | 5 +
.../pipe/config/constant/PipeSinkConstant.java | 49 +-
.../datastructure/pattern/IoTDBTreePattern.java | 31 +
.../pipe/datastructure/pattern/TreePattern.java | 490 +++-
.../pattern/UnionIoTDBTreePattern.java | 6 +
.../pattern/WithExclusionIoTDBTreePattern.java | 2 -
.../pattern/WithExclusionTreePattern.java | 2 -
.../commons/pipe/receiver/IoTDBFileReceiver.java | 11 +-
.../pipe/source/IoTDBNonDataRegionSource.java | 14 +-
.../iotdb/commons/pipe/source/IoTDBSource.java | 2 +
.../iotdb/commons/schema/column/ColumnHeader.java | 14 +-
.../iotdb/commons/schema/filter/SchemaFilter.java | 3 +-
.../commons/schema/filter/impl/DataTypeFilter.java | 9 +
.../schema/filter/impl/PathContainsFilter.java | 10 +
.../commons/schema/filter/impl/TagFilter.java | 9 +
.../commons/schema/filter/impl/TemplateFilter.java | 10 +
.../commons/schema/filter/impl/ViewTypeFilter.java | 10 +
.../multichildren/AbstractMultiChildrenFilter.java | 25 +
.../filter/impl/multichildren/AndFilter.java | 9 +
.../schema/filter/impl/multichildren/OrFilter.java | 9 +
.../singlechild/AbstractSingleChildFilter.java | 16 +
.../filter/impl/singlechild/AttributeFilter.java | 10 +
.../schema/filter/impl/singlechild/NotFilter.java | 9 +
.../schema/filter/impl/singlechild/TagFilter.java | 10 +
.../filter/impl/values/ComparisonFilter.java | 10 +
.../schema/filter/impl/values/InFilter.java | 8 +
.../schema/filter/impl/values/LikeFilter.java | 11 +
.../schema/filter/impl/values/PreciseFilter.java | 10 +
.../table/AlterOrDropTableOperationType.java | 5 +-
.../apache/iotdb/commons/schema/table/TsTable.java | 64 +-
.../schema/table/column/AttributeColumnSchema.java | 7 +
.../schema/table/column/FieldColumnSchema.java | 14 +-
.../schema/table/column/TagColumnSchema.java | 6 +
.../schema/table/column/TimeColumnSchema.java | 6 +
.../schema/table/column/TsTableColumnSchema.java | 6 +
.../table/column/TsTableColumnSchemaUtil.java | 12 +
.../iotdb/commons/schema}/template/Template.java | 2 +-
.../tree/AlterTimeSeriesOperationType.java} | 22 +-
.../apache/iotdb/commons/udf/builtin/UDTFAbs.java | 3 +
.../iotdb/commons/udf/builtin/UDTFBottomK.java | 1 +
.../commons/udf/builtin/UDTFCommonDerivative.java | 1 +
.../udf/builtin/UDTFCommonValueDifference.java | 1 +
.../iotdb/commons/udf/builtin/UDTFConst.java | 5 +
.../udf/builtin/UDTFContinuouslySatisfy.java | 2 +
.../udf/builtin/UDTFEqualSizeBucketAggSample.java | 1 +
.../udf/builtin/UDTFEqualSizeBucketM4Sample.java | 1 +
.../builtin/UDTFEqualSizeBucketOutlierSample.java | 1 +
.../builtin/UDTFEqualSizeBucketRandomSample.java | 1 +
.../iotdb/commons/udf/builtin/UDTFInRange.java | 3 +
.../apache/iotdb/commons/udf/builtin/UDTFJexl.java | 3 +
.../apache/iotdb/commons/udf/builtin/UDTFM4.java | 1 +
.../apache/iotdb/commons/udf/builtin/UDTFMath.java | 3 +
.../udf/builtin/UDTFNonNegativeDerivative.java | 1 +
.../builtin/UDTFNonNegativeValueDifference.java | 1 +
.../iotdb/commons/udf/builtin/UDTFOnOff.java | 1 +
.../iotdb/commons/udf/builtin/UDTFSelectK.java | 2 +
.../apache/iotdb/commons/udf/builtin/UDTFTopK.java | 1 +
.../iotdb/commons/udf/builtin/UDTFValueTrend.java | 1 +
.../relational/TableBuiltinScalarFunction.java | 1 +
.../commons/udf/utils/UDFDataTypeTransformer.java | 7 +
.../apache/iotdb/commons/utils/MetadataUtils.java} | 13 +-
.../apache/iotdb/commons/utils/SerializeUtils.java | 6 +
.../apache/iotdb/commons/utils/WindowsOSUtils.java | 64 +
...ommonUtilsTest.java => WindowsOSUtilsTest.java} | 25 +-
iotdb-core/pom.xml | 2 +-
iotdb-core/relational-grammar/pom.xml | 2 +-
.../db/relational/grammar/sql/RelationalSql.g4 | 3 +-
iotdb-protocol/openapi/pom.xml | 2 +-
iotdb-protocol/pom.xml | 2 +-
iotdb-protocol/thrift-ainode/pom.xml | 4 +-
.../thrift-ainode/src/main/thrift/ainode.thrift | 8 +-
iotdb-protocol/thrift-commons/pom.xml | 2 +-
iotdb-protocol/thrift-confignode/pom.xml | 4 +-
.../src/main/thrift/confignode.thrift | 15 +
iotdb-protocol/thrift-consensus/pom.xml | 4 +-
iotdb-protocol/thrift-datanode/pom.xml | 4 +-
.../thrift-datanode/src/main/thrift/client.thrift | 2 +-
.../src/main/thrift/datanode.thrift | 24 +-
library-udf/pom.xml | 4 +-
pom.xml | 14 +-
973 files changed, 40093 insertions(+), 5627 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBPredicateConversionTreeIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/schema/IoTDBAlterTimeSeriesTypeIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/object/IoTDBObjectQuery2IT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/object/IoTDBObjectQueryIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/IoTDBPredicateConversionTableIT.java
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/{IoTDBNullValueIT.java
=> IoTDBTableFunctionIT.java} (50%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/IoTExplainAnalyzeIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/view/recent/IoTDBTableViewAddColumnTest.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/schema/IoTDBAlterColumnTypeIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/session/IoTDBObjectDeleteIT.java
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/{query/old/alignbydevice/IoTDBAlignByDeviceTable3IT.java
=> session/IoTDBObjectDeleteIT2.java} (74%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/session/IoTDBObjectInsertIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/session/IoTDBObjectInsertIT2.java
create mode 100644 integration-test/src/test/resources/object-example.pt
copy
iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/collector/{RowCollector.java
=> DataCollector.java} (71%)
copy
iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/collector/{RowCollector.java
=> TabletCollector.java} (78%)
copy
iotdb-client/service-rpc/src/test/java/org/apache/iotdb/rpc/TSStatusCodeTest.java
=>
iotdb-api/pipe-api/src/test/java/org/apache/iotdb/pipe/api/customizer/parameter/PipeParametersTest.java
(57%)
copy {iotdb-client/client-py/iotdb =>
iotdb-core/ainode/iotdb/ainode/core/model/chronos2}/__init__.py (100%)
create mode 100644 iotdb-core/ainode/iotdb/ainode/core/model/chronos2/base.py
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/chronos2/chronos_bolt.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/core/model/chronos2/config.py
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/chronos2/dataset.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/core/model/chronos2/layers.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/core/model/chronos2/model.py
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/chronos2/pipeline_chronos2.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/core/model/chronos2/utils.py
delete mode 100644 iotdb-core/ainode/resources/syncPythonVersion.groovy
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/pipe/payload/PipeAlterTimeSeriesPlan.java
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{template/DropSchemaTemplatePlan.java
=> table/AlterColumnDataTypePlan.java} (58%)
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/source/PipeConfigPhysicalPlanTablePrivilegeParseVisitor.java
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/source/{PipeConfigPhysicalPlanTablePatternParseVisitor.java
=> PipeConfigTablePatternParseVisitor.java} (95%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/source/PipeConfigTablePrivilegeParseVisitor.java
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/source/{PipeConfigPhysicalPlanTableScopeParseVisitor.java
=> PipeConfigTableScopeParseVisitor.java} (98%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/source/{PipeConfigPhysicalPlanTreePatternParseVisitor.java
=> PipeConfigTreePatternParseVisitor.java} (91%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/source/PipeConfigTreePrivilegeParseVisitor.java
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/source/{PipeConfigPhysicalPlanTreeScopeParseVisitor.java
=> PipeConfigTreeScopeParseVisitor.java} (98%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/AlterTimeSeriesDataTypeProcedure.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/AlterTableColumnDataTypeProcedure.java
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/schema/{AddTableColumnState.java
=> AlterTableColumnDataTypeState.java} (89%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/schema/{DeleteDatabaseState.java
=> AlterTimeSeriesDataTypeState.java} (88%)
rename
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/source/{PipeConfigPhysicalPlanScopeParseVisitorTest.java
=> PipeConfigScopeParseVisitorTest.java} (98%)
rename
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/source/{PipeConfigPhysicalPlanTablePatternParseVisitorTest.java
=> PipeConfigTablePatternParseVisitorTest.java} (95%)
rename
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/source/{PipeConfigPhysicalPlanTreePatternParseVisitorTest.java
=> PipeConfigTreePatternParseVisitorTest.java} (95%)
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/source/PipeConfigTreePrivilegeParseVisitorTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/schema/DataNodeRegionTaskExecutorTest.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{storageengine/dataregion/compaction/selector/utils/DeviceInfo.java
=> exception/ChunkTypeInconsistentException.java} (58%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/{BadNodeUrlFormatException.java
=> DataTypeInconsistentException.java} (74%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tablet/PipeRawTabletEventConverter.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tablet/PipeTabletCollector.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/client/ClientRunner.java
copy {example/pipe-opc-ua-sink/src/main/java/org/apache/iotdb/opcua =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/client}/IoTDBKeyStoreLoaderClient.java
(78%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/client/IoTDBOpcUaClient.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/{
=> server}/OpcUaKeyStoreLoader.java (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/{
=> server}/OpcUaNameSpace.java (75%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/{
=> server}/OpcUaServerBuilder.java (82%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/schemaregion/PipePlanTreePrivilegeParseVisitor.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/schemaregion/{PipeStatementToPlanVisitor.java
=> PipeTableStatementToPlanVisitor.java} (96%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/schemaregion/PipeTreeStatementToPlanVisitor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/CteScanOperator.java
rename
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/udf/access =>
datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation}/RecordIterator.java
(61%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/{AlterEncodingCompressorTask.java
=> AlterTimeSeriesTask.java} (60%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/relational/{AlterTableDropColumnTask.java
=> AlterColumnDataTypeTask.java} (65%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/write/ObjectNode.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/function/tvf/ClassifyTableFunction.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/CteMaterializer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/ir/PredicateWithUncorrelatedScalarSubqueryReconstructor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/CteScanNode.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/AstMemoryEstimator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/AlterColumnDataType.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/AstMemoryEstimationHelper.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/utils/ResultColumnAppender.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/{ShowVariablesStatement.java
=> AlterTimeSeriesDataTypeStatement.java} (78%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/{unary/scalar/AbstractBitwise2ColumnTransformer.java
=> binary/ReadObject2ColumnTransformer.java} (68%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/ternary/{LpadColumnTransformer.java
=> ReadObject3ColumnTransformer.java} (54%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/{AbstractBitwiseColumnTransformer.java
=> AbstractLengthColumnTransformer.java} (79%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/{binary/ArithmeticAdditionColumnTransformer.java
=> unary/scalar/ObjectLengthColumnTransformer.java} (69%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/ReadObjectColumnTransformer.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/metrics/file/{ModsFileMetrics.java
=> ObjectFileMetrics.java} (69%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/Base32ObjectPath.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/IObjectPath.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/PlainObjectPath.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/CompactionSeriesContext.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/ObjectTypeUtils.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/ObjectWriter.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/cte/CteDataReader.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/cte/CteDataStore.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/cte/MemoryReader.java
copy
iotdb-core/{node-commons/src/test/java/org/apache/iotdb/commons/pipe/datastructure/PipeReceiverStatusHandlerTest.java
=>
datanode/src/test/java/org/apache/iotdb/db/consensus/statemachine/schemaregion/SchemaExecutionVisitorTest.java}
(70%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/event/PipeTsFileInsertionEventTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/pattern/TreePatternPruningTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/source/PipeTreeStatementToPlanVisitorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/CteScanOperatorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/expression/predicate/TreePredicateConversionTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/function/RecordObjectTypeTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/CteMaterializerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/CteSubqueryTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/assertions/CteScanMatcher.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/predicate/TablePredicateConversionTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/sql/AstMemoryEstimatorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/ObjectTypeFunctionTest.java
copy
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/{CompactionDataTypeNotMatchTest.java
=> CompactionDataTypeAlterTest.java} (58%)
copy
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/{CompactionDataTypeNotMatchTest.java
=> CompactionDataTypeNotMatchAlterableDataTypeTest.java} (91%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/object/ObjectTypeCompactionTest.java
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/{IoTDBIORuntimeException.java
=> ObjectFileNotExist.java} (70%)
rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/schemaengine =>
node-commons/src/main/java/org/apache/iotdb/commons/schema}/template/Template.java
(99%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/{cq/CQState.java
=> schema/tree/AlterTimeSeriesOperationType.java} (71%)
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/utils/ConversionUtils.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/utils/MetadataUtils.java}
(77%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/utils/WindowsOSUtils.java
copy
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/utils/{JVMCommonUtilsTest.java
=> WindowsOSUtilsTest.java} (60%)
