This is an automated email from the ASF dual-hosted git repository.
chenyz pushed a change to branch udtf
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 1902b2466fd adjust package structure
add a8a65105730 fix pass through
add 05003055930 Support authentication for query module
add bbaa63bbc13 Add maintenance commands for table model
add b166aa14f2c Insertion/deletion authentication
add d90088336d3 Read of .meta file is not included in the compaction io
metrics (#14772)
add a1a10c1743a Fix setSystemStatusTableIT
add 70f02780a8a Support authentication for maintain and udf management
statement
add 8b287ca9e16 Fix select time in TreeModel
add c2625d07ec0 Try fix error code different in each data node problem
add 46009936dcc Pipe IT: Refactor how IT is categorized to reduce overall
runtime (#14719)
add e160e19789e Added regions/pipes/pipe_plugins/topics/subscriptions to
information_schema & Fixed the time precision of + add "user" column for
queries table (#14680)
add 1d93c99a9ca Implemented auth IT for
load/pipe/subscription/database/table & Fixed the bug that partial pipe tree
auth IT does not run & Fixed the tag data type of
CompactionTableModelTestFileWriter (#14807)
add 5c4f0191132 Pipe IT: Modify the Git Action failure log name to be
consistent with the Job (#14810)
add 2c0f7ec033b Pipe: Adapted pipe metadata sync for new permission
(#14775)
add d8e6c303fb6 Fix some issues.
add 2eea334b93c fix auth parser error with grant all on root.** from
non-root user.
add e5dacc08fcf Add Greatest and Least Comparison functions
add 27a3b944db5 [AINode] fix missing dependency in wheel file (#14818)
add 69b01012ade fix_docker (#14781)
add 9c54cfc4e26 feat: add generate-thrift-sources-csharp (#14824)
add 29b9ead7d85 Bump net.minidev:json-smart from 2.5.0 to 2.5.2
add eed0a4687b5 Added metrics to DeviceSchemaCache's memory and entries
num (#14826)
add 7ac71fb2a33 Load: convert to insert tablet on region replica set
changes (#14717)
add a798d2f0dbc Subscription: fix nack tablet response & periodically
report the state of prefetching queue & improve logs for subscription providers
(#14822)
add ac63e9aa79b Check time precision for negative timestamps (#14828)
add c8ea40f18d8 Fixed the bug that internalCreate(Multi)TimeSeries may
write empty device when measurements are all trimmed (#14827)
add 4c65958e1d0 Update DualKeyCacheImpl.java (#14817)
add 8d08153d928 Pipe: Default parameters adjustment for pipe threads and
pipeStuckRestartMinIntervalMs (#14819)
add af1db94f4b8 Pipe: avoid event accumulation in the stale sink pending
queue & promptly clean up closed processor subtasks & close parser when
releasing phantom reference of tsfile event (#14820)
add 3580c34e369 update workflow (#14837)
add 4d2ac447a88 Support 'set sql_dialect' in Tree and Table Model
add 338e715210b Fix NPE of RelationalDeleteDataNode merge method (#14834)
add b990b9e498b Enhance getLatestRegionRouteMap log for debugging #14830
add 0fa9fa1d3ab [IoTConsensusV2] Fix NPE when transfer tsfile mods #14840
add a0eab8f5eab Metric: Add pipe linked tsfile size and count metric
(#14768)
add 6233e53acd4 [remove confignode] Add Remove ConfigNode SQL (#14813)
add b1e07c79f39 fix todos-check (#14851)
add 515991dc9f7 Pipe: adjust default pipeRealTimeQueuePollHistoryThreshold
to reduce retransmission upon frequent rebooting (#14846)
add 563e42ac868 Pipe: fix the issue where the pipe still forwards insert
events when the parameter source.mode.double-living is true. (#14839)
add 3edb24fe96c Delete remove-confignode.sh and remove-datanode.sh
add 9264b701a93 Do not print host and port when failed to connect through
CLI (#14844)
add 57ede481a84 Pipe: Fix the problem that the receiver constructs
InsertStatement causing the MeasurementShcema to not be correctly set to null
(NPE) (#14831)
add 4bd2f259c50 IoTConsensus and IoTConsensusV2 no longer stores the peer
list locally on the DataNode (#14814)
add 379993ec38a Add SSL support to Python client (#14789)
add 8e61e3072ab Remove JDBC sensitive information output (#14857)
add 1deffc58907 Pipe: Fix the issue where the pipe still forwards insert
events in the table model when forwarding-pipe-requests is false (#14861)
add 330a683242d Pipe: Implement force forwarding feature where the Pipe
sender can force the receiver to forward the received event (#14847)
add 3cc339bd47a Pipe: Introduce timely flush options & Execute flush after
pipe watchdog restarts & Log degrade reasons for debugging (#14865)
add cb03ad80653 Subscription: fix consumer infinite pulling event & fully
managed tsfile parsing process & increase the reference count for subscribed
parsed raw tablet event & disrupt parsing requests through the introduction of
randomness & disable prefetch by default (#14856)
add 92bb0a19f0a Pipe IT: explicitly declare `setUp` method for test class
to avoid `UNKNOWN-IT` test class name (#14874)
add 2c4acfc1af8 Add query metrics AGGREGATION_FROM_RAW_DATA and
AGGREGATION_FROM_STATISTICS for table model
add f2c1a2a68b7 Pipe: Fixed the bug that delete timeSeries / logicalView
cannot be transferred (#14867)
add b4cec03c26f [remove datanode] Delete the SQL of removing multiple
datanodes at the same time #14862
add 0cce0e277d6 Fix TableModelJDBCExample (#14878)
add 692b6bf4d8a Pipe: Fixed the DataNode startup failure caused by Pipe
plugin loading (#14816)
add 33c9e3a1a54 fix table deletion with time predicate (#14870)
add 5f259bacc63 Remove attribute columns after attributes are updated
(#14721)
add dc8418277ab Fix insert/load with timestamp of Long.MIN_VALUE and
LONG.MAX_VALUE (#14491)
add 9e973b751cf Fix IoTConsensus safe deleted index (#14883)
add adba099046c Pipe: bind memory block for PipeTransferTsFileHandler and
PipeInsertNodeTabletInsertionEvent & unify the memory threshold judgment for
tablet and tsfile block & close data container when internally decrease
reference count of PipeTsFileInsertionEvent (#14873)
add 85f85cec61d Pipe: Optimize the data logic of distinguishing table
model and tree model (#14803)
add f8082c651aa Pipe: Reduce degrade log from
PipeRealtimeDataRegionHybridExtractor (#14888)
add 2964bd20079 Pipe: Fixed the bug that the create/delete database cannot
be passed to the receiver & SchemaRegionSnapshot parsing failure & The
historical table/databases cannot be transferred & The class cast exception at
receiver (#14876)
add 7883265abcc Fix the incorrect configuration of the JAVA_HOME
environment variable in script." (#14893)
add 4e0ecc24541 Add Date and Float data IT (#14892)
add 4aadc09fb20 Fix IoTConsensus safe deleted index again (#14897)
add 7b588c81b17 Pipe: fix threshold judgment for tablet and tsfile memory
block & Subscription: close data container for current PipeTsFileInsertionEvent
in batch (#14901)
add 897e989261d Fixed the bug that procedure rollback may generate NPE &&
some of the rollback steps may not be / be extra executed (#14871)
add 065a58d68bd Subscription: add methods to obtain the consumer
identifier in the top-level interface (#14904)
add 8760e10b796 Pipe: Avoid stuck in insertion process because failed to
allocate memory (#14899)
add 8e4fef3b8f0 Update dockerfile to use the latest ubuntu 24 (#14903)
add 7615222e8fe Subscription: close memory block for previous tsfile
response (#14909)
add b8438dd0165 Add connection_time_out_in_ms for Python SDK (#14898)
add 43ed88f4909 Allow to write time column only (#14703)
add 9a93a0e29f1 Reject inserting invalid timestamp string (#14913)
add 547e7f6f6b8 Initialize WALNode when DataRegion is created for iotv1
and iotv2 (#14918)
add 85326097340 Memtable enhancement for query (#14591)
add 481a79d3c14 Fix that failure of one row in relational InsertRows will
fail other rows (#14912)
add b498285c4f4 Pipe: Modify MaxAllowedPinnedMemTableCount to adapt to
changes in the number of DRs & Modify the implementation of the poll method in
PipeRealtimePriorityBlockingQueue to reduce commit queue backlog & Adjust the
default thread count related to Pipe for better performance & Significantly
reduce pipeMemoryAllocateRetryIntervalMs & Provide a switch for memory control
of ConnectorReadFileBuffer (#14917)
add 650bbcc25f7 [RTO/RPO] Unify retry logic on SessionConnection (#14894)
add 61576c0a5bc Implemented JDBC for IoTDB based on tables
add 083ae4858fa Fix IT names & Fix region operation related IT (#14905)
add 4d965e9d6ec Don't log known error's exception thread stack
add 6b5e5b00e4c [To Master] MQTT Extensions to the Table Model Using the
Row Protocol (#14848)
add babc2af50ee Replace ExportTsFile By SubscriptionTsFile (#14812)
add 22238fc880b resolve conflict
No new revisions were added by this update.
Summary of changes:
.github/workflows/cluster-it-1c1d.yml | 9 +-
.github/workflows/cluster-it-1c1d1a.yml | 9 +-
.github/workflows/cluster-it-1c3d.yml | 9 +-
.github/workflows/compile-check.yml | 9 +-
.github/workflows/dependency-check.yml | 1 -
.github/workflows/multi-language-client.yml | 1 -
.../{pipe-it-2cluster.yml => pipe-it.yml} | 314 +-
.github/workflows/sonar-codecov.yml | 1 -
.github/workflows/table-cluster-it-1c1d.yml | 9 +-
.github/workflows/table-cluster-it-1c3d.yml | 9 +-
.github/workflows/todos-check.yml | 27 +-
.github/workflows/unit-test.yml | 1 -
docker/src/main/DockerCompose/do-docker-build.sh | 4 +-
docker/src/main/DockerCompose/entrypoint.sh | 5 +-
.../main/DockerCompose/replace-conf-from-env.sh | 33 +-
docker/src/main/Dockerfile-1.0.0-confignode | 2 +-
docker/src/main/Dockerfile-1.0.0-datanode | 2 +-
docker/src/main/Dockerfile-1.0.0-standalone | 2 +-
docker/src/main/Dockerfile-1c1d | 2 +-
.../org/apache/iotdb/TableModelJDBCExample.java | 4 +-
.../server/CustomizedJsonPayloadFormatter.java | 2 +-
.../org/apache/iotdb/mqtt/server/MyMessage.java | 31 +-
.../java/org/apache/iotdb/mqtt/MQTTClient.java | 39 +-
.../java/org/apache/iotdb/CountPointProcessor.java | 3 +-
.../apache/iotdb/SubscriptionSessionExample.java | 2 +-
.../TableModelSubscriptionSessionExample.java | 16 +-
integration-test/pom.xml | 46 +-
.../iotdb/it/env/cluster/ClusterConstant.java | 1 +
.../it/env/cluster/config/MppCommonConfig.java | 10 +-
.../it/env/cluster/config/MppDataNodeConfig.java | 12 +
.../env/cluster/config/MppSharedCommonConfig.java | 13 +-
.../iotdb/it/env/cluster/env/AbstractEnv.java | 12 +
.../iotdb/it/env/cluster/node/DataNodeWrapper.java | 11 +
.../it/env/remote/config/RemoteCommonConfig.java | 7 +-
.../it/env/remote/config/RemoteDataNodeConfig.java | 10 +
.../iotdb/it/env/remote/env/RemoteServerEnv.java | 10 +
.../category/MultiClusterIT2AutoCreateSchema.java | 22 -
...va => MultiClusterIT2DualTableManualBasic.java} | 2 +-
...=> MultiClusterIT2DualTableManualEnhanced.java} | 2 +-
....java => MultiClusterIT2DualTreeAutoBasic.java} | 2 +-
...va => MultiClusterIT2DualTreeAutoEnhanced.java} | 2 +-
...rIT.java => MultiClusterIT2DualTreeManual.java} | 2 +-
.../MultiClusterIT2ManualCreateSchema.java | 22 -
.../itbase/category/MultiClusterIT2TableModel.java | 22 -
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 3 +
.../org/apache/iotdb/itbase/env/CommonConfig.java | 4 +-
.../apache/iotdb/itbase/env/DataNodeConfig.java | 4 +
.../iotdb/itbase/runtime/ClusterTestStatement.java | 5 +-
.../{AbstractScript.java => AbstractScriptIT.java} | 2 +-
.../apache/iotdb/cli/it/StartClientScriptIT.java | 6 +-
....java => IoTDBAutoRegionGroupExtension2IT.java} | 4 +-
...st.java => IoTDBPartitionTableAutoCleanIT.java} | 2 +-
...IoTDBRegionOperationReliabilityITFramework.java | 72 -
.../IoTDBRegionGroupExpandAndShrinkForIoTV1IT.java | 20 +-
...IoTDBRegionMigrateNormalITForIoTV2BatchIT.java} | 2 +-
...=> IoTDBRegionMigrateOtherForIoTV2BatchIT.java} | 2 +-
... IoTDBRegionMigrateNormalForIoTV2StreamIT.java} | 2 +-
...IoTDBRegionMigrateOtherITForIoTV2StreamIT.java} | 2 +-
...rCrashWhenRemoveRemotePeerForIoTV2BatchIT.java} | 2 +-
...RegionMigrateDataNodeCrashForIoTV2BatchIT.java} | 2 +-
...alCrashWhenDeleteLocalPeerForIoTV2BatchIT.java} | 2 +-
...lCrashWhenRemoveRemotePeerForIoTV2BatchIT.java} | 2 +-
...CrashWhenRemoveRemotePeerForIoTV2StreamIT.java} | 2 +-
...egionMigrateDataNodeCrashForIoTV2StreamIT.java} | 2 +-
...lCrashWhenDeleteLocalPeerForIoTV2StreamIT.java} | 2 +-
...CrashWhenRemoveRemotePeerForIoTV2StreamIT.java} | 2 +-
...oTDBRegionMigrateClusterCrashIoTV2BatchIT.java} | 2 +-
...BRegionMigrateConfigNodeCrashIoTV2BatchIT.java} | 2 +-
...TDBRegionMigrateClusterCrashIoTV2StreamIT.java} | 2 +-
...RegionMigrateConfigNodeCrashIoTV2StreamIT.java} | 2 +-
.../IoTDBRemoveConfigNodeITFramework.java | 206 +
.../IoTDBRemoveConfigNodeNormalIT.java} | 16 +-
.../IoTDBRemoveDataNodeITFramework.java | 2 +-
.../apache/iotdb/db/it/IoTDBDuplicateTimeIT.java | 5 +-
.../apache/iotdb/db/it/IoTDBFloatPrecisionIT.java | 45 +
.../apache/iotdb/db/it/IoTDBInsertWithQueryIT.java | 1 +
.../org/apache/iotdb/db/it/IoTDBLoadTsFileIT.java | 73 +
.../org/apache/iotdb/db/it/IoTDBRestartIT.java | 4 +-
.../org/apache/iotdb/db/it/IoTDBSimpleQueryIT.java | 38 +
.../org/apache/iotdb/db/it/auth/IoTDBAuthIT.java | 38 +
.../iotdb/db/it/auth/IoTDBRelationalAuthIT.java | 183 +
.../iotdb/db/it/auth/IoTDBSystemPermissionIT.java | 2 +-
.../iotdb/db/it/groupby/IoTDBGroupByUnseqIT.java | 2 +-
.../apache/iotdb/db/it/query/IoTDBQueryDemoIT.java | 25 +
.../org/apache/iotdb/db/it/utils/TestUtils.java | 227 +-
.../it/{ => dual}/tablemodel/TableModelUtils.java | 2 +-
.../AbstractPipeTableModelDualManualIT.java} | 4 +-
.../tablemodel/manual/basic}/IoTDBPipeAlterIT.java | 17 +-
.../manual/basic}/IoTDBPipeDataSinkIT.java | 21 +-
.../manual/basic}/IoTDBPipeExtractorIT.java | 10 +-
.../manual/basic}/IoTDBPipeIsolationIT.java | 17 +-
.../manual/basic}/IoTDBPipeLifeCycleIT.java | 165 +-
.../manual/basic}/IoTDBPipeProtocolIT.java | 11 +-
.../manual/basic}/IoTDBPipeSwitchStatusIT.java | 18 +-
.../manual/basic}/IoTDBPipeSyntaxIT.java | 17 +-
.../manual/basic}/IoTDBPipeWithLoadIT.java | 10 +-
.../manual/basic}/IoTDBTablePatternFormatIT.java | 17 +-
.../manual/enhanced}/IoTDBPipeAutoConflictIT.java | 11 +-
.../manual/enhanced}/IoTDBPipeAutoDropIT.java | 17 +-
.../manual/enhanced}/IoTDBPipeClusterIT.java | 10 +-
.../enhanced}/IoTDBPipeConnectorCompressionIT.java | 10 +-
.../enhanced}/IoTDBPipeConnectorParallelIT.java | 18 +-
.../manual/enhanced}/IoTDBPipeDoubleLivingIT.java | 20 +-
.../manual/enhanced/IoTDBPipeIdempotentIT.java | 205 +
.../manual/enhanced/IoTDBPipeMetaIT.java} | 95 +-
.../manual/enhanced}/IoTDBPipeNullValueIT.java | 17 +-
.../IoTDBPipeTypeConversionISessionIT.java | 26 +-
.../enhanced}/IoTDBPipeTypeConversionIT.java | 25 +-
.../auto/AbstractPipeDualTreeModelAutoIT.java} | 4 +-
.../treemodel/auto/basic}/IoTDBPipeAlterIT.java | 16 +-
.../auto/basic}/IoTDBPipeConnectorParallelIT.java | 17 +-
.../treemodel/auto/basic}/IoTDBPipeDataSinkIT.java | 17 +-
.../auto/basic}/IoTDBPipeExtractorIT.java | 9 +-
.../auto/basic}/IoTDBPipeLifeCycleIT.java | 30 +-
.../auto/basic}/IoTDBPipeProcessorIT.java | 10 +-
.../treemodel/auto/basic}/IoTDBPipeProtocolIT.java | 10 +-
.../auto/basic}/IoTDBPipeSwitchStatusIT.java | 17 +-
.../treemodel/auto/basic}/IoTDBPipeSyntaxIT.java | 17 +-
.../auto/basic}/IoTDBTreePatternFormatIT.java | 17 +-
.../auto/enhanced}/IoTDBPipeAutoConflictIT.java | 10 +-
.../auto/enhanced}/IoTDBPipeAutoDropIT.java | 16 +-
.../auto/enhanced}/IoTDBPipeClusterIT.java | 11 +-
.../IoTDBPipeConditionalOperationsIT.java | 16 +-
.../enhanced}/IoTDBPipeConnectorCompressionIT.java | 9 +-
.../auto/enhanced}/IoTDBPipeIdempotentIT.java | 117 +-
.../auto/enhanced}/IoTDBPipeNullValueIT.java | 9 +-
.../auto/enhanced}/IoTDBPipeWithLoadIT.java | 9 +-
.../auto/enhanced}/PipeNowFunctionIT.java | 16 +-
.../manual/AbstractPipeDualTreeModelManualIT.java} | 4 +-
.../treemodel}/manual/IoTDBPipeInclusionIT.java | 8 +-
.../manual/IoTDBPipeManualConflictIT.java | 8 +-
.../manual/IoTDBPipeMetaHistoricalIT.java | 8 +-
.../manual/IoTDBPipeMetaLeaderChangeIT.java | 8 +-
.../treemodel}/manual/IoTDBPipeMetaRestartIT.java | 8 +-
.../manual/IoTDBPipeMultiSchemaRegionIT.java | 8 +-
.../treemodel}/manual/IoTDBPipePermissionIT.java | 8 +-
.../treemodel}/manual/IoTDBPipeReqAutoSliceIT.java | 8 +-
.../manual/IoTDBPipeTypeConversionISessionIT.java | 8 +-
.../manual/IoTDBPipeTypeConversionIT.java | 8 +-
.../iotdb/pipe/it/single/IoTDBPipeOPCUAIT.java | 2 +-
.../it/db/it/IoTDBAuthenticationTableIT.java | 1001 +++++
.../relational/it/db/it/IoTDBDeletionTableIT.java | 115 +
.../relational/it/db/it/IoTDBInsertTableIT.java | 28 +-
.../it/IoTDBLoadConfigurationTableIT.java} | 75 +-
.../relational/it/db/it/IoTDBRestartTableIT.java | 3 -
.../it/db/it/IoTDBSetSystemStatusTableIT.java | 104 +
.../relational/it/mqtt/IoTDBMQTTServiceIT.java | 132 +
.../query/old/query/IoTDBGreatestLeastTableIT.java | 305 ++
.../it/query/recent/IoTDBMaintainAuthIT.java | 289 ++
.../it/query/recent/IoTDBNullIdQueryIT.java | 33 +
.../it/query/recent/IoTDBQueryAuthIT.java | 320 ++
.../relational/it/schema/IoTDBDatabaseIT.java | 145 +-
.../iotdb/relational/it/schema/IoTDBTableIT.java | 57 +
.../it/session/IoTDBSessionRelationalIT.java | 268 ++
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 258 +-
.../it/local/IoTDBSubscriptionBasicIT.java | 67 +
.../regression/param/IoTDBTestParamTopicIT.java | 2 +-
.../apache/iotdb/tools/it/ExportDataTestIT.java | 4 +-
.../apache/iotdb/tools/it/ExportSchemaTestIT.java | 4 +-
.../apache/iotdb/tools/it/ExportTsFileTestIT.java | 36 +-
.../apache/iotdb/tools/it/ImportDataTestIT.java | 4 +-
.../apache/iotdb/tools/it/ImportSchemaTestIT.java | 4 +-
.../src/test/resources/logback-test.xml | 2 +-
iotdb-client/cli/pom.xml | 4 +
.../src/main/java/org/apache/iotdb/cli/Cli.java | 4 +-
.../org/apache/iotdb/tool/common/Constants.java | 30 +-
.../org/apache/iotdb/tool/common/OptionsUtil.java | 112 +
.../org/apache/iotdb/tool/tsfile/ExportTsFile.java | 539 +--
.../subscription/AbstractSubscriptionTsFile.java | 74 +
.../tool/tsfile/subscription/CommonParam.java | 212 +
.../subscription/SubscriptionTableTsFile.java | 186 +
.../subscription/SubscriptionTreeTsFile.java | 183 +
iotdb-client/client-py/iotdb/Session.py | 51 +-
iotdb-client/client-py/iotdb/SessionPool.py | 12 +
iotdb-client/client-py/iotdb/table_session.py | 9 +
iotdb-client/client-py/iotdb/table_session_pool.py | 6 +
iotdb-client/client-py/session_ssl_example.py | 85 +
iotdb-client/jdbc/pom.xml | 55 +-
.../main/java/org/apache/iotdb/jdbc/Constant.java | 7 +-
...ata.java => IoTDBAbstractDatabaseMetadata.java} | 4330 +++++++++-----------
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 30 +-
.../apache/iotdb/jdbc/IoTDBConnectionParams.java | 4 +-
.../apache/iotdb/jdbc/IoTDBDataSourceFactory.java | 3 -
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 3555 ++--------------
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 7 +
.../IoTDBRelationalDatabaseMetadata.java | 405 ++
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 14 +
.../iotdb/rpc/subscription/config/TopicConfig.java | 7 +-
.../subscription/payload/poll/TabletsPayload.java | 4 +-
.../java/org/apache/iotdb/rpc/RpcUtilsTest.java | 10 +
.../java/org/apache/iotdb/session/Session.java | 34 +-
.../apache/iotdb/session/SessionConnection.java | 1031 ++---
.../apache/iotdb/session/TableSessionBuilder.java | 4 +-
.../org/apache/iotdb/session/pool/SessionPool.java | 5 +-
.../iotdb/session/pool/TableSessionWrapper.java | 15 +
.../consumer/ISubscriptionTablePullConsumer.java | 18 +
.../consumer/ISubscriptionTablePushConsumer.java | 18 +
.../consumer/ISubscriptionTreePullConsumer.java | 18 +
.../consumer/ISubscriptionTreePushConsumer.java | 18 +
.../base/AbstractSubscriptionConsumer.java | 6 +-
.../base/AbstractSubscriptionProviders.java | 48 +-
.../consumer/table/SubscriptionTableProvider.java | 18 +-
.../table/SubscriptionTablePullConsumer.java | 34 +-
.../table/SubscriptionTablePushConsumer.java | 36 +-
.../consumer/tree/SubscriptionTreeProvider.java | 18 +-
.../tree/SubscriptionTreePullConsumer.java | 34 +-
.../tree/SubscriptionTreePushConsumer.java | 34 +-
.../apache/iotdb/session/util/CheckedSupplier.java | 32 -
iotdb-core/ainode/pyproject.toml | 14 +-
iotdb-core/ainode/resources/conf/ainode-env.sh | 2 +-
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 6 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 23 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 24 +
.../assembly/resources/sbin/remove-confignode.bat | 135 -
.../assembly/resources/sbin/remove-confignode.sh | 69 -
.../confignode/conf/ConfigNodeRemoveCheck.java | 5 +-
.../request/ConfigPhysicalPlanVisitor.java | 221 +-
.../pipe/payload/PipeDeleteLogicalViewPlan.java | 5 +-
.../pipe/payload/PipeDeleteTimeSeriesPlan.java | 5 +-
.../statemachine/ConfigRegionStateMachine.java | 6 +-
.../iotdb/confignode/manager/ConfigManager.java | 3 +-
.../confignode/manager/PermissionManager.java | 7 +-
.../client/IoTDBConfigNodeSyncClientManager.java | 6 +-
.../protocol/IoTDBConfigRegionAirGapConnector.java | 3 +
.../protocol/IoTDBConfigRegionConnector.java | 6 +-
.../pipe/event/PipeConfigRegionSnapshotEvent.java | 17 +-
.../extractor/ConfigRegionListeningFilter.java | 84 +-
.../pipe/extractor/IoTDBConfigRegionExtractor.java | 23 +-
...ConfigPhysicalPlanTablePatternParseVisitor.java | 62 +
...peConfigPhysicalPlanTableScopeParseVisitor.java | 86 +
...eConfigPhysicalPlanTreePatternParseVisitor.java | 30 +-
...ipeConfigPhysicalPlanTreeScopeParseVisitor.java | 80 +
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 187 +-
.../PipeConfigPhysicalPlanTSStatusVisitor.java | 207 +-
.../iotdb/confignode/persistence/AuthorInfo.java | 70 +-
.../schema/CNPhysicalPlanGenerator.java | 15 +-
...otParser.java => ConfigNodeSnapshotParser.java} | 24 +-
.../procedure/impl/StateMachineProcedure.java | 7 +-
.../impl/schema/AlterLogicalViewProcedure.java | 4 +-
...ipeConfigPhysicalPlanScopeParseVisitorTest.java | 116 +
...igPhysicalPlanTablePatternParseVisitorTest.java | 25 +
.../org/apache/iotdb/consensus/common/Peer.java | 13 +-
.../apache/iotdb/consensus/iot/IoTConsensus.java | 30 +-
.../consensus/iot/IoTConsensusServerImpl.java | 258 +-
.../consensus/iot/logdispatcher/LogDispatcher.java | 9 +-
.../service/IoTConsensusRPCServiceProcessor.java | 2 +-
.../apache/iotdb/consensus/pipe/PipeConsensus.java | 90 +-
.../consensus/pipe/PipeConsensusPeerManager.java | 89 +-
.../consensus/pipe/PipeConsensusServerImpl.java | 33 +-
.../apache/iotdb/consensus/iot/ReplicateTest.java | 63 +-
.../assembly/resources/sbin/remove-datanode.bat | 148 -
.../src/assembly/resources/sbin/remove-datanode.sh | 91 -
.../src/assembly/resources/sbin/start-datanode.bat | 2 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 3 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 34 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 25 +-
.../db/pipe/agent/runtime/PipeAgentLauncher.java | 3 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 63 +-
.../task/builder/PipeDataNodeTaskBuilder.java | 12 +-
.../agent/task/connection/PipeEventCollector.java | 11 +-
.../agent/task/stage/PipeTaskProcessorStage.java | 9 +-
.../PipeRealtimePriorityBlockingQueue.java | 10 +-
.../subtask/processor/PipeProcessorSubtask.java | 5 +-
.../processor/PipeProcessorSubtaskWorker.java | 11 +-
.../client/IoTDBDataNodeAsyncClientManager.java | 9 +-
.../client/IoTDBDataNodeSyncClientManager.java | 6 +-
.../airgap/IoTDBDataNodeAirGapConnector.java | 3 +
.../async/IoTDBDataRegionAsyncConnector.java | 18 +-
.../handler/PipeTransferTrackableHandler.java | 33 +-
.../async/handler/PipeTransferTsFileHandler.java | 70 +-
.../thrift/sync/IoTDBDataNodeSyncConnector.java | 6 +-
.../db/pipe/event/common/PipeInsertionEvent.java | 64 +-
.../db/pipe/event/common/row/PipeRowCollector.java | 27 +-
.../schema/PipeSchemaRegionSnapshotEvent.java | 7 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 56 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 26 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 86 +-
.../query/TsFileInsertionEventQueryParser.java | 70 +-
.../scan/TsFileInsertionEventScanParser.java | 35 +-
.../table/TsFileInsertionEventTableParser.java | 70 +-
.../db/pipe/event/realtime/PipeRealtimeEvent.java | 6 +
.../event/realtime/PipeRealtimeEventFactory.java | 12 +-
...oricalDataRegionTsFileAndDeletionExtractor.java | 10 +-
.../realtime/PipeRealtimeDataRegionExtractor.java | 26 +-
.../PipeRealtimeDataRegionHybridExtractor.java | 139 +-
.../realtime/assigner/PipeDataRegionAssigner.java | 19 +
.../listener/PipeInsertionDataNodeListener.java | 4 +-
.../schemaregion/SchemaRegionListeningFilter.java | 8 +-
.../iotdb/db/pipe/metric/PipeResourceMetrics.java | 34 +
.../processor/aggregate/AggregateProcessor.java | 18 +-
.../twostage/plugin/TwoStageCountProcessor.java | 14 +-
.../pipeconsensus/PipeConsensusReceiver.java | 55 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 10 +-
.../visitor/PipePlanToStatementVisitor.java | 18 +-
.../db/pipe/resource/memory/PipeMemoryManager.java | 137 +-
.../resource/tsfile/PipeTsFileResourceManager.java | 15 +
.../iotdb/db/protocol/client/ConfigNodeClient.java | 3 +-
.../db/protocol/mqtt/JSONPayloadFormatter.java | 6 +-
.../db/protocol/mqtt/LinePayloadFormatter.java | 252 ++
.../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 239 +-
.../org/apache/iotdb/db/protocol/mqtt/Message.java | 58 +-
.../iotdb/db/protocol/mqtt/TableMessage.java | 144 +
.../mqtt/{Message.java => TreeMessage.java} | 16 +-
.../db/protocol/rest/impl/PingApiServiceImpl.java | 4 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 29 +-
.../execution/executor/RegionWriteExecutor.java | 33 +-
.../fragment/FragmentInstanceContext.java | 78 +-
.../fragment/FragmentInstanceManager.java | 2 +
.../execution/fragment/QueryContext.java | 9 +
.../process/function/PartitionRecognizer.java | 8 +-
.../process/function/TableFunctionOperator.java | 7 +-
.../operator/process/function/partition/Slice.java | 20 +-
.../process/function/partition/SliceCache.java | 2 +-
.../InformationSchemaContentSupplierFactory.java | 341 +-
.../relational/aggregation/TableAggregator.java | 49 +-
.../relational/ColumnTransformerBuilder.java | 15 +
.../queryengine/metric/QueryPlanCostMetricSet.java | 68 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 8 +
.../db/queryengine/plan/analyze/AnalyzeUtils.java | 9 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 16 +-
.../db/queryengine/plan/analyze/Analyzer.java | 3 +-
.../queryengine/plan/analyze/TemplatedAnalyze.java | 3 +-
.../analyze/cache/partition/PartitionCache.java | 5 +
.../schema/dualkeycache/IDualKeyCacheStats.java | 6 +
.../cache/schema/dualkeycache/impl/CacheStats.java | 24 +-
.../schema/dualkeycache/impl/DualKeyCacheImpl.java | 122 +-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 7 +
.../analyze/load/LoadTsFileTableSchemaCache.java | 11 +-
.../analyze/load/LoadTsFileTreeSchemaCache.java | 7 +-
.../plan/analyze/schema/SchemaValidator.java | 14 +-
.../plan/execution/IQueryExecution.java | 2 +
.../queryengine/plan/execution/QueryExecution.java | 19 +-
.../plan/execution/config/ConfigExecution.java | 9 +-
.../execution/config/TableConfigTaskVisitor.java | 46 +
.../execution/config/TreeConfigTaskVisitor.java | 31 +
.../config/executor/ClusterConfigTaskExecutor.java | 75 +-
.../config/executor/IConfigTaskExecutor.java | 6 +
...DataNodeTask.java => RemoveConfigNodeTask.java} | 12 +-
.../config/metadata/ShowPipePluginsTask.java | 4 +-
.../SetSqlDialectTask.java} | 15 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 57 +-
.../db/queryengine/plan/planner/IPlanner.java | 3 +-
.../queryengine/plan/planner/LogicalPlanner.java | 6 +-
.../plan/planner/TableOperatorGenerator.java | 22 +-
.../queryengine/plan/planner/TreeModelPlanner.java | 20 +-
.../plan/node/load/LoadSingleTsFileNode.java | 12 +-
.../plan/node/load/LoadTsFilePieceNode.java | 6 +-
.../plan/planner/plan/node/write/InsertNode.java | 2 +
.../planner/plan/node/write/InsertRowNode.java | 3 +
.../plan/node/write/RelationalDeleteDataNode.java | 4 +-
.../plan/node/write/RelationalInsertRowNode.java | 5 +
.../node/write/RelationalInsertTabletNode.java | 8 +
.../plan/relational/analyzer/Analyzer.java | 3 +-
.../relational/analyzer/StatementAnalyzer.java | 11 +-
.../relational/metadata/TableMetadataImpl.java | 20 +
.../fetcher/TableHeaderSchemaValidator.java | 4 -
.../fetcher/cache/TableDeviceSchemaCache.java | 19 +-
.../cache/TableDeviceSchemaCacheMetrics.java | 34 +
.../relational/planner/TableLogicalPlanner.java | 16 +-
.../plan/relational/planner/TableModelPlanner.java | 32 +-
.../distribute/TableDistributedPlanner.java | 11 +-
.../DataNodeLocationSupplierFactory.java | 22 +-
.../optimizations/PushPredicateIntoTableScan.java | 6 +-
.../plan/relational/security/AccessControl.java | 8 +
.../relational/security/AccessControlImpl.java | 62 +-
.../relational/security/AllowAllAccessControl.java | 5 +
.../plan/relational/sql/ast/AstVisitor.java | 16 +
.../plan/relational/sql/ast/InsertRows.java | 5 +-
...{StopRepairData.java => LoadConfiguration.java} | 6 +-
.../{RemoveDataNode.java => RemoveConfigNode.java} | 22 +-
.../sql/ast/{KillQuery.java => SetSqlDialect.java} | 28 +-
.../{StartRepairData.java => SetSystemStatus.java} | 6 +-
.../relational/sql/ast/WrappedInsertStatement.java | 78 +-
.../plan/relational/sql/parser/AstBuilder.java | 145 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 47 +-
.../plan/statement/StatementVisitor.java | 21 +
.../plan/statement/crud/InsertBaseStatement.java | 78 +-
.../crud/InsertMultiTabletsStatement.java | 11 +
.../plan/statement/crud/InsertRowStatement.java | 10 +
.../crud/InsertRowsOfOneDeviceStatement.java | 5 +
.../plan/statement/crud/InsertRowsStatement.java | 11 +
.../plan/statement/crud/InsertTabletStatement.java | 10 +
...atement.java => RemoveConfigNodeStatement.java} | 17 +-
...nStatement.java => SetSqlDialectStatement.java} | 38 +-
...nt.java => ShowCurrentSqlDialectStatement.java} | 16 +-
...tatement.java => ShowCurrentUserStatement.java} | 16 +-
.../AbstractGreatestLeastColumnTransformer.java | 109 +
.../multi/BinaryGreatestColumnTransformer.java | 53 +
.../column/multi/BinaryLeastColumnTransformer.java | 53 +
.../multi/BooleanGreatestColumnTransformer.java | 52 +
.../multi/BooleanLeastColumnTransformer.java | 49 +
.../multi/DoubleGreatestColumnTransformer.java | 52 +
.../column/multi/DoubleLeastColumnTransformer.java | 52 +
.../multi/FloatGreatestColumnTransformer.java | 52 +
.../column/multi/FloatLeastColumnTransformer.java | 52 +
.../multi/Int32GreatestColumnTransformer.java | 52 +
.../column/multi/Int32LeastColumnTransformer.java | 52 +
.../multi/Int64GreatestColumnTransformer.java | 52 +
.../column/multi/Int64LeastColumnTransformer.java | 52 +
.../schemaregion/utils/ResourceByPathUtils.java | 146 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 2 +-
.../iotdb/db/service/DataNodeShutdownHook.java | 22 +-
.../{RPCService.java => ExternalRPCService.java} | 6 +-
.../org/apache/iotdb/db/service/MQTTService.java | 2 +
.../iotdb/db/service/metrics/WritingMetrics.java | 29 +-
.../iotdb/db/storageengine/StorageEngine.java | 35 +-
.../db/storageengine/dataregion/DataRegion.java | 23 +-
.../performer/impl/FastCompactionPerformer.java | 4 +-
.../execute/utils/MultiTsFileDeviceIterator.java | 7 +-
.../executor/fast/SeriesCompactionExecutor.java | 20 +-
.../readchunk/AlignedSeriesCompactionExecutor.java | 4 +-
.../ReadChunkAlignedSeriesCompactionExecutor.java | 6 +-
.../readchunk/SingleSeriesCompactionExecutor.java | 30 +-
.../utils/writer/AbstractCompactionWriter.java | 5 +-
.../writer/AbstractCrossCompactionWriter.java | 7 +-
.../writer/AbstractInnerCompactionWriter.java | 1 +
.../utils/writer/FastCrossCompactionWriter.java | 6 +
.../utils/writer/FastInnerCompactionWriter.java | 6 +
.../writer/ReadPointCrossCompactionWriter.java | 1 +
.../CompactionDiskTSMIterator.java} | 28 +-
.../compaction/io/CompactionTsFileInput.java | 122 +-
.../compaction/io/CompactionTsFileReader.java | 60 +-
.../compaction/io/CompactionTsFileWriter.java | 9 +
.../compaction/repair/RepairDataFileScanUtil.java | 56 +-
.../estimator/AbstractCompactionEstimator.java | 9 +-
.../selector/impl/SettleSelectorImpl.java | 24 +-
.../selector/utils/TsFileResourceCandidate.java | 13 +-
.../dataregion/flush/MemTableFlushTask.java | 16 +-
.../dataregion/memtable/AbstractMemTable.java | 166 +-
.../memtable/AlignedReadOnlyMemChunk.java | 588 ++-
.../memtable/AlignedWritableMemChunk.java | 752 +++-
.../memtable/AlignedWritableMemChunkGroup.java | 21 +-
.../dataregion/memtable/IMemTable.java | 8 +-
.../dataregion/memtable/IWritableMemChunk.java | 56 +-
.../memtable/IWritableMemChunkGroup.java | 9 +-
.../dataregion/memtable/ReadOnlyMemChunk.java | 274 +-
.../dataregion/memtable/TsFileProcessor.java | 65 +-
.../dataregion/memtable/WritableMemChunk.java | 595 ++-
.../dataregion/memtable/WritableMemChunkGroup.java | 30 +-
.../dataregion/modification/ModificationFile.java | 16 +-
.../filescan/impl/MemAlignedChunkHandleImpl.java | 21 +-
.../read/reader/chunk/MemAlignedChunkReader.java | 259 +-
.../read/reader/chunk/MemAlignedPageReader.java | 137 +-
.../read/reader/chunk/MemChunkReader.java | 139 +-
.../read/reader/chunk/MemPageReader.java | 129 +-
.../reader/chunk/metadata/AlignedPageMetadata.java | 74 +
.../read/reader/chunk/metadata/PageMetadata.java | 90 +
.../dataregion/tsfile/TsFileResource.java | 76 +-
.../tsfile/timeindex/ArrayDeviceTimeIndex.java | 23 +-
.../dataregion/tsfile/timeindex/FileTimeIndex.java | 9 +-
.../dataregion/tsfile/timeindex/ITimeIndex.java | 5 +-
.../utils/TsFileDeviceStartEndTimeIterator.java | 6 +-
.../dataregion/utils/TsFileResourceUtils.java | 30 +-
.../storageengine/dataregion/wal/io/WALReader.java | 2 +-
.../wal/recover/file/TsFilePlanRedoer.java | 9 +-
.../file/UnsealedTsFileRecoverPerformer.java | 10 +-
...leStatementDataTypeConvertExecutionVisitor.java | 4 +
...eeStatementDataTypeConvertExecutionVisitor.java | 4 +
.../load/splitter/AlignedChunkData.java | 16 +-
.../splitter/BatchedAlignedValueChunkData.java | 8 +-
.../load/splitter/NonAlignedChunkData.java | 8 +-
.../load/splitter/TsFileSplitter.java | 7 +
.../broker/SubscriptionPrefetchingQueue.java | 14 +-
.../broker/SubscriptionPrefetchingTabletQueue.java | 2 +-
.../broker/SubscriptionPrefetchingTsFileQueue.java | 2 +-
.../batch/SubscriptionPipeTabletEventBatch.java | 52 +-
.../SubscriptionPipeTabletIterationSnapshot.java | 62 +
.../pipe/SubscriptionPipeTabletBatchEvents.java | 29 +-
.../response/SubscriptionEventTabletResponse.java | 5 -
.../response/SubscriptionEventTsFileResponse.java | 7 +-
.../apache/iotdb/db/tools/IoTDBDataDirViewer.java | 6 +-
.../iotdb/db/tools/TsFileResourcePrinter.java | 10 +-
.../iotdb/db/tools/utils/TsFileValidationScan.java | 10 +-
.../TsFileOverlapValidationAndRepairTool.java | 8 +-
.../org/apache/iotdb/db/utils/DateTimeUtils.java | 4 +-
.../java/org/apache/iotdb/db/utils/MathUtils.java | 24 +-
.../apache/iotdb/db/utils/ModificationUtils.java | 17 +
.../iotdb/db/utils/TimestampPrecisionUtils.java | 20 +-
.../db/utils/datastructure/AlignedTVList.java | 415 +-
.../db/utils/datastructure/BackAlignedTVList.java | 66 +-
.../db/utils/datastructure/BackBinaryTVList.java | 72 +-
.../db/utils/datastructure/BackBooleanTVList.java | 71 +-
.../db/utils/datastructure/BackDoubleTVList.java | 71 +-
.../db/utils/datastructure/BackFloatTVList.java | 71 +-
.../db/utils/datastructure/BackIntTVList.java | 72 +-
.../db/utils/datastructure/BackLongTVList.java | 71 +-
.../iotdb/db/utils/datastructure/BackwardSort.java | 66 +-
.../iotdb/db/utils/datastructure/BinaryTVList.java | 128 +-
.../db/utils/datastructure/BooleanTVList.java | 75 +-
.../iotdb/db/utils/datastructure/DoubleTVList.java | 76 +-
.../iotdb/db/utils/datastructure/FloatTVList.java | 76 +-
.../iotdb/db/utils/datastructure/IntTVList.java | 75 +-
.../iotdb/db/utils/datastructure/LongTVList.java | 75 +-
.../MergeSortAlignedTVListIterator.java | 242 ++
.../datastructure/MergeSortTvListIterator.java | 162 +
.../PageColumnAccessInfo.java} | 43 +-
.../db/utils/datastructure/QuickAlignedTVList.java | 34 +-
.../db/utils/datastructure/QuickBinaryTVList.java | 34 +-
.../db/utils/datastructure/QuickBooleanTVList.java | 31 +-
.../db/utils/datastructure/QuickDoubleTVList.java | 31 +-
.../db/utils/datastructure/QuickFloatTVList.java | 31 +-
.../db/utils/datastructure/QuickIntTVList.java | 37 +-
.../db/utils/datastructure/QuickLongTVList.java | 31 +-
.../iotdb/db/utils/datastructure/QuickSort.java | 28 +-
.../iotdb/db/utils/datastructure/TVList.java | 363 +-
.../db/utils/datastructure/TimAlignedTVList.java | 109 +-
.../db/utils/datastructure/TimBinaryTVList.java | 113 +-
.../db/utils/datastructure/TimBooleanTVList.java | 111 +-
.../db/utils/datastructure/TimDoubleTVList.java | 111 +-
.../db/utils/datastructure/TimFloatTVList.java | 112 +-
.../iotdb/db/utils/datastructure/TimIntTVList.java | 112 +-
.../db/utils/datastructure/TimLongTVList.java | 111 +-
.../iotdb/db/utils/datastructure/TimSort.java | 105 +-
....apache.iotdb.db.protocol.mqtt.PayloadFormatter | 1 +
.../org/apache/iotdb/db/auth/entity/UserTest.java | 4 +-
.../db/protocol/mqtt/JSONPayloadFormatterTest.java | 8 +-
.../db/protocol/mqtt/LinePayloadFormatterTest.java | 91 +
.../db/protocol/mqtt/PayloadFormatManagerTest.java | 2 +-
.../db/protocol/rest/IoTDBRestServiceTest.java | 6 +-
.../operator/MergeTreeSortOperatorTest.java | 6 +
.../plan/parser/StatementGeneratorTest.java | 3 +
.../plan/relational/analyzer/AnalyzerTest.java | 7 +-
.../plan/relational/analyzer/ShowQueriesTest.java | 7 +-
.../storageengine/dataregion/DataRegionTest.java | 6 +-
.../compaction/CompactionDataTypeNotMatchTest.java | 19 +-
.../FastCompactionPerformerWithEmptyPageTest.java | 5 +-
.../FastInnerCompactionPerformerTest.java | 134 +-
.../ReadPointCompactionPerformerTest.java | 134 +-
.../TsFileValidationCorrectnessTests.java | 14 +-
...eCompactionWithFastPerformerValidationTest.java | 14 +-
...actionWithReadPointPerformerValidationTest.java | 14 +-
.../InsertionCrossSpaceCompactionRecoverTest.java | 4 +-
.../InsertionCrossSpaceCompactionSelectorTest.java | 4 +-
.../cross/RewriteCompactionFileSelectorTest.java | 6 +-
.../CompactionTableModelTestFileWriter.java | 2 +-
.../compaction/utils/CompactionCheckerUtils.java | 11 +-
.../memtable/MemChunkDeserializeTest.java | 332 ++
.../dataregion/memtable/PrimitiveMemTableTest.java | 41 +-
.../dataregion/memtable/TsFileProcessorTest.java | 451 +-
.../read/control/FileReaderManagerTest.java | 5 +-
.../reader/chunk/AlignedMemPageReaderTest.java | 32 +-
.../reader/chunk/MemAlignedChunkLoaderTest.java | 138 +-
.../read/reader/chunk/MemChunkLoaderTest.java | 260 +-
.../read/reader/chunk/MemPageReaderTest.java | 12 +-
.../dataregion/tsfile/TsFileResourceTest.java | 12 +-
.../wal/recover/WALRecoverManagerTest.java | 21 +-
.../file/SealedTsFileRecoverPerformerTest.java | 33 +-
.../wal/recover/file/TsFilePlanRedoerTest.java | 18 +-
.../file/UnsealedTsFileRecoverPerformerTest.java | 21 +-
.../apache/iotdb/db/utils/DateTimeUtilsTest.java | 14 +
.../apache/iotdb/db/utils/EnvironmentUtils.java | 4 -
.../db/utils/TimestampPrecisionUtilsTest.java | 10 +
.../db/utils/datastructure/AlignedTVListTest.java | 20 +-
.../db/utils/datastructure/BinaryTVListTest.java | 30 -
.../datanode/src/test/resources/logback-test.xml | 2 +-
.../conf/iotdb-system.properties.template | 46 +-
.../src/assembly/resources/sbin/health_check.bat | 2 +-
.../commons/auth/authorizer/BasicAuthorizer.java | 21 +
.../iotdb/commons/auth/authorizer/IAuthorizer.java | 4 +
.../commons/auth/authorizer/OpenIdAuthorizer.java | 6 +-
.../org/apache/iotdb/commons/auth/entity/Role.java | 8 +
.../org/apache/iotdb/commons/auth/entity/User.java | 8 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 58 +-
.../iotdb/commons/conf/CommonDescriptor.java | 43 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 1 +
.../iotdb/commons/consensus/ConsensusGroupId.java | 7 +-
.../commons/pipe/agent/task/PipeTaskAgent.java | 52 +-
.../task/connection/BlockingPendingQueue.java | 14 +
.../iotdb/commons/pipe/config/PipeConfig.java | 21 +-
.../config/constant/PipeConnectorConstant.java | 4 +
.../pipe/connector/client/IoTDBClientManager.java | 6 +-
.../connector/client/IoTDBSyncClientManager.java | 9 +-
.../common/PipeTransferHandshakeConstant.java | 1 +
.../pipe/connector/protocol/IoTDBConnector.java | 12 +-
.../connector/protocol/IoTDBSslSyncConnector.java | 6 +-
.../options/PipeInclusionOptions.java | 15 +-
.../commons/pipe/receiver/IoTDBFileReceiver.java | 12 +-
.../schema/column/ColumnHeaderConstant.java | 30 +
.../commons/schema/table/InformationSchema.java | 109 +
.../iotdb/commons/service/metric/enums/Metric.java | 2 +
.../relational/TableBuiltinScalarFunction.java | 2 +
.../db/relational/grammar/sql/RelationalSql.g4 | 24 +-
pom.xml | 19 +-
583 files changed, 22427 insertions(+), 12995 deletions(-)
rename .github/workflows/{pipe-it-2cluster.yml => pipe-it.yml} (62%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/mqtt/Message.java
=>
example/mqtt-customize/src/main/java/org/apache/iotdb/mqtt/server/MyMessage.java
(68%)
delete mode 100644
integration-test/src/main/java/org/apache/iotdb/itbase/category/MultiClusterIT2AutoCreateSchema.java
copy
integration-test/src/main/java/org/apache/iotdb/itbase/category/{ClusterIT.java
=> MultiClusterIT2DualTableManualBasic.java} (94%)
copy
integration-test/src/main/java/org/apache/iotdb/itbase/category/{AIClusterIT.java
=> MultiClusterIT2DualTableManualEnhanced.java} (93%)
copy
integration-test/src/main/java/org/apache/iotdb/itbase/category/{ClusterIT.java
=> MultiClusterIT2DualTreeAutoBasic.java} (94%)
copy
integration-test/src/main/java/org/apache/iotdb/itbase/category/{ClusterIT.java
=> MultiClusterIT2DualTreeAutoEnhanced.java} (94%)
copy
integration-test/src/main/java/org/apache/iotdb/itbase/category/{ClusterIT.java
=> MultiClusterIT2DualTreeManual.java} (94%)
delete mode 100644
integration-test/src/main/java/org/apache/iotdb/itbase/category/MultiClusterIT2ManualCreateSchema.java
delete mode 100644
integration-test/src/main/java/org/apache/iotdb/itbase/category/MultiClusterIT2TableModel.java
rename
integration-test/src/test/java/org/apache/iotdb/cli/it/{AbstractScript.java =>
AbstractScriptIT.java} (98%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/partition/{IoTDBAutoRegionGroupExtensionIT2.java
=> IoTDBAutoRegionGroupExtension2IT.java} (98%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/partition/{IoTDBPartitionTableAutoCleanTest.java
=> IoTDBPartitionTableAutoCleanIT.java} (99%)
copy
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/commit/batch/{IoTDBRegionMigrateNormalITForIoTV2Batch.java
=> IoTDBRegionMigrateNormalITForIoTV2BatchIT.java} (96%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/commit/batch/{IoTDBRegionMigrateOtherITForIoTV2Batch.java
=> IoTDBRegionMigrateOtherForIoTV2BatchIT.java} (97%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/commit/stream/{IoTDBRegionMigrateNormalITForIoTV2Stream.java
=> IoTDBRegionMigrateNormalForIoTV2StreamIT.java} (97%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/commit/stream/{IoTDBRegionMigrateOtherITForIoTV2Stream.java
=> IoTDBRegionMigrateOtherITForIoTV2StreamIT.java} (97%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/datanodecrash/iotv2/batch/{IoTDBRegionMigrateCoordinatorCrashWhenRemoveRemotePeerForIoTV2Batch.java
=> IoTDBRegionMigrateCoordinatorCrashWhenRemoveRemotePeerForIoTV2BatchIT.java}
(99%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/datanodecrash/iotv2/batch/{IoTDBRegionMigrateDataNodeCrashForIoTV2Batch.java
=> IoTDBRegionMigrateDataNodeCrashForIoTV2BatchIT.java} (98%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/datanodecrash/iotv2/batch/{IoTDBRegionMigrateOriginalCrashWhenDeleteLocalPeerForIoTV2Batch.java
=> IoTDBRegionMigrateOriginalCrashWhenDeleteLocalPeerForIoTV2BatchIT.java}
(99%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/datanodecrash/iotv2/batch/{IoTDBRegionMigrateOriginalCrashWhenRemoveRemotePeerForIoTV2Batch.java
=> IoTDBRegionMigrateOriginalCrashWhenRemoveRemotePeerForIoTV2BatchIT.java}
(99%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/datanodecrash/iotv2/stream/{IoTDBRegionMigrateCoordinatorCrashWhenRemoveRemotePeerForIoTV2Stream.java
=>
IoTDBRegionMigrateCoordinatorCrashWhenRemoveRemotePeerForIoTV2StreamIT.java}
(99%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/datanodecrash/iotv2/stream/{IoTDBRegionMigrateDataNodeCrashForIoTV2Stream.java
=> IoTDBRegionMigrateDataNodeCrashForIoTV2StreamIT.java} (98%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/datanodecrash/iotv2/stream/{IoTDBRegionMigrateOriginalCrashWhenDeleteLocalPeerForIoTV2Stream.java
=> IoTDBRegionMigrateOriginalCrashWhenDeleteLocalPeerForIoTV2StreamIT.java}
(99%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/datanodecrash/iotv2/stream/{IoTDBRegionMigrateOriginalCrashWhenRemoveRemotePeerForIoTV2Stream.java
=> IoTDBRegionMigrateOriginalCrashWhenRemoveRemotePeerForIoTV2StreamIT.java}
(99%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/iotv2/batch/{IoTDBRegionMigrateClusterCrashIoTV2Batch.java
=> IoTDBRegionMigrateClusterCrashIoTV2BatchIT.java} (97%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/iotv2/batch/{IoTDBRegionMigrateConfigNodeCrashIoTV2Batch.java
=> IoTDBRegionMigrateConfigNodeCrashIoTV2BatchIT.java} (98%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/iotv2/stream/{IoTDBRegionMigrateClusterCrashIoTV2Stream.java
=> IoTDBRegionMigrateClusterCrashIoTV2StreamIT.java} (98%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/iotv2/stream/{IoTDBRegionMigrateConfigNodeCrashIoTV2Stream.java
=> IoTDBRegionMigrateConfigNodeCrashIoTV2StreamIT.java} (98%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/removeconfignode/IoTDBRemoveConfigNodeITFramework.java
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/{regionmigration/pass/commit/batch/IoTDBRegionMigrateNormalITForIoTV2Batch.java
=> removeconfignode/IoTDBRemoveConfigNodeNormalIT.java} (64%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{ =>
dual}/tablemodel/TableModelUtils.java (99%)
rename
integration-test/src/test/java/org/apache/iotdb/pipe/it/{tablemodel/AbstractPipeTableModelTestIT.java
=> dual/tablemodel/manual/AbstractPipeTableModelDualManualIT.java} (95%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{tablemodel =>
dual/tablemodel/manual/basic}/IoTDBPipeAlterIT.java (97%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{tablemodel =>
dual/tablemodel/manual/basic}/IoTDBPipeDataSinkIT.java (98%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{tablemodel =>
dual/tablemodel/manual/basic}/IoTDBPipeExtractorIT.java (99%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{tablemodel =>
dual/tablemodel/manual/basic}/IoTDBPipeIsolationIT.java (97%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{tablemodel =>
dual/tablemodel/manual/basic}/IoTDBPipeLifeCycleIT.java (82%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{tablemodel =>
dual/tablemodel/manual/basic}/IoTDBPipeProtocolIT.java (97%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{tablemodel =>
dual/tablemodel/manual/basic}/IoTDBPipeSwitchStatusIT.java (97%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{tablemodel =>
dual/tablemodel/manual/basic}/IoTDBPipeSyntaxIT.java (98%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{tablemodel =>
dual/tablemodel/manual/basic}/IoTDBPipeWithLoadIT.java (97%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{tablemodel =>
dual/tablemodel/manual/basic}/IoTDBTablePatternFormatIT.java (98%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{tablemodel =>
dual/tablemodel/manual/enhanced}/IoTDBPipeAutoConflictIT.java (96%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{tablemodel =>
dual/tablemodel/manual/enhanced}/IoTDBPipeAutoDropIT.java (93%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{tablemodel =>
dual/tablemodel/manual/enhanced}/IoTDBPipeClusterIT.java (98%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{tablemodel =>
dual/tablemodel/manual/enhanced}/IoTDBPipeConnectorCompressionIT.java (97%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{tablemodel =>
dual/tablemodel/manual/enhanced}/IoTDBPipeConnectorParallelIT.java (90%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{tablemodel =>
dual/tablemodel/manual/enhanced}/IoTDBPipeDoubleLivingIT.java (95%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeIdempotentIT.java
rename
integration-test/src/test/java/org/apache/iotdb/pipe/it/{manual/IoTDBPipeTableManualIT.java
=> dual/tablemodel/manual/enhanced/IoTDBPipeMetaIT.java} (76%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{tablemodel =>
dual/tablemodel/manual/enhanced}/IoTDBPipeNullValueIT.java (93%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{tablemodel =>
dual/tablemodel/manual/enhanced}/IoTDBPipeTypeConversionISessionIT.java (95%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{tablemodel =>
dual/tablemodel/manual/enhanced}/IoTDBPipeTypeConversionIT.java (97%)
rename
integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate/AbstractPipeDualAutoIT.java
=> dual/treemodel/auto/AbstractPipeDualTreeModelAutoIT.java} (97%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate =>
dual/treemodel/auto/basic}/IoTDBPipeAlterIT.java (98%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate =>
dual/treemodel/auto/basic}/IoTDBPipeConnectorParallelIT.java (90%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate =>
dual/treemodel/auto/basic}/IoTDBPipeDataSinkIT.java (97%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate =>
dual/treemodel/auto/basic}/IoTDBPipeExtractorIT.java (99%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate =>
dual/treemodel/auto/basic}/IoTDBPipeLifeCycleIT.java (97%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate =>
dual/treemodel/auto/basic}/IoTDBPipeProcessorIT.java (94%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate =>
dual/treemodel/auto/basic}/IoTDBPipeProtocolIT.java (98%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate =>
dual/treemodel/auto/basic}/IoTDBPipeSwitchStatusIT.java (97%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate =>
dual/treemodel/auto/basic}/IoTDBPipeSyntaxIT.java (98%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate =>
dual/treemodel/auto/basic}/IoTDBTreePatternFormatIT.java (94%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate =>
dual/treemodel/auto/enhanced}/IoTDBPipeAutoConflictIT.java (98%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate =>
dual/treemodel/auto/enhanced}/IoTDBPipeAutoDropIT.java (94%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate =>
dual/treemodel/auto/enhanced}/IoTDBPipeClusterIT.java (98%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate =>
dual/treemodel/auto/enhanced}/IoTDBPipeConditionalOperationsIT.java (96%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate =>
dual/treemodel/auto/enhanced}/IoTDBPipeConnectorCompressionIT.java (97%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate =>
dual/treemodel/auto/enhanced}/IoTDBPipeIdempotentIT.java (79%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate =>
dual/treemodel/auto/enhanced}/IoTDBPipeNullValueIT.java (97%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate =>
dual/treemodel/auto/enhanced}/IoTDBPipeWithLoadIT.java (93%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate =>
dual/treemodel/auto/enhanced}/PipeNowFunctionIT.java (96%)
rename
integration-test/src/test/java/org/apache/iotdb/pipe/it/{manual/AbstractPipeDualManualIT.java
=> dual/treemodel/manual/AbstractPipeDualTreeModelManualIT.java} (97%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{ =>
dual/treemodel}/manual/IoTDBPipeInclusionIT.java (97%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{ =>
dual/treemodel}/manual/IoTDBPipeManualConflictIT.java (97%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{ =>
dual/treemodel}/manual/IoTDBPipeMetaHistoricalIT.java (98%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{ =>
dual/treemodel}/manual/IoTDBPipeMetaLeaderChangeIT.java (97%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{ =>
dual/treemodel}/manual/IoTDBPipeMetaRestartIT.java (96%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{ =>
dual/treemodel}/manual/IoTDBPipeMultiSchemaRegionIT.java (95%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{ =>
dual/treemodel}/manual/IoTDBPipePermissionIT.java (97%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{ =>
dual/treemodel}/manual/IoTDBPipeReqAutoSliceIT.java (98%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{ =>
dual/treemodel}/manual/IoTDBPipeTypeConversionISessionIT.java (99%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{ =>
dual/treemodel}/manual/IoTDBPipeTypeConversionIT.java (98%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/db/it/IoTDBAuthenticationTableIT.java
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/{query/old/builtinfunction/scalar/IoTDBCastFunctionTableSpecialIT.java
=> db/it/IoTDBLoadConfigurationTableIT.java} (58%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/db/it/IoTDBSetSystemStatusTableIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/mqtt/IoTDBMQTTServiceIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/old/query/IoTDBGreatestLeastTableIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/IoTDBMaintainAuthIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/IoTDBQueryAuthIT.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/tsfile/subscription/AbstractSubscriptionTsFile.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/tsfile/subscription/CommonParam.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/tsfile/subscription/SubscriptionTableTsFile.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/tsfile/subscription/SubscriptionTreeTsFile.java
create mode 100644 iotdb-client/client-py/session_ssl_example.py
copy
iotdb-client/jdbc/src/main/java/org/apache/iotdb/jdbc/{IoTDBDatabaseMetadata.java
=> IoTDBAbstractDatabaseMetadata.java} (61%)
create mode 100644
iotdb-client/jdbc/src/main/java/org/apache/iotdb/jdbc/relational/IoTDBRelationalDatabaseMetadata.java
delete mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/util/CheckedSupplier.java
delete mode 100644
iotdb-core/confignode/src/assembly/resources/sbin/remove-confignode.bat
delete mode 100755
iotdb-core/confignode/src/assembly/resources/sbin/remove-confignode.sh
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/extractor/PipeConfigPhysicalPlanTableScopeParseVisitor.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/extractor/PipeConfigPhysicalPlanTreeScopeParseVisitor.java
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/schema/{ConfignodeSnapshotParser.java
=> ConfigNodeSnapshotParser.java} (91%)
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/extractor/PipeConfigPhysicalPlanScopeParseVisitorTest.java
delete mode 100644
iotdb-core/datanode/src/assembly/resources/sbin/remove-datanode.bat
delete mode 100755
iotdb-core/datanode/src/assembly/resources/sbin/remove-datanode.sh
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/mqtt/LinePayloadFormatter.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/mqtt/TableMessage.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/mqtt/{Message.java
=> TreeMessage.java} (87%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/{RemoveDataNodeTask.java
=> RemoveConfigNodeTask.java} (82%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/{sys/MergeTask.java
=> session/SetSqlDialectTask.java} (76%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{StopRepairData.java
=> LoadConfiguration.java} (84%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{RemoveDataNode.java
=> RemoveConfigNode.java} (75%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{KillQuery.java
=> SetSqlDialect.java} (72%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{StartRepairData.java
=> SetSystemStatus.java} (86%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/{RemoveDataNodeStatement.java
=> RemoveConfigNodeStatement.java} (84%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/{TestConnectionStatement.java
=> SetSqlDialectStatement.java} (63%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/{ShowVersionStatement.java
=> ShowCurrentSqlDialectStatement.java} (78%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/{ShowVersionStatement.java
=> ShowCurrentUserStatement.java} (78%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/multi/AbstractGreatestLeastColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/multi/BinaryGreatestColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/multi/BinaryLeastColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/multi/BooleanGreatestColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/multi/BooleanLeastColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/multi/DoubleGreatestColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/multi/DoubleLeastColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/multi/FloatGreatestColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/multi/FloatLeastColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/multi/Int32GreatestColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/multi/Int32LeastColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/multi/Int64GreatestColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/multi/Int64LeastColumnTransformer.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/{RPCService.java
=> ExternalRPCService.java} (95%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/{selector/ICrossSpaceSelector.java
=> io/CompactionDiskTSMIterator.java} (56%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/chunk/metadata/AlignedPageMetadata.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/chunk/metadata/PageMetadata.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionPipeTabletIterationSnapshot.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/datastructure/MergeSortAlignedTVListIterator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/datastructure/MergeSortTvListIterator.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/{SetThreadName.java
=> datastructure/PageColumnAccessInfo.java} (57%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/protocol/mqtt/LinePayloadFormatterTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/memtable/MemChunkDeserializeTest.java
