This is an automated email from the ASF dual-hosted git repository.
lancelly pushed a change to branch support_uncorrelated_in_predicate
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 3280f84092e fix semi join operator with right sort null first
add 69fb8dc479b Pipe: fix the reference count leak of events in async
connector during restart (#14324)
add 0d22f2b3f35 Load: flush metadata of generated files to avoid OOM
(#14419)
add eb3f554d654 Load: when table exists in IoTDB, make sure the
existing/incoming ID columns are the prefix of the incoming/existing ID columns
(#14341)
add 78ec1c9f825 Load: Fix Memory Allocation and Release Mismatch in
LoadTsFileDataCacheMemoryBlock (#14375)
add 65f3ad46274 [To dev/1.3]Support auto mkdirs in ExportData (#14378)
(#14400)
add 0c444734d50 Load: fix that empty measurement in aligned devices may
cause warnings (#14444)
add fbd17931ebc Pipe: Fixed the bug that the handling logic of return
status is not of use in convert execution visitor (#14443)
add 0d69f7149b8 Pipe: Fix the null pointer exception when the receiver
closes the Session (#14446)
add f6b16ed0aec Pipe: Added permission check for config receiver (#14418)
add 6a28a0792c3 Pipe: Introduce a minimum restart interval to optimize the
restart strategy to avoid frequent restarts & Stay tsfile extraction mode if
the task is currently restarted (#14374)
add d3f63920531 Bump h2-mvstore to 2.3.232 (#14450)
add 5f7b570aa5d Fix ratis byte limit configuration too small (#14449)
add aa8e21c664f Fix ThreadPool Metric NPE #14459
add 9df0030ebca Add TsfileSize column to 'show regions' (#14436)
add 6efe1125c8f Fix query scan will return duplicated timestamp or
unordered timestamp while TsFileResource degrading
add b5fe66ee754 Add eviction metrics in binary allocator (#14432)
add 7d6753a81c9 Bump ratis to 3.1.2-a862328-SNAPSHOT
add addbf964e4a Pipe: Do not stop runtime agent when removing datanode
(#14474)
add ef6a06a2def Subscription: allow generate subsequent events with the
same tablet batch to avoid large message & improve poll logic to avoid
unnecessary nack (#14452)
add 59dac3272a6 [TABLE MODEL] Support user-defined aggregate function
add 876d8469515 fix checkNonAlignedDeviceSeries (#14461)
add 91b672da649 Allow hot reloading compaction from disabled status
(#14470)
add 067b0b35f51 Initialize compaction schedule even when compaction is not
enabled (#14479)
add 55b37e0d14a Pipe: Fix infinite loop when thread is interrupted in
invoking PipeMemoryBlock#close & Avoid throwing new InterruptedException in
conditions that can be self-restoring (#14471)
add 72c803fa981 Table model insertion auto-cast & Fix TVList not removed
when all data are deleted. (#14391)
add 2076bf6b86c Fix setting illegal default_storage_group_level does not
report an error (#14477)
add 2a26c6eb52b Pipe: Fixed the bug that auth plan with system privileges
can not be transferred (#14489)
add 0a8ad9751c6 Add format function in table model
add c5547b09d6e Pipe & Subscription: support synonym database and table
parameters for table model (#14487)
add 640a0c7ac1b Isolate Show-Queries of TableModel and TreeModel
add 67cd48da3fb Modify the UDF Time Dimension
add 96f8c19a80b Subscription: fix NPE when building consumer with missing
id & add more checker for topic operations using session (#14493)
add 61fa8d6f004 Implement schema of 'information_schema' & Make
AddLocation plan immune readOnly state
add d34511a93f3 Fix error in template + sort + offset + limit + align by
device
add a877b82b819 Make the construction method of class
TableAggTableScanOperator tidy
add f013e975933 Remove redundant trim (#14502)
add a04c752bc24 fix compaction task comparator & fix the conflicts between
inner compaction selection conditions (#14495)
add f215c4225a1 Revert "[IOTDB-6353] replace cglib to byte-buddy (#14426)"
(#14497)
add 81db737e325 Add lock for insertSeparatorToWAL (#14478)
add 50241423ef8 Apply new configurations in memory before update file
(#14500)
add aee90fb8442 Separate table/tree model database & Added
SchemaRegionGroupNum / dataRegionGroupNum in table databases details &
Optimized the message for table flush operation with database
add 1bb5667a549 add Content-Type in prometheus reporter (#14507)
add 97046f9023c Encountering empty tablets during batch export of tsfile
does not affect subsequent export tasks (#14484)
add fa4f6da8da0 Added the missed separate mTree logic for tree/table
database plans (#14509)
add 4a6a9ed406f fix: docker replace conf sh (#14518)
add e704935dead reduce useless loops (#14513)
add c0de204cd35 feat: add DEFAULT_SQL_DIALECT for start-cli (#14519)
add c059bcc2068 Feature add support for query, nonQuery, and insertTablet
interfaces for table models in the REST service (#14165)
add 5fe299a7c67 Fix error msg of Inpredicate
add 7d92f475296 [region migration] Make peer list correct when
IoTConsensus & IoTConsensusV2 & Ratis starting (#14505)
add 88e8800487f Bump jinja2 from 3.1.4 to 3.1.5 in /iotdb-core/ainode
(#14530)
add e54e8cc3988 increase the memory used in UT (#14528)
add 615da741337 Fixed the bug that database "root" in tree model can be
created
add 1ca1f9c0b91 Fixed the bug that nodes with non-trivial wildcards are
not correctly handled in mods setting (#12978)
add 6b53f75482e Fix load data region snapshot miss some writing metrics
(#14532)
add 1464446ca6d DataRegionMetric was not deleted when the DataRegion was
removed (#14506)
add 3ae23550d61 [region migration] Log optimization (#14536)
add 17729a987b2 [remove datanode] Remove LoadScore sort to fix
RegionPriority order (#14527)
add d2f95b87e65 Pipe: Receiver write table model data type conversion test
(#14499)
add 159e558eadd Subscription: improve `createTopic` API with nullable
properties or when if not exists cond is set (#14516)
add 99221da8ca8 Load: detect region replica set changes due to Region
Migration (#14104)
add 54ab67c2f41 [Py-client] rename table concept (#14531)
add 4e76b3d1333 Add database name for table model CLI
add 266c3b08fdc Compaction task can not stopped when abort compaction
(#14538)
add 3238ec257a1 Add the used memory calculation for
DescPriorityMergeReader which is missed before (#14548)
add 530dd0bc653 [IoTConsensus] Refine IoTConsensus Configuration logs
(#14542)
add 80e564b6ef5 Pipe: Fixed the issue of NPE caused by unexpected
exceptions thrown during the use of AsyncClient. (#14556)
add f156ca9f284 Remove ' in create model uri
add 949fd17bb3f Add branches name pattern that will trigger CI (#14567)
add 2c4bb243956 Fix that config changes rejected by DN will be written to
CN's config (#14551)
add c4f8ee9a168 Fix the issue that the cache key used for queries may
conflict. (#14560)
add 81a58c0e890 Rename table concept (#14537)
add f1199fa3fdf Compaction Read Metric and rate limit are bypassed due to
parent class modification (#14559)
add 755516f1eb1 refactor(client-cpp): TableModel ID->TAG,
MEASUREMENT->FIELD (#14546)
add 72184a405b4 merge master
No new revisions were added by this update.
Summary of changes:
.github/workflows/cluster-it-1c1d.yml | 1 +
.github/workflows/cluster-it-1c1d1a.yml | 2 +
.github/workflows/cluster-it-1c3d.yml | 2 +
.github/workflows/compile-check.yml | 2 +
.github/workflows/dependency-check.yml | 2 +
.github/workflows/multi-language-client.yml | 2 +
.github/workflows/pipe-it-2cluster.yml | 2 +
.github/workflows/sonar-codecov.yml | 2 +
.github/workflows/table-cluster-it-1c1d.yml | 2 +
.github/workflows/table-cluster-it-1c3d.yml | 2 +
.github/workflows/todos-check.yml | 1 +
.github/workflows/unit-test.yml | 4 +-
dependencies.json | 2 +-
.../main/DockerCompose/replace-conf-from-env.sh | 33 +-
example/client-cpp-example/pom.xml | 4 +
example/client-cpp-example/src/CMakeLists.txt | 3 +
.../src/TableModelSessionExample.cpp | 129 +-
.../java/org/apache/iotdb/TableHttpExample.java | 223 ++
.../java/org/apache/iotdb/TableHttpsExample.java | 223 ++
.../org/apache/iotdb/TableModelSessionExample.java | 14 +-
.../apache/iotdb/TableModelSessionPoolExample.java | 28 +-
.../apache/iotdb/udf/AggregateFunctionExample.java | 117 +
.../apache/iotdb/udf/ScalarFunctionExample.java | 2 +-
.../query/udf/example/relational/FirstTwoSum.java | 168 ++
.../db/query/udf/example/relational/MyAvg.java | 126 +
.../db/query/udf/example/relational/MyCount.java | 95 +
.../it/env/cluster/config/MppCommonConfig.java | 12 +
.../env/cluster/config/MppSharedCommonConfig.java | 14 +
.../it/env/remote/config/RemoteCommonConfig.java | 5 +
.../org/apache/iotdb/itbase/env/CommonConfig.java | 6 +
.../apache/iotdb/db/it/IoTDBFileTimeIndexIT.java | 117 +
.../iotdb/db/it/IoTDBSetConfigurationIT.java | 77 +-
.../org/apache/iotdb/db/it/IoTDBSimpleQueryIT.java | 1 -
.../IoTDBAlignByDeviceWithTemplateIT.java | 28 +-
.../db/it/query/IoTDBEncryptionValueQueryIT.java | 2 +-
.../iotdb/db/it/schema/IoTDBCreateDatabaseIT.java | 193 ++
.../db/it/schema/IoTDBCreateStorageGroupIT.java | 153 --
.../db/it/schema/IoTDBDeleteStorageGroupIT.java | 4 +-
.../org/apache/iotdb/db/it/utils/TestUtils.java | 42 +
.../iotdb/pipe/it/manual/IoTDBPipeInclusionIT.java | 12 +-
.../pipe/it/manual/IoTDBPipeMetaHistoricalIT.java | 12 +-
.../pipe/it/manual/IoTDBPipePermissionIT.java | 71 +-
.../manual/IoTDBPipeTypeConversionISessionIT.java | 2 +-
.../pipe/it/tablemodel/IoTDBPipeClusterIT.java | 3 +-
.../IoTDBPipeTypeConversionISessionIT.java | 498 ++++
.../it/tablemodel/IoTDBPipeTypeConversionIT.java | 632 +++++
.../pipe/it/tablemodel/IoTDBPipeWithLoadIT.java | 248 ++
.../it/tablemodel/IoTDBTablePatternFormatIT.java | 2 +-
.../iotdb/pipe/it/tablemodel/TableModelUtils.java | 20 +-
.../it/db/it/IoTDBCaseWhenThenTableIT.java | 6 +-
.../relational/it/db/it/IoTDBDeletionTableIT.java | 68 +-
.../it/db/it/IoTDBDisableDeletionTableIT.java | 2 +-
.../it/db/it/IoTDBExecuteBatchTableIT.java | 26 +-
.../it/db/it/IoTDBFlushQueryTableIT.java | 38 +-
.../it/db/it/IoTDBInsertAlignedValuesTableIT.java | 122 +-
.../relational/it/db/it/IoTDBInsertTableIT.java | 267 +--
.../it/db/it/IoTDBMultiDeviceTableIT.java | 90 +-
...va => IoTDBMultiTAGsWithAttributesTableIT.java} | 56 +-
.../relational/it/db/it/IoTDBRecoverTableIT.java | 16 +-
.../it/db/it/IoTDBRecoverUnclosedTableIT.java | 16 +-
.../relational/it/db/it/IoTDBRestartTableIT.java | 51 +-
.../it/db/it/udf/IoTDBSQLFunctionManagementIT.java | 58 +-
.../udf/IoTDBUserDefinedAggregateFunctionIT.java | 690 ++++++
....java => IoTDBUserDefinedScalarFunctionIT.java} | 12 +-
.../relational/it/db/it/udf/SQLFunctionUtils.java | 87 +
.../it/query/old/IoTDBDatetimeFormatTableIT.java | 2 +-
.../it/query/old/IoTDBFilterBetweenTableIT.java | 2 +-
.../it/query/old/IoTDBFilterNullTableIT.java | 2 +-
.../it/query/old/IoTDBFilterTableIT.java | 10 +-
.../it/query/old/IoTDBNestedQueryTableIT.java | 6 +-
.../it/query/old/IoTDBSimpleQueryTableIT.java | 59 +-
.../alignbydevice/IoTDBAlignByDeviceTableIT.java | 2 +-
.../IoTDBAlignByDeviceWithTemplateTableIT.java | 2 +-
...oTDBOrderByLimitOffsetAlignByDeviceTableIT.java | 4 +-
.../IoTDBOrderByWithAlignByDeviceTableIT.java | 6 +-
.../IoTDBAlignedOffsetLimitPushDownTableIT.java | 2 +-
.../it/query/old/aligned/TableUtils.java | 2 +-
.../scalar/IoTDBCastFunctionTableIT.java | 6 +-
.../scalar/IoTDBCastFunctionTableSpecialIT.java | 2 +-
.../scalar/IoTDBDiffFunctionTableIT.java | 2 +-
.../scalar/IoTDBFormatFunctionTableIT.java | 190 ++
.../scalar/IoTDBReplaceFunctionTableIT.java | 2 +-
.../scalar/IoTDBRoundFunctionTableIT.java | 2 +-
.../scalar/IoTDBScalarFunctionTableIT.java | 62 +-
.../scalar/IoTDBSubStringFunctionTableIT.java | 2 +-
.../it/query/old/orderBy/IoTDBOrderByTableIT.java | 36 +-
.../it/query/old/query/IoTDBArithmeticTableIT.java | 4 +-
.../it/query/old/query/IoTDBFuzzyQueryTableIT.java | 2 +-
.../it/query/old/query/IoTDBInTableIT.java | 4 +-
...oTDBNoSelectExpressionAfterAnalyzedTableIT.java | 2 +-
.../query/old/query/IoTDBNullOperandTableIT.java | 2 +-
.../it/query/old/query/IoTDBPaginationTableIT.java | 4 +-
.../it/query/old/query/IoTDBQueryDemoTableIT.java | 2 +-
.../IoTDBQueryWithComplexValueFilterTableIT.java | 2 +-
.../it/query/old/query/IoTDBResultSetTableIT.java | 6 +-
.../query/IoTDBSelectCompareExpressionTableIT.java | 2 +-
.../it/query/recent/IoTDBFillTableIT.java | 6 +-
.../it/query/recent/IoTDBGapFillTableIT.java | 2 +-
.../it/query/recent/IoTDBNullIdQueryIT.java | 4 +-
.../it/query/recent/IoTDBTableAggregationIT.java | 4 +-
.../recent/subquery/SubqueryDataSetUtils.java | 4 +-
.../it/IoTDBRestServiceCaseWhenThenIT.java} | 526 ++--
.../it/rest/it/IoTDBRestServiceFlushQueryIT.java | 311 +++
.../relational/it/rest/it/IoTDBRestServiceIT.java | 352 +++
.../it/IoTDBRestServiceInsertAlignedValuesIT.java | 361 +++
.../iotdb/relational/it/rest/it/RestUtils.java | 128 +
.../relational/it/schema/IoTDBDatabaseIT.java | 166 +-
.../iotdb/relational/it/schema/IoTDBDeviceIT.java | 14 +-
.../iotdb/relational/it/schema/IoTDBTableIT.java | 56 +-
.../it/session}/IoTDBSessionRelationalIT.java | 612 ++++-
.../it/session/IoTDBTableModelSessionIT.java | 8 +-
.../pool/IoTDBInsertTableSessionPoolIT.java | 57 +-
.../session/pool/IoTDBTableModelSessionPoolIT.java | 4 +-
.../it/local/IoTDBSubscriptionBasicIT.java | 69 +
.../param/IoTDBTestParamPullConsumerIT.java | 8 +-
.../param/IoTDBTestParamPushConsumerIT.java | 8 +-
.../regression/param/IoTDBTestParamTopicIT.java | 11 +-
.../apache/iotdb/tools/it/ExportTsFileTestIT.java | 4 +-
.../customizer/config/AggregateFunctionConfig.java | 53 +
.../udf/api/relational/AggregateFunction.java | 81 +-
.../iotdb/udf/api/relational/access/Record.java | 3 +-
.../cli/src/assembly/resources/sbin/start-cli.bat | 10 +
.../cli/src/assembly/resources/sbin/start-cli.sh | 17 +-
.../java/org/apache/iotdb/cli/AbstractCli.java | 26 +-
.../src/main/java/org/apache/iotdb/cli/Cli.java | 4 +-
.../org/apache/iotdb/tool/data/ExportData.java | 5 +-
.../org/apache/iotdb/tool/tsfile/ExportTsFile.java | 37 +-
iotdb-client/client-cpp/src/main/Session.h | 37 +-
iotdb-client/client-cpp/src/main/TableSession.cpp | 2 +-
iotdb-client/client-cpp/src/main/TableSession.h | 2 +-
.../src/test/cpp/sessionRelationalIT.cpp | 26 +-
iotdb-client/client-py/iotdb/utils/NumpyTablet.py | 2 +-
iotdb-client/client-py/iotdb/utils/Tablet.py | 6 +-
.../client-py/table_model_session_example.py | 2 +-
.../client-py/table_model_session_pool_example.py | 2 +-
.../tests/integration/test_relational_session.py | 14 +-
.../tests/integration/test_tablemodel_insert.py | 408 ++--
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 4 +
.../iotdb/rpc/subscription/config/TopicConfig.java | 9 +-
.../rpc/subscription/config/TopicConstant.java | 8 +-
.../session/subscription/SubscriptionSession.java | 17 +-
.../consumer/SubscriptionConsumer.java | 28 +-
.../consumer/SubscriptionPullConsumer.java | 7 +-
.../consumer/SubscriptionPushConsumer.java | 3 +-
.../session/subscription/util/IdentifierUtils.java | 10 +-
.../iotdb/session/SessionCacheLeaderTest.java | 12 +-
.../ainode/iotdb/ainode/model/model_factory.py | 2 -
iotdb-core/ainode/poetry.lock | 8 +-
.../heartbeat/DataNodeHeartbeatHandler.java | 3 +
.../confignode/conf/ConfigNodeDescriptor.java | 600 ++---
.../read/ainode/GetAINodeConfigurationPlan.java | 15 -
.../request/read/database/CountDatabasePlan.java | 15 +-
.../request/read/database/GetDatabasePlan.java | 7 +-
.../request/read/model/GetModelInfoPlan.java | 16 -
.../request/read/model/ShowModelPlan.java | 20 -
.../database/AdjustMaxRegionGroupNumPlan.java | 20 +-
.../request/write/quota/SetSpaceQuotaPlan.java | 2 +-
.../write/region/CreateRegionGroupsPlan.java | 39 +-
.../statemachine/ConfigRegionStateMachine.java | 4 +-
.../exception/NoAvailableRegionGroupException.java | 2 +-
.../confignode/manager/ClusterQuotaManager.java | 8 +-
.../iotdb/confignode/manager/ConfigManager.java | 196 +-
.../apache/iotdb/confignode/manager/IManager.java | 6 +-
.../iotdb/confignode/manager/ProcedureManager.java | 19 +-
.../iotdb/confignode/manager/load/LoadManager.java | 13 +-
.../manager/load/balancer/PartitionBalancer.java | 18 +-
.../manager/load/balancer/RegionBalancer.java | 28 +-
.../manager/load/balancer/RouteBalancer.java | 7 +-
.../router/priority/GreedyPriorityBalancer.java | 42 +-
.../router/priority/IPriorityBalancer.java | 5 +-
.../router/priority/LeaderPriorityBalancer.java | 21 +-
.../confignode/manager/load/cache/LoadCache.java | 29 +-
.../load/cache/node/DataNodeHeartbeatCache.java | 3 +-
.../iotdb/confignode/manager/node/NodeManager.java | 8 +-
.../manager/partition/PartitionManager.java | 151 +-
.../manager/partition/PartitionMetrics.java | 3 +-
.../PipeConfigPhysicalPlanPatternParseVisitor.java | 12 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 119 +
.../manager/schema/ClusterSchemaManager.java | 102 +-
.../persistence/executor/ConfigPlanExecutor.java | 14 +-
.../partition/DatabasePartitionTable.java | 5 +-
.../persistence/partition/PartitionInfo.java | 47 +-
.../confignode/persistence/pipe/PipeTaskInfo.java | 12 +-
.../persistence/schema/ClusterSchemaInfo.java | 318 +--
.../confignode/persistence/schema/ConfigMTree.java | 59 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 15 +-
.../procedure/env/RegionMaintainHandler.java | 29 +-
.../impl/region/AddRegionPeerProcedure.java | 12 +-
.../impl/region/CreateRegionGroupsProcedure.java | 51 +-
.../impl/region/RegionMigrateProcedure.java | 34 +-
.../impl/region/RemoveRegionPeerProcedure.java | 22 +-
.../impl/schema/AlterLogicalViewProcedure.java | 110 +-
.../impl/schema/DeactivateTemplateProcedure.java | 2 +-
.../impl/schema/DeleteTimeSeriesProcedure.java | 2 +-
.../impl/schema/table/CreateTableProcedure.java | 119 +-
.../impl/schema/table/DeleteDevicesProcedure.java | 33 +-
.../schema/table/DropTableColumnProcedure.java | 23 +-
.../impl/schema/table/DropTableProcedure.java | 43 +-
.../procedure/state/schema/CreateTableState.java | 1 -
.../thrift/ConfigNodeRPCServiceProcessor.java | 75 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 31 +-
.../router/priority/GreedyPriorityTest.java | 13 +-
.../priority/LeaderPriorityBalancerTest.java | 65 +-
.../confignode/persistence/PartitionInfoTest.java | 16 +-
.../persistence/schema/ClusterSchemaInfoTest.java | 2 +-
.../persistence/schema/ConfigMTreeTest.java | 23 +-
.../schema/table/AddTableColumnProcedureTest.java | 6 +-
.../schema/table/CreateTableProcedureTest.java | 11 +-
.../schema/table/DeleteDevicesProcedureTest.java | 2 +-
.../schema/table/DropTableColumnProcedureTest.java | 2 +-
.../impl/schema/table/DropTableProcedureTest.java | 2 +-
.../table/RenameTableColumnProcedureTest.java | 2 +-
.../table/SetTablePropertiesProcedureTest.java | 2 +-
.../org/apache/iotdb/consensus/IConsensus.java | 21 +-
.../apache/iotdb/consensus/iot/IoTConsensus.java | 101 +-
.../consensus/iot/IoTConsensusServerImpl.java | 39 +-
.../service/IoTConsensusRPCServiceProcessor.java | 15 +-
.../apache/iotdb/consensus/pipe/PipeConsensus.java | 139 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 78 +-
.../apache/iotdb/consensus/ratis/utils/Utils.java | 3 +-
.../iotdb/consensus/simple/SimpleConsensus.java | 12 +-
.../apache/iotdb/consensus/iot/ReplicateTest.java | 4 -
.../apache/iotdb/consensus/iot/StabilityTest.java | 82 +-
.../iotdb/consensus/ratis/RatisConsensusTest.java | 4 -
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 34 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 2515 ++++++--------------
.../db/conf/rest/IoTDBRestServiceDescriptor.java | 92 +-
.../dataregion/DataExecutionVisitor.java | 4 +
.../{ => load}/LoadEmptyFileException.java | 2 +-
.../db/exception/{ => load}/LoadFileException.java | 2 +-
.../{ => load}/LoadReadOnlyException.java | 2 +-
.../LoadRuntimeOutOfMemoryException.java | 2 +-
.../{ => load}/PartitionViolationException.java | 2 +-
.../load/RegionReplicaSetChangedException.java} | 22 +-
.../exception/metadata/DatabaseModelException.java | 53 -
.../exception/sql/StatementAnalyzeException.java | 4 +
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 37 +
.../subtask/connector/PipeConnectorSubtask.java | 9 +
.../connector/protocol/opcua/OpcUaNameSpace.java | 4 +-
.../async/IoTDBDataRegionAsyncConnector.java | 41 +-
.../PipeTransferTabletBatchEventHandler.java | 33 +-
.../PipeTransferTabletInsertNodeEventHandler.java | 14 +-
.../PipeTransferTabletInsertionEventHandler.java | 62 +-
.../handler/PipeTransferTabletRawEventHandler.java | 15 +-
.../handler/PipeTransferTrackableHandler.java | 98 +
.../async/handler/PipeTransferTsFileHandler.java | 39 +-
.../consensus/ConsensusPipeDataNodeDispatcher.java | 11 +
.../deletion/persist/PageCacheDeletionBuffer.java | 2 +-
.../db/pipe/event/common/PipeInsertionEvent.java | 6 +-
.../tablet/parser/TabletInsertionEventParser.java | 8 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 17 +-
...ileInsertionEventTableParserTabletIterator.java | 2 +-
.../dataregion/IoTDBDataRegionExtractor.java | 6 +-
...oricalDataRegionTsFileAndDeletionExtractor.java | 9 +-
.../realtime/PipeRealtimeDataRegionExtractor.java | 4 +-
.../PipeRealtimeDataRegionHybridExtractor.java | 11 +-
.../realtime/assigner/PipeDataRegionAssigner.java | 18 +-
.../protocol/legacy/loader/DeletionLoader.java | 2 +-
.../protocol/legacy/loader/TsFileLoader.java | 2 +-
.../pipeconsensus/PipeConsensusReceiver.java | 2 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 34 +-
.../transform/converter/ValueConverter.java | 4 +-
.../statement/PipeConvertedInsertRowStatement.java | 7 +
.../PipeConvertedInsertTabletStatement.java | 7 +
.../visitor/PipeStatementExceptionVisitor.java | 2 +-
...leStatementDataTypeConvertExecutionVisitor.java | 10 +-
...eeStatementDataTypeConvertExecutionVisitor.java | 10 +-
.../resource/memory/InsertNodeMemoryEstimator.java | 5 +-
.../db/pipe/resource/memory/PipeMemoryBlock.java | 14 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 4 +-
.../rest/table/v1/handler/ExceptionHandler.java | 91 +
.../table/v1/handler/ExecuteStatementHandler.java | 84 +
.../rest/table/v1/handler/QueryDataSetHandler.java | 219 ++
.../table/v1/handler/RequestValidationHandler.java | 100 +
.../v1/handler/StatementConstructionHandler.java | 188 ++
.../rest/table/v1/impl/RestApiServiceImpl.java | 293 +++
.../iotdb/db/protocol/session/SessionManager.java | 4 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 17 +-
.../thrift/impl/DataNodeRegionManager.java | 14 +-
.../execution/executor/RegionWriteExecutor.java | 7 +-
.../schema/source/TableDeviceFetchSource.java | 2 +-
.../schema/source/TableDeviceQuerySource.java | 2 +-
.../execution/operator/source/SeriesScanUtil.java | 30 +-
.../operator/source/ShowQueriesOperator.java | 23 +-
.../InformationSchemaContentSupplierFactory.java | 33 +-
.../TableAggregationTableScanOperator.java | 169 +-
.../source/relational/TableScanOperator.java | 4 +-
.../relational/aggregation/AccumulatorFactory.java | 38 +-
.../UserDefinedAggregateFunctionAccumulator.java | 123 +
.../GroupedUserDefinedAggregateAccumulator.java | 134 ++
.../relational/ColumnTransformerBuilder.java | 9 +
.../db/queryengine/plan/analyze/Analysis.java | 27 +-
.../db/queryengine/plan/analyze/AnalyzeUtils.java | 79 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 32 +-
.../plan/analyze/ClusterPartitionFetcher.java | 74 +-
.../db/queryengine/plan/analyze/IAnalysis.java | 2 +-
.../plan/analyze/IPartitionFetcher.java | 16 +-
.../plan/analyze/TemplatedAggregationAnalyze.java | 6 +-
.../queryengine/plan/analyze/TemplatedAnalyze.java | 7 +-
.../analyze/cache/partition/PartitionCache.java | 103 +-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 2 +-
.../analyze/load/LoadTsFileTableSchemaCache.java | 8 +-
.../load/LoadTsFileToTableModelAnalyzer.java | 7 +-
.../load/LoadTsFileToTreeModelAnalyzer.java | 2 +-
.../analyze/load/LoadTsFileTreeSchemaCache.java | 2 +-
.../load/TreeSchemaAutoCreatorAndVerifier.java | 18 +-
.../plan/analyze/schema/SchemaValidator.java | 6 +-
.../plan/execution/IQueryExecution.java | 3 +-
.../queryengine/plan/execution/QueryExecution.java | 13 +-
.../plan/execution/config/ConfigExecution.java | 5 +-
.../execution/config/TableConfigTaskVisitor.java | 44 +-
.../config/executor/ClusterConfigTaskExecutor.java | 79 +-
.../config/executor/IConfigTaskExecutor.java | 4 +-
.../execution/config/metadata/ShowRegionTask.java | 18 +-
.../relational/AbstractAlterOrDropTableTask.java | 4 +-
.../metadata/relational/CreateTableTask.java | 4 +-
.../config/metadata/relational/ShowDBTask.java | 31 +-
.../plan/execution/config/sys/FlushTask.java | 18 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 20 +-
.../db/queryengine/plan/planner/IPlanner.java | 4 +-
.../plan/planner/LocalExecutionPlanner.java | 9 +
.../plan/planner/TableOperatorGenerator.java | 262 +-
.../queryengine/plan/planner/TreeModelPlanner.java | 5 +-
.../distribution/WriteFragmentParallelPlanner.java | 2 +-
.../metadata/write/view/AlterLogicalViewNode.java | 47 +-
.../plan/planner/plan/node/write/InsertNode.java | 8 +-
.../plan/node/write/RelationalDeleteDataNode.java | 15 +-
.../node/write/RelationalInsertTabletNode.java | 14 +-
.../plan/relational/analyzer/Analysis.java | 58 +-
.../relational/analyzer/ExpressionTreeUtils.java | 5 +-
.../relational/analyzer/StatementAnalyzer.java | 7 +-
.../predicate/ConvertPredicateToFilterVisitor.java | 2 +-
.../schema/CheckSchemaPredicateVisitor.java | 4 +-
.../ConvertSchemaPredicateToFilterVisitor.java | 4 +-
.../plan/relational/metadata/Metadata.java | 6 +-
.../relational/metadata/TableMetadataImpl.java | 106 +-
.../plan/relational/metadata/TableSchema.java | 29 +-
.../metadata/fetcher/TableDeviceSchemaFetcher.java | 2 +-
.../fetcher/TableHeaderSchemaValidator.java | 68 +-
.../fetcher/cache/TableDeviceSchemaCache.java | 65 +-
.../plan/relational/planner/RelationPlanner.java | 11 +-
.../plan/relational/planner/TableModelPlanner.java | 5 +-
.../distribute/TableDistributedPlanGenerator.java | 71 +-
.../relational/planner/node/TableScanNode.java | 7 +-
.../node/schema/CreateOrUpdateTableDeviceNode.java | 5 +-
.../schema/TableDeviceAttributeUpdateNode.java | 9 +-
.../DataNodeLocationSupplierFactory.java | 12 +-
.../PushLimitOffsetIntoTableScan.java | 5 +-
.../optimizations/PushPredicateIntoTableScan.java | 42 +-
.../TransformAggregationToStreamable.java | 4 +-
.../optimizations/TransformSortToStreamSort.java | 5 +-
.../relational/planner/optimizations/Util.java | 2 -
.../plan/relational/security/AccessControl.java | 2 +-
.../sql/ast/AbstractQueryDeviceWithCache.java | 2 +-
.../relational/sql/ast/AbstractTraverseDevice.java | 1 +
.../plan/relational/sql/ast/ColumnDefinition.java | 2 +-
.../queryengine/plan/relational/sql/ast/Flush.java | 4 +-
.../plan/relational/sql/ast/InsertRows.java | 3 +-
.../relational/sql/ast/WrappedInsertStatement.java | 26 +-
.../plan/relational/sql/parser/AstBuilder.java | 71 +-
.../plan/relational/sql/rewrite/ShowRewrite.java | 4 +-
.../scheduler/load/LoadTsFileDispatcherImpl.java | 2 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 134 +-
.../db/queryengine/plan/statement/Statement.java | 8 +-
.../plan/statement/crud/InsertBaseStatement.java | 15 +-
.../plan/statement/crud/InsertRowStatement.java | 4 +-
.../plan/statement/crud/InsertTabletStatement.java | 5 +-
.../statement/metadata/ShowDatabaseStatement.java | 12 +-
.../plan/statement/sys/FlushStatement.java | 33 +-
.../unary/scalar/FormatColumnTransformer.java | 119 +
.../apache/iotdb/db/schemaengine/SchemaEngine.java | 60 +-
.../schemaregion/ISchemaRegionParams.java | 3 +-
.../schemaregion/SchemaRegionParams.java | 11 +-
.../GeneralRegionAttributeSecurityService.java | 6 +-
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 13 +-
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 6 +-
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 2 +-
.../schemaengine/schemaregion/utils/MetaUtils.java | 9 +-
.../db/schemaengine/table/DataNodeTableCache.java | 55 +-
.../schemaengine/table/InformationSchemaUtils.java | 186 ++
.../java/org/apache/iotdb/db/service/DataNode.java | 91 +-
.../iotdb/db/service/metrics/FileMetrics.java | 5 +
.../db/service/metrics/file/TsFileMetrics.java | 67 +-
.../iotdb/db/storageengine/StorageEngine.java | 42 +-
.../db/storageengine/buffer/BloomFilterCache.java | 28 +-
.../iotdb/db/storageengine/buffer/ChunkCache.java | 27 +-
.../buffer/TimeSeriesMetadataCache.java | 56 +-
.../db/storageengine/dataregion/DataRegion.java | 43 +-
.../performer/impl/FastCompactionPerformer.java | 15 +
.../execute/task/InnerSpaceCompactionTask.java | 9 +-
.../execute/utils/CompactionTableSchema.java | 4 +-
.../execute/utils/MultiTsFileDeviceIterator.java | 7 +-
.../compaction/io/CompactionTsFileReader.java | 14 +-
.../compaction/io/CompactionTsFileWriter.java | 2 +-
.../compaction/repair/RepairDataFileScanUtil.java | 2 +-
.../compaction/schedule/CompactionTaskManager.java | 15 +-
.../compaction/schedule/CompactionWorker.java | 7 +-
.../DefaultCompactionTaskComparatorImpl.java | 16 +-
.../impl/NewSizeTieredCompactionSelector.java | 2 +-
.../dataregion/memtable/AbstractMemTable.java | 8 +-
.../memtable/AlignedWritableMemChunk.java | 6 +-
.../memtable/AlignedWritableMemChunkGroup.java | 5 +
.../memtable/IWritableMemChunkGroup.java | 2 +
.../dataregion/memtable/TsFileProcessor.java | 17 +-
.../dataregion/memtable/WritableMemChunkGroup.java | 5 +
.../dataregion/read/QueryDataSource.java | 14 +-
.../reader/common/CachedPriorityMergeReader.java | 97 -
.../reader/common/DescPriorityMergeReader.java | 16 +-
.../read/reader/common/PriorityMergeReader.java | 22 +-
.../dataregion/tsfile/TsFileResource.java | 14 +-
.../tsfile/timeindex/ArrayDeviceTimeIndex.java | 2 +-
.../dataregion/tsfile/timeindex/FileTimeIndex.java | 2 +-
.../dataregion/tsfile/timeindex/ITimeIndex.java | 2 +-
.../wal/allocation/FirstCreateStrategy.java | 1 +
.../storageengine/dataregion/wal/node/WALNode.java | 8 +-
.../db/storageengine/load/LoadTsFileManager.java | 63 +-
.../memory/LoadTsFileAnalyzeSchemaMemoryBlock.java | 4 +-
.../memory/LoadTsFileDataCacheMemoryBlock.java | 43 +-
.../load/memory/LoadTsFileMemoryManager.java | 17 +-
.../load/splitter/TsFileSplitter.java | 35 +-
.../db/subscription/broker/SubscriptionBroker.java | 104 +-
.../broker/SubscriptionPrefetchingQueue.java | 7 +-
.../db/subscription/broker/SubscriptionStates.java | 30 +-
.../event/SubscriptionCommitContextSupplier.java} | 11 +-
.../db/subscription/event/SubscriptionEvent.java | 14 +-
.../batch/SubscriptionPipeTabletEventBatch.java | 57 +-
.../SubscriptionEventExtendableResponse.java | 6 -
.../event/response/SubscriptionEventResponse.java | 7 +
.../response/SubscriptionEventTabletResponse.java | 60 +-
.../response/SubscriptionEventTsFileResponse.java | 2 +-
.../receiver/SubscriptionReceiverV1.java | 2 +-
.../db/tools/schema/SRStatementGenerator.java | 3 +-
.../org/apache/iotdb/db/utils/CommonUtils.java | 88 +-
.../org/apache/iotdb/db/utils/DateTimeUtils.java | 5 +
.../java/org/apache/iotdb/db/utils/MemUtils.java | 2 +-
.../db/utils/datastructure/AlignedTVList.java | 29 +-
.../apache/iotdb/db/metadata/MetaUtilsTest.java | 9 +-
.../iotdb/db/metadata/path/PatternTreeMapTest.java | 41 +-
.../schemaRegion/AbstractSchemaRegionTest.java | 4 +-
.../SchemaRegionSimpleRecoverTest.java | 9 +-
.../schemaRegion/SchemaRegionTableDeviceTest.java | 10 +-
.../schemaRegion/SchemaRegionTestUtil.java | 3 +-
.../schemaRegion/SchemaStatisticsTest.java | 2 +-
.../operator/MergeTreeSortOperatorTest.java | 4 +-
.../plan/analyze/FakePartitionFetcherImpl.java | 5 -
.../plan/analyze/cache/PartitionCacheTest.java | 8 +-
.../plan/parser/StatementGeneratorTest.java | 11 +-
.../plan/planner/distribution/Util.java | 5 -
.../plan/planner/distribution/Util2.java | 5 -
.../node/write/InsertRowsNodeSerdeTest.java | 22 +-
.../node/write/InsertTabletNodeSerdeTest.java | 16 +-
.../planner/node/write/WritePlanNodeSplitTest.java | 2 +-
.../plan/relational/analyzer/AnalyzerTest.java | 55 +-
.../analyzer/MockTableModelDataPartition.java | 17 +-
.../plan/relational/analyzer/ShowQueriesTest.java | 20 +-
.../plan/relational/analyzer/TSBSMetadata.java | 49 +-
.../plan/relational/analyzer/TestMatadata.java | 92 +-
.../fetcher/cache/TableDeviceSchemaCacheTest.java | 32 +-
.../planner/assertions/PlanMatchPattern.java | 12 +
.../plan/relational/sql/ast/InsertTabletTest.java | 4 +-
.../plan/statement/InsertStatementTest.java | 50 +-
.../plan/statement/StatementTestUtils.java | 14 +-
.../DataNodeInternalRPCServiceImplTest.java | 3 +-
.../iotdb/db/storageengine/StorageEngineTest.java | 2 +
.../storageengine/buffer/BloomFilterCacheTest.java | 29 +-
.../BatchedCompactionWithTsFileSplitterTest.java | 15 +-
.../compaction/CompactionTaskComparatorTest.java | 2 +-
.../compaction/CompactionWorkerTest.java | 33 +
.../inner/InnerSequenceCompactionSpeedTest.java | 43 +
.../NewSizeTieredCompactionSelectorTest.java | 30 +
.../repair/RepairUnsortedFileCompactionTest.java | 53 +
.../CompactionTableModelTestFileWriter.java | 2 +-
.../CompactionTableSchemaCollectorTest.java | 44 +-
.../TableModelCompactionWithTTLTest.java | 9 +-
.../compaction/utils/CompactionCheckerUtils.java | 30 +-
...SeriesReader.java => AscFakedSeriesReader.java} | 28 +-
.../read/reader/common/DescFakedSeriesReader.java | 54 +
.../reader/common/PriorityMergeReaderTest.java | 113 +-
.../reader/common/PriorityMergeReaderTest2.java | 59 -
.../dataregion/wal/io/WALFileTest.java | 2 +-
.../file/UnsealedTsFileRecoverPerformerTest.java | 4 +-
.../org/apache/iotdb/db/tools/MLogParserTest.java | 5 +-
.../db/utils/SchemaRegionSnapshotParserTest.java | 89 +-
.../reporter/prometheus/PrometheusReporter.java | 5 +-
iotdb-core/node-commons/pom.xml | 4 +-
.../conf/iotdb-system.properties.template | 7 +-
.../commons/binaryallocator/BinaryAllocator.java | 18 +-
.../iotdb/commons/binaryallocator/arena/Arena.java | 39 +-
.../metric/BinaryAllocatorMetrics.java | 36 +-
.../apache/iotdb/commons/client/ThriftClient.java | 17 +-
.../commons/client/sync/ByteBuddyEnhancer.java | 75 -
.../sync/SyncThriftClientWithErrorHandler.java | 30 +-
.../commons/concurrent/ThreadPoolMetrics.java | 26 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 9 +
.../iotdb/commons/conf/CommonDescriptor.java | 5 +
.../iotdb/commons/conf/ConfigurationFileUtils.java | 32 +-
.../commons/exception/IllegalPathException.java | 4 +-
.../iotdb/commons/partition/DataPartition.java | 55 +-
.../iotdb/commons/partition/SchemaPartition.java | 10 +-
.../org/apache/iotdb/commons/path/PartialPath.java | 11 +-
.../apache/iotdb/commons/path/PathPatternNode.java | 105 +-
.../apache/iotdb/commons/path/PathPatternUtil.java | 9 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 5 +
.../config/constant/PipeExtractorConstant.java | 4 +
.../config/constant/PipeRPCMessageConstant.java} | 19 +-
.../pipe/datastructure/pattern/TablePattern.java | 16 +-
.../resource/ref/PipePhantomReferenceManager.java | 2 +-
.../schema/column/ColumnHeaderConstant.java | 23 +-
.../commons/schema/table/InformationSchema.java | 126 +
.../schema/table/InformationSchemaTable.java | 96 -
.../apache/iotdb/commons/schema/table/TsTable.java | 23 +-
...entColumnSchema.java => FieldColumnSchema.java} | 60 +-
.../{IdColumnSchema.java => TagColumnSchema.java} | 17 +-
.../schema/table/column/TsTableColumnCategory.java | 24 +-
.../table/column/TsTableColumnSchemaUtil.java | 16 +-
.../iotdb/commons/udf/access/RecordIterator.java | 10 +-
.../TableBuiltinAggregationFunction.java | 4 +-
.../relational/TableBuiltinScalarFunction.java | 1 +
.../iotdb/commons/udf/utils/TableUDFUtils.java | 6 +-
.../commons/udf/utils/UDFDataTypeTransformer.java | 45 +-
.../org/apache/iotdb/commons/utils/PathUtils.java | 8 +-
.../db/relational/grammar/sql/RelationalSql.g4 | 16 +-
iotdb-protocol/openapi/pom.xml | 27 +
.../src/main/openapi3/iotdb_rest_table_v1.yaml | 167 ++
.../src/main/thrift/confignode.thrift | 7 +-
.../iotdb/library/dprofile/UDAFIntegral.java | 41 +-
.../iotdb/library/drepair/UDTFTimestampRepair.java | 47 +-
.../library/drepair/util/TimestampInterval.java | 22 +-
.../library/drepair/util/TimestampRepair.java | 2 +-
pom.xml | 20 +-
530 files changed, 15042 insertions(+), 8097 deletions(-)
create mode 100644
example/rest-java-example/src/main/java/org/apache/iotdb/TableHttpExample.java
create mode 100644
example/rest-java-example/src/main/java/org/apache/iotdb/TableHttpsExample.java
create mode 100644
example/udf/src/main/java/org/apache/iotdb/udf/AggregateFunctionExample.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/FirstTwoSum.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/MyAvg.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/MyCount.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBFileTimeIndexIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/schema/IoTDBCreateDatabaseIT.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/schema/IoTDBCreateStorageGroupIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/tablemodel/IoTDBPipeTypeConversionISessionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/tablemodel/IoTDBPipeTypeConversionIT.java
rename
integration-test/src/test/java/org/apache/iotdb/relational/it/db/it/{IoTDBMultiIDsWithAttributesTableIT.java
=> IoTDBMultiTAGsWithAttributesTableIT.java} (97%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/db/it/udf/IoTDBUserDefinedAggregateFunctionIT.java
rename
integration-test/src/test/java/org/apache/iotdb/relational/it/db/it/udf/{scalar/IoTDBScalarFunctionIT.java
=> IoTDBUserDefinedScalarFunctionIT.java} (95%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/db/it/udf/SQLFunctionUtils.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/old/builtinfunction/scalar/IoTDBFormatFunctionTableIT.java
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/{db/it/IoTDBCaseWhenThenTableIT.java
=> rest/it/IoTDBRestServiceCaseWhenThenIT.java} (50%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/rest/it/IoTDBRestServiceFlushQueryIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/rest/it/IoTDBRestServiceIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/rest/it/IoTDBRestServiceInsertAlignedValuesIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/rest/it/RestUtils.java
rename integration-test/src/test/java/org/apache/iotdb/{session/it =>
relational/it/session}/IoTDBSessionRelationalIT.java (60%)
create mode 100644
iotdb-api/udf-api/src/main/java/org/apache/iotdb/udf/api/customizer/config/AggregateFunctionConfig.java
copy iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/{ =>
load}/LoadEmptyFileException.java (95%)
copy iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/{ =>
load}/LoadFileException.java (96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/{ =>
load}/LoadReadOnlyException.java (96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/{ =>
load}/LoadRuntimeOutOfMemoryException.java (95%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/{ =>
load}/PartitionViolationException.java (96%)
copy
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/exception/IllegalPathException.java
=>
datanode/src/main/java/org/apache/iotdb/db/exception/load/RegionReplicaSetChangedException.java}
(58%)
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/metadata/DatabaseModelException.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/thrift/async/handler/PipeTransferTrackableHandler.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest/table/v1/handler/ExceptionHandler.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest/table/v1/handler/ExecuteStatementHandler.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest/table/v1/handler/QueryDataSetHandler.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest/table/v1/handler/RequestValidationHandler.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest/table/v1/handler/StatementConstructionHandler.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest/table/v1/impl/RestApiServiceImpl.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/UserDefinedAggregateFunctionAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/GroupedUserDefinedAggregateAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/FormatColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/table/InformationSchemaUtils.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/common/CachedPriorityMergeReader.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{exception/LoadEmptyFileException.java
=> subscription/event/SubscriptionCommitContextSupplier.java} (77%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/common/{FakedSeriesReader.java
=> AscFakedSeriesReader.java} (79%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/common/DescFakedSeriesReader.java
delete mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/common/PriorityMergeReaderTest2.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/sync/ByteBuddyEnhancer.java
rename
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/exception/LoadFileException.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/config/constant/PipeRPCMessageConstant.java}
(65%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/table/InformationSchema.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/table/InformationSchemaTable.java
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/table/column/{MeasurementColumnSchema.java
=> FieldColumnSchema.java} (55%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/table/column/{IdColumnSchema.java
=> TagColumnSchema.java} (75%)
create mode 100644
iotdb-protocol/openapi/src/main/openapi3/iotdb_rest_table_v1.yaml
