This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch share_mod_file
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 85152702457 Merge branch 'master' into share_mod_file
add 95d06f6de16 Fix AsyncClientManager selector thread leak #14203
add 098306cbb9c Optimize the implantation of EXPLAIN ANALYZE
add bf2c5b134f6 Fix upper-case database name in TableSession error
add bb99334754f Pipe: implement RenameDatabaseProcessor &
WriteBackConnector for table model events (#14131)
add 0160b65d67b Pipe: make exception message more friendly when creating
data sync pipe failed (#14208)
add d9552365dc2 Set fetchSize to max_tsblock_line_number if it's equal to
or less than zero
add 8a6405cdfa7 [remove datanode] Do not allow regions to inherit the
Removing state from datanode (#14185)
add 77a21a71e7f Fixed the bugs of the table cache
add b072f9e861c Fix throw exception when compare with null
add d751364acb3 Refactor UDF management process to support table model
user-defined function
add 8618464d861 Fix table model insert without measurement error (#14222)
add 5b7f1c66260 Fix flaky LastFlushTimeMapTest (#14225)
add 864b94edf76 Add extra info for TableScanOperator and
AggTableScanOperator in Explain Analyze
add add7f323f4b Fix query failure if a table deletion involves deviceId
with null & Fix status code when deleting illegal time range & support is null
in deletion (#14217)
add f367c729a1b Register TableSchema to TsfileWriter when recover from wal
(#14228)
add 93438081109 Add extra info for HashAggregationOperator and
StreamingHashAggregationOperator in Explain Analyze
add 2b548342ea2 Fixed the bug that the exception may print stack when
dropping id or time column
add f15c30b97fa Fix issue that data is incomplete in full join of table
model and add new ExchangeNode for table model
add 0d8a0d101bf IoTConsensusV2: Fix syncLag error when using steam mode
and 2+ replicas (#14219)
add 0bb51c67c71 IoTConsensusV2: Fix reqBuffer reset and receive concurrent
bug (#14215)
add 4fddd584b20 [IoTConsensusV2 X Pipe Deletion]: Release deletion
resource when delete region & Improve for release when buffer is null (#14227)
add b34b714c80e [IoTConsensusV2 X Region Migration] Start consensus pipe
in proper time rather than automatically start it when create it
add 7806f84debe Pipe: Allow STATEMENT_STATUS_VISITOR and
STATEMENT_EXCEPTION_VISITOR for data conversion statements on data sync
receiver side (#14220)
add aaa9a9b86e3 Fixed the bug that a pre-updated table may face multiple
updates and generate NPE
add 8c6bd8e6c15 Fix that queries may retrieve false positive deletion
add 196795d61f7 Fix async recover TsfileResource error handle
add 355abf59902 Refactor TableSession and TableSessionPool of Python
client (#14232)
add 87dc2ca7245 Tsfile java interfaces & Subscription: The usage of bitmap
in SubscriptionSessionDataSet may cause npe (#14124)
add 6eb576cc9fb Pipe IT: Modify the forwarding-pipe-requests configuration
of Double Living IT (#14240)
add 642cf54930b Fix that table deletion will be mistakenly merged together
add 05bc4fd7f1d Some files were not added to TsFileResourceManager
add c5eacf01e8f Fix error in single device with sort + offset + limit
align by device query
add 041d292b092 [remove datanode] Do not disable the entire region group
for one removing region (#14241)
add 45d189e1317 Disabled some unsupportted operations
add 1e93245b822 Diasble delete-from sql
add 2f51c3b205d Add table series number in schema quota
add 7af7c80c551 Implement schema quota check at schemaRegion for table
device
add db715b76b1e Combine CSV SQL TSfile data import/export script (#13930)
(#14191)
add 9cffb76310d Fix the deserialization of table deletion in WAL
add eece66eec7d Fixed the bug that drop table won't release device num in
quota & table requests may block forever after ConfigNode restart
add 496c62e1819 Enhance procedure recover policy
add 73476e00a9a Fix back-quote remove of Select-Into query when query is
not for raw data
add d101d76879c [remove datanode] Not re-submit region migration procedure
when leader change or reboot #14277
add ba2646059ea Pipe: Introduce restart strategy to control resources'
memory only used by pipe hardlinked files (#14279)
add 72e69aee1f9 [Refactor] Reduce redundancy by introducing consistent
functional interface in SessionConnection (#14212)
add 2bad1f7477f Pipe: Enhanced the pipe transferred create timeseries
logic to allow merging tags / attributes (#14261)
add 6e9aa8ee50d Pipe: Fix a tree model pipe becomes table model pipe
exceptionally due to alter pipe operations (#14242)
add 2aa7af9599a Common Config & Pipe IT: Fixed the bug that
dn-connection-timeout and cn-connection-timeout are mixed (#14275)
add 925f7cc8749 Optimize table cache leader implement 2 (#14278)
add 3e8a201b319 [Vulnerability-check] Add weekly vulnerability-check #14288
add d3483237f75 Add avg file size in DefaultCompactionTaskComparatorImpl
(#14270)
add a7fbca63206 [Py-client] Support insert_records with None values
(#14272)
add af2cedf2562 Merge branch 'master' into share_mod_file
No new revisions were added by this update.
Summary of changes:
.github/workflows/pipe-it-2cluster.yml | 18 +
.github/workflows/vulnerability-check.yml | 49 +
.../java/org/apache/iotdb/CountPointProcessor.java | 3 +-
.../iotdb/AlignedTimeseriesSessionExample.java | 59 +-
.../org/apache/iotdb/DataMigrationExample.java | 26 +-
.../iotdb/HybridTimeseriesSessionExample.java | 10 +-
.../org/apache/iotdb/SessionConcurrentExample.java | 16 +-
.../main/java/org/apache/iotdb/SessionExample.java | 62 +-
.../org/apache/iotdb/TableModelSessionExample.java | 28 +-
.../apache/iotdb/TableModelSessionPoolExample.java | 30 +-
.../main/java/org/apache/iotdb/TabletExample.java | 3 +-
.../iotdb/trigger/StatisticsUpdaterTrigger.java | 6 +-
.../trigger/example/TriggerFireTimesCounter.java | 2 +-
.../it/env/cluster/config/MppCommonConfig.java | 4 +-
.../env/cluster/config/MppSharedCommonConfig.java | 6 +-
.../it/env/remote/config/RemoteCommonConfig.java | 2 +-
.../org/apache/iotdb/it/utils/TsFileGenerator.java | 28 +-
.../org/apache/iotdb/itbase/env/CommonConfig.java | 2 +-
.../confignode/it/IoTDBConfigNodeSnapshotIT.java | 14 +-
.../it/partition/IoTDBPartitionCreationIT.java | 59 +-
.../it/partition/IoTDBPartitionDurableIT.java | 130 ---
.../org/apache/iotdb/db/it/IoTDBLoadTsFileIT.java | 24 +-
.../iotdb/db/it/IoTDBPartialInsertionIT.java | 8 +-
.../org/apache/iotdb/db/it/IoTDBRestServiceIT.java | 8 +-
.../it/IoTDBSyntaxConventionStringLiteralIT.java | 2 +-
.../IoTDBOrderByLimitOffsetAlignByDeviceIT.java | 23 +-
.../iotdb/db/it/selectinto/IoTDBSelectIntoIT.java | 49 +
.../iotdb/db/it/udaf/IoTDBUDAFManagementIT.java | 12 +-
.../iotdb/db/it/udf/IoTDBUDFManagementIT.java | 17 +-
.../pipe/it/autocreate/AbstractPipeDualAutoIT.java | 4 +-
.../iotdb/pipe/it/autocreate/IoTDBPipeAlterIT.java | 5 +-
.../it/autocreate/IoTDBPipeAutoConflictIT.java | 55 +-
.../pipe/it/autocreate/IoTDBPipeClusterIT.java | 4 +-
.../IoTDBPipeConnectorCompressionIT.java | 4 +-
.../pipe/it/autocreate/IoTDBPipeExtractorIT.java | 4 +-
.../pipe/it/autocreate/IoTDBPipeIdempotentIT.java | 4 +-
.../pipe/it/autocreate/IoTDBPipeLifeCycleIT.java | 6 +-
.../pipe/it/autocreate/IoTDBPipeNullValueIT.java | 4 +-
.../pipe/it/autocreate/IoTDBPipeProcessorIT.java | 4 +-
.../pipe/it/autocreate/IoTDBPipeProtocolIT.java | 12 +-
.../pipe/it/autocreate/IoTDBPipeWithLoadIT.java | 4 +-
.../pipe/it/manual/AbstractPipeDualManualIT.java | 4 +-
.../pipe/it/manual/IoTDBPipeMetaHistoricalIT.java | 4 +-
.../it/manual/IoTDBPipeMetaLeaderChangeIT.java | 4 +-
.../pipe/it/manual/IoTDBPipePermissionIT.java | 4 +-
.../pipe/it/manual/IoTDBPipeReqAutoSliceIT.java | 22 +-
.../manual/IoTDBPipeTypeConversionISessionIT.java | 39 +-
.../iotdb/pipe/it/single/AbstractPipeSingleIT.java | 2 +-
.../tablemodel/AbstractPipeTableModelTestIT.java | 4 +-
.../iotdb/pipe/it/tablemodel/IoTDBPipeAlterIT.java | 2 +
.../it/tablemodel/IoTDBPipeAutoConflictIT.java | 4 +-
.../pipe/it/tablemodel/IoTDBPipeClusterIT.java | 4 +-
.../IoTDBPipeConnectorCompressionIT.java | 4 +-
.../pipe/it/tablemodel/IoTDBPipeDataSinkIT.java | 59 ++
.../pipe/it/tablemodel/IoTDBPipeExtractorIT.java | 4 +-
.../pipe/it/tablemodel/IoTDBPipeLifeCycleIT.java | 6 +-
.../pipe/it/tablemodel/IoTDBPipeProtocolIT.java | 12 +-
.../pipe/it/tablemodel/IoTDBPipeWithLoadIT.java | 4 +-
.../iotdb/pipe/it/tablemodel/TableModelUtils.java | 32 +-
.../relational/it/db/it/IoTDBDeletionTableIT.java | 145 +++
.../it/db/it/IoTDBDisableDeletionTableIT.java | 120 +++
.../relational/it/db/it/IoTDBInsertTableIT.java | 178 ++--
.../db/it/IoTDBMultiIDsWithAttributesTableIT.java | 99 +-
.../it/query/old/IoTDBFilterTableIT.java | 24 +
.../it/query/old/orderBy/IoTDBOrderByTableIT.java | 48 +-
.../iotdb/relational/it/schema/IoTDBDeviceIT.java | 23 +-
.../iotdb/relational/it/schema/IoTDBTableIT.java | 123 +--
.../it/session/IoTDBTableModelSessionIT.java | 39 +
.../pool/IoTDBInsertTableSessionPoolIT.java | 69 +-
.../session/it/IoTDBSessionAlignedInsertIT.java | 10 +-
.../iotdb/session/it/IoTDBSessionComplexIT.java | 24 +-
.../it/IoTDBSessionDisableMemControlIT.java | 12 +-
.../IoTDBSessionInsertWithTriggerExecutionIT.java | 6 +-
.../iotdb/session/it/IoTDBSessionRelationalIT.java | 213 ++--
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 126 +--
.../session/it/IoTDBSessionSyntaxConventionIT.java | 4 +-
.../org/apache/iotdb/session/it/SessionIT.java | 21 +-
.../it/dual/AbstractSubscriptionDualIT.java | 4 +-
.../it/local/IoTDBSubscriptionBasicIT.java | 2 +-
.../it/triple/AbstractSubscriptionTripleIT.java | 6 +-
.../it/triple/IoTDBSubscriptionSharingIT.java | 6 +-
.../IoTDBDefaultPullConsumerDataSetIT.java | 2 +-
.../IoTDBDefaultTsfilePushConsumerIT.java | 2 +-
.../IoTDBRootDatasetPushConsumerIT.java | 2 +-
.../IoTDBRootPullConsumeTsfileIT.java | 2 +-
...merPullConsumerWith1TopicShareProcessMixIT.java | 2 +-
.../param/IoTDBTestParamPullConsumerIT.java | 2 +-
.../param/IoTDBTestParamPushConsumerIT.java | 2 +-
...DBTestAutoCommitFalseDataSetPullConsumerIT.java | 4 +-
...TDBTestAutoCommitTrueDataSetPullConsumerIT.java | 4 +-
.../format/IoTDBDBDataSetPullConsumerIT.java | 2 +-
.../format/IoTDBDBTsfilePullConsumerIT.java | 2 +-
.../IoTDBAllTsDatasetPullConsumerIT.java | 2 +-
.../IoTDBAllTsTsfilePullConsumerIT.java | 2 +-
.../IoTDBAllTsfilePullConsumerSnapshotIT.java | 2 +-
.../IoTDBPathDeviceDataSetPullConsumerIT.java | 2 +-
.../IoTDBPathDeviceTsfilePullConsumerIT.java | 2 +-
.../IoTDBTimeTsDatasetPullConsumerIT.java | 2 +-
.../IoTDBTimeTsTsfilePullConsumerIT.java | 2 +-
.../IoTDBSnapshotDevicePullConsumerDataSetIT.java | 2 +-
.../IoTDBSnapshotDevicePullConsumerTsfileIT.java | 2 +-
...DBConsumer2With1TopicShareProcessDataSetIT.java | 2 +-
...TDBConsumer2With1TopicShareProcessTsfileIT.java | 2 +-
.../multi/IoTDBMultiGroupVsMultiConsumerIT.java | 4 +-
.../IoTDBOneConsumerMultiTopicsDatasetIT.java | 2 +-
.../multi/IoTDBOneConsumerMultiTopicsMixIT.java | 5 +-
.../multi/IoTDBOneConsumerMultiTopicsTsfileIT.java | 2 +-
.../pattern/IoTDBDBPatternPullConsumeTsfileIT.java | 2 +-
.../IoTDBDBPatternPullConsumerDataSetIT.java | 2 +-
.../IoTDBDefaultPatternPullConsumerDataSetIT.java | 2 +-
.../IoTDBDevicePatternPullConsumeTsfileIT.java | 2 +-
.../IoTDBDevicePatternPullConsumerDataSetIT.java | 2 +-
...DBMiddleMatch2PatternPullConsumerDataSetIT.java | 2 +-
...IoTDBMiddleMatchPatternPullConsumeTsfileIT.java | 2 +-
...TDBMiddleMatchPatternPullConsumerDataSetIT.java | 2 +-
.../IoTDBRootPatternPullConsumeTsfileIT.java | 2 +-
.../pattern/IoTDBTSPatternPullConsumeTsfileIT.java | 2 +-
.../IoTDBTSPatternPullConsumerDataSetIT.java | 2 +-
.../time/IoTDBAllPullConsumerDataSetIT.java | 2 +-
.../time/IoTDBHistoryPullConsumerDataSetIT.java | 2 +-
.../time/IoTDBRealTimePullConsumerDataSetIT.java | 2 +-
...oTDBTimeRangeAccuratePullConsumerDataSetIT.java | 2 +-
.../time/IoTDBTimeRangePullConsumerDataSetIT.java | 2 +-
.../format/IoTDBTestPushConsumeDataSetIT.java | 2 +-
.../IoTDBTestPushConsumeNoTargetDirTsfileIT.java | 2 +-
.../format/IoTDBTestPushConsumeTsfileIT.java | 2 +-
.../IoTDBLooseAllTsDatasetPushConsumerIT.java | 2 +-
...TDBLooseAllTsDatasetPushConsumerSnapshotIT.java | 2 +-
.../IoTDBLooseAllTsfilePushConsumerIT.java | 2 +-
.../IoTDBPathLooseDeviceTsfilePushConsumerIT.java | 2 +-
.../IoTDBPathLooseTsDatasetPushConsumerIT.java | 2 +-
.../IoTDBPathLooseTsfilePushConsumerIT.java | 2 +-
.../IoTDBPathTsLooseDatasetPushConsumerIT.java | 2 +-
.../IoTDBTimeLooseTsDatasetPushConsumerIT.java | 2 +-
.../IoTDBTimeLooseTsTsfilePushConsumerIT.java | 2 +-
.../IoTDBTimeLooseTsfilePushConsumerIT.java | 2 +-
.../IoTDBTimeTsLooseDatasetPushConsumerIT.java | 2 +-
...oTDBSnapshotTSPatternDatasetPushConsumerIT.java | 2 +-
...IoTDBSnapshotTSPatternTsfilePushConsumerIT.java | 2 +-
...DBConsumer2With1TopicShareProcessDataSetIT.java | 2 +-
...TDBConsumer2With1TopicShareProcessTsfileIT.java | 2 +-
.../multi/IoTDBMultiGroupVsMultiConsumerIT.java | 6 +-
.../IoTDBOneConsumerMultiTopicsDatasetIT.java | 2 +-
.../multi/IoTDBOneConsumerMultiTopicsMixIT.java | 2 +-
.../multi/IoTDBOneConsumerMultiTopicsTsfileIT.java | 2 +-
.../IoTDBDBPatternDatasetPushConsumerIT.java | 2 +-
.../IoTDBDBPatternTsfilePushConsumerIT.java | 2 +-
.../IoTDBDefaultPatternTsfilePushConsumerIT.java | 2 +-
.../IoTDBDevicePatternDatasetPushConsumerIT.java | 2 +-
.../IoTDBDevicePatternTsfilePushConsumerIT.java | 2 +-
.../IoTDBRootPatternDatasetPushConsumerIT.java | 2 +-
.../IoTDBTSPatternDatasetPushConsumerIT.java | 2 +-
.../IoTDBTSPatternTsfilePushConsumerIT.java | 2 +-
.../IoTDBHistoryRootDatasetPushConsumerIT.java | 2 +-
.../time/IoTDBHistoryRootTsFilePushConsumerIT.java | 2 +-
.../time/IoTDBRealTimeDBDatasetPushConsumerIT.java | 2 +-
.../time/IoTDBRealTimeDBTsfilePushConsumerIT.java | 2 +-
...DBTimeRangeAccurateDBDataSetPushConsumerIT.java | 2 +-
.../IoTDBTimeRangeDBDataSetPushConsumerIT.java | 2 +-
.../time/IoTDBTimeRangeDBTsfilePushConsumerIT.java | 2 +-
.../topic/IoTDBDataSet1TopicConsumerSpecialIT.java | 2 +-
.../regression/topic/IoTDBTestTopicNameIT.java | 2 +-
.../regression/user/IoTDBOtherUserConsumerIT.java | 2 +-
.../apache/iotdb/tools/it/ExportDataTestIT.java | 12 +-
.../apache/iotdb/tools/it/ImportDataTestIT.java | 16 +-
.../udf/api/relational/AggregationFunction.java | 12 +-
.../iotdb/udf/api/relational/SQLFunction.java | 12 +-
.../iotdb/udf/api/relational/ScalarFunction.java | 12 +-
.../iotdb/udf/api/relational/TableFunction.java | 12 +-
.../iotdb/udf/api/relational/access/Record.java | 129 +++
.../src/assembly/resources/tools/export-data.bat | 6 +-
.../src/assembly/resources/tools/export-data.sh | 6 +-
.../src/assembly/resources/tools/import-data.bat | 6 +-
.../src/assembly/resources/tools/import-data.sh | 6 +-
.../apache/iotdb/tool/data/AbstractDataTool.java | 1106 +++++++++++++++++++-
.../apache/iotdb/tool/data/AsyncImportData.java | 160 +++
.../org/apache/iotdb/tool/data/ExportData.java | 397 +++++--
.../org/apache/iotdb/tool/data/ImportData.java | 1091 +++++++------------
.../apache/iotdb/tool/data/ImportDataScanTool.java | 63 ++
.../iotdb/tool/tsfile/AbstractTsFileTool.java | 3 +-
.../org/apache/iotdb/tool/tsfile/ExportTsFile.java | 124 ++-
.../org/apache/iotdb/tool/tsfile/ImportTsFile.java | 68 +-
.../apache/iotdb/tool/tsfile/ImportTsFileBase.java | 10 +-
.../iotdb/tool/tsfile/ImportTsFileRemotely.java | 11 +-
iotdb-client/client-py/iotdb/Session.py | 158 ++-
iotdb-client/client-py/iotdb/SessionPool.py | 20 +-
iotdb-client/client-py/iotdb/table_session.py | 147 +++
iotdb-client/client-py/iotdb/table_session_pool.py | 116 ++
...le.py => session_aligned_timeseries_example.py} | 0
.../{SessionExample.py => session_example.py} | 0
...ssionPoolExample.py => session_pool_example.py} | 0
...onExample.py => table_model_session_example.py} | 48 +-
...mple.py => table_model_session_pool_example.py} | 45 +-
.../tests => tests/integration/dbapi}/__init__.py | 0
.../integration/dbapi}/test_connection.py | 2 +-
.../integration/dbapi}/test_cursor.py | 2 +-
.../integration/iotdb_container.py} | 0
.../integration/sqlalchemy}/__init__.py | 0
.../integration/sqlalchemy}/test_dialect.py | 2 +-
.../tests/integration/test_aligned_timeseries.py | 2 +-
.../client-py/tests/integration/test_dataframe.py | 2 +-
.../tests/integration/test_delete_data.py | 2 +-
.../tests/integration/test_new_data_types.py | 2 +-
.../client-py/tests/integration/test_one_device.py | 2 +-
.../tests/integration/test_relational_session.py | 37 +-
.../client-py/tests/integration/test_session.py | 102 +-
.../tests/integration/test_session_pool.py | 2 +-
.../tests/integration/test_tablemodel_insert.py | 37 +-
.../client-py/tests/integration/test_tablet.py | 2 +-
.../client-py/tests/integration/test_todf.py | 2 +-
.../tests/integration/test_treemodel_insert.py | 3 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 2 +
.../java/org/apache/iotdb/session/Session.java | 46 +-
.../apache/iotdb/session/SessionConnection.java | 374 ++-----
.../payload/SubscriptionSessionDataSet.java | 6 +-
.../apache/iotdb/session/util/CheckedSupplier.java | 28 +-
.../apache/iotdb/session/util/SessionUtils.java | 42 +-
.../iotdb/session/SessionCacheLeaderTest.java | 190 ++--
.../java/org/apache/iotdb/session/SessionTest.java | 96 +-
.../java/org/apache/iotdb/session/TabletTest.java | 2 +-
.../session/pool/SessionPoolExceptionTest.java | 24 +-
.../apache/iotdb/session/pool/SessionPoolTest.java | 72 +-
.../iotdb/session/util/SessionUtilsTest.java | 114 +-
.../heartbeat/DataNodeHeartbeatHandler.java | 14 +-
.../consensus/request/ConfigPhysicalPlan.java | 10 +-
.../consensus/request/ConfigPhysicalPlanType.java | 5 +-
...TablePlan.java => GetAllFunctionTablePlan.java} | 6 +-
.../read/function/GetFunctionTablePlan.java | 10 +-
...onPlan.java => DropTableModelFunctionPlan.java} | 12 +-
...ionPlan.java => DropTreeModelFunctionPlan.java} | 12 +-
...opFunctionPlan.java => UpdateFunctionPlan.java} | 44 +-
.../response/function/FunctionTableResp.java | 14 +-
.../iotdb/confignode/manager/ConfigManager.java | 12 +-
.../apache/iotdb/confignode/manager/IManager.java | 6 +-
.../iotdb/confignode/manager/ProcedureManager.java | 4 +-
.../iotdb/confignode/manager/UDFManager.java | 95 +-
.../manager/consensus/ConsensusManager.java | 6 +-
.../manager/load/cache/AbstractLoadCache.java | 2 +-
.../confignode/manager/load/cache/LoadCache.java | 8 +
.../load/cache/region/RegionGroupCache.java | 17 +-
.../manager/node/ClusterNodeStartUtils.java | 2 +-
.../iotdb/confignode/manager/node/NodeManager.java | 4 +-
.../manager/partition/RegionGroupStatus.java | 14 +-
.../iotdb/confignode/persistence/UDFInfo.java | 43 +-
.../persistence/executor/ConfigPlanExecutor.java | 20 +-
.../persistence/schema/ClusterSchemaInfo.java | 3 +
.../confignode/persistence/schema/ConfigMTree.java | 2 +-
.../confignode/procedure/ProcedureExecutor.java | 2 +-
.../procedure/env/RemoveDataNodeHandler.java | 27 +-
.../impl/node/RemoveDataNodesProcedure.java | 19 +-
.../impl/pipe/task/CreatePipeProcedureV2.java | 4 +-
.../iotdb/confignode/service/ConfigNode.java | 2 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 7 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 22 +-
.../response/ConvertToThriftRespTest.java | 19 +-
.../confignode/manager/load/LoadManagerTest.java | 12 +-
.../manager/load/cache/RegionGroupCacheTest.java | 2 +-
.../iotdb/confignode/persistence/UDFInfoTest.java | 6 +-
.../iot/client/IoTConsensusClientPool.java | 5 +-
.../apache/iotdb/consensus/pipe/PipeConsensus.java | 13 +-
.../consensus/pipe/PipeConsensusServerImpl.java | 24 +-
.../consensuspipe/ConsensusPipeDispatcher.java | 3 +-
.../pipe/consensuspipe/ConsensusPipeManager.java | 18 +-
.../pipe/metric/PipeConsensusSyncLagManager.java | 88 +-
.../service/PipeConsensusRPCServiceProcessor.java | 3 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 3 +-
.../schemaregion/SchemaExecutionVisitor.java | 36 +-
.../PipeDataRegionProcessorConstructor.java | 4 +
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 18 +-
.../batch/PipeTabletEventTsFileBatch.java | 8 +-
.../request/PipeTransferTabletRawReq.java | 4 +-
.../request/PipeTransferTabletRawReqV2.java | 4 +-
.../protocol/legacy/IoTDBLegacyPipeConnector.java | 4 +-
.../connector/protocol/opcua/OpcUaNameSpace.java | 8 +-
.../protocol/writeback/WriteBackConnector.java | 120 +--
.../pipe/connector/util/PipeTabletEventSorter.java | 16 +-
.../consensus/ConsensusPipeDataNodeDispatcher.java | 4 +-
.../deletion/persist/PageCacheDeletionBuffer.java | 4 +-
.../db/pipe/event/common/PipeInsertionEvent.java | 4 +
.../db/pipe/event/common/row/PipeRowCollector.java | 14 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 2 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 4 +-
.../tablet/parser/TabletInsertionEventParser.java | 25 +-
.../TabletInsertionEventTablePatternParser.java | 8 +-
.../TabletInsertionEventTreePatternParser.java | 2 +-
...ileInsertionEventQueryParserTabletIterator.java | 6 +-
.../scan/TsFileInsertionEventScanParser.java | 6 +-
...ileInsertionEventTableParserTabletIterator.java | 24 +-
.../PipeRealtimeDataRegionHybridExtractor.java | 4 +-
.../schemachange/RenameDatabaseProcessor.java | 101 ++
.../twostage/plugin/TwoStageCountProcessor.java | 1 -
.../pipeconsensus/PipeConsensusReceiver.java | 27 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 4 +-
...peStatementDataTypeConvertExecutionVisitor.java | 32 +-
.../visitor/PipeStatementTSStatusVisitor.java | 3 +-
.../resource/memory/InsertNodeMemoryEstimator.java | 2 +-
.../db/pipe/resource/memory/PipeMemoryManager.java | 4 +
.../pipe/resource/tsfile/PipeTsFileResource.java | 4 +
.../resource/tsfile/PipeTsFileResourceManager.java | 19 +
.../iotdb/db/protocol/client/ConfigNodeClient.java | 5 +-
.../protocol/client/DataNodeClientPoolFactory.java | 5 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 4 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 7 +-
.../common/header/ColumnHeaderConstant.java | 4 +-
.../common/schematree/ClusterSchemaTree.java | 4 +-
.../schematree/visitor/SchemaTreeVisitor.java | 2 +-
.../execution/MemoryEstimationHelper.java | 4 +-
.../execution/aggregation/UDAFAccumulator.java | 2 +-
.../execution/executor/RegionWriteExecutor.java | 30 +
.../execution/fragment/QueryContext.java | 15 +-
.../execution/operator/OperatorContext.java | 4 +-
.../TableAggregationTableScanOperator.java | 45 +-
.../relational/TableFullOuterJoinOperator.java | 292 +-----
.../source/relational/TableInnerJoinOperator.java | 175 ++--
.../source/relational/TableScanOperator.java | 44 +-
.../grouped/HashAggregationOperator.java | 2 +
.../grouped/StreamingAggregationOperator.java | 5 +-
.../grouped/StreamingHashAggregationOperator.java | 18 +-
.../builder/InMemoryHashAggregationBuilder.java | 13 +
.../db/queryengine/plan/analyze/AnalyzeUtils.java | 56 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 6 +-
.../queryengine/plan/analyze/SelectIntoUtils.java | 12 +
.../db/queryengine/plan/analyze/TemplatedInfo.java | 2 +-
.../load/TreeSchemaAutoCreatorAndVerifier.java | 12 +-
.../plan/execution/config/ConfigExecution.java | 2 +-
.../execution/config/TableConfigTaskVisitor.java | 25 +
.../execution/config/TreeConfigTaskVisitor.java | 33 +-
.../config/executor/ClusterConfigTaskExecutor.java | 76 +-
.../config/executor/IConfigTaskExecutor.java | 14 +-
.../config/metadata/CreateFunctionTask.java | 28 +-
.../config/metadata/DropFunctionTask.java | 10 +-
.../config/metadata/ShowFunctionsTask.java | 102 +-
.../TableModelStatementMemorySourceVisitor.java | 7 +-
.../plan/expression/multi/FunctionExpression.java | 4 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 9 +-
.../plan/parser/StatementGenerator.java | 6 +-
.../plan/planner/LogicalPlanBuilder.java | 5 +-
.../plan/planner/TableOperatorGenerator.java | 6 +-
.../planner/distribution/ExchangeNodeAdder.java | 4 +
.../plan/planner/plan/node/ExplainAnalyzeNode.java | 26 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 29 +-
.../plan/planner/plan/node/PlanNodeType.java | 9 +-
.../plan/planner/plan/node/PlanVisitor.java | 11 +
.../planner/plan/node/process/ExchangeNode.java | 9 +-
.../plan/planner/plan/node/write/InsertNode.java | 6 +-
.../planner/plan/node/write/InsertRowNode.java | 2 +-
.../planner/plan/node/write/InsertTabletNode.java | 2 +-
.../plan/node/write/RelationalDeleteDataNode.java | 8 +-
.../plan/relational/analyzer/Analysis.java | 8 +-
.../plan/relational/analyzer/Analyzer.java | 2 +-
.../relational/analyzer/StatementAnalyzer.java | 4 +
.../function/arithmetic/AdditionResolver.java | 14 +
.../function/arithmetic/DivisionResolver.java | 10 +
.../function/arithmetic/ModulusResolver.java | 10 +
.../arithmetic/MultiplicationResolver.java | 10 +
.../function/arithmetic/SubtractionResolver.java | 10 +
.../relational/metadata/TableMetadataImpl.java | 17 +-
.../plan/relational/metadata/TableSchema.java | 12 +-
.../metadata/fetcher/cache/SchemaCacheEntry.java | 4 +-
.../cache/TreeDeviceSchemaCacheManager.java | 6 +-
.../relational/planner/TableLogicalPlanner.java | 10 +-
.../planner/distribute/AddExchangeNodes.java | 25 +-
.../planner/distribute/SubPlanGenerator.java | 2 +-
.../distribute/TableDistributedPlanGenerator.java | 23 +-
.../distribute/TableDistributedPlanner.java | 2 +-
.../distribute/TableModelQueryFragmentPlanner.java | 6 +-
.../TableModelTypeProviderExtractor.java | 4 +-
.../planner/node}/ExchangeNode.java | 72 +-
.../planner/node/ExplainAnalyzeNode.java | 115 ++
.../optimizations/PushPredicateIntoTableScan.java | 12 +-
.../optimizations/UnaliasSymbolReferences.java | 2 +-
.../plan/relational/sql/ast/DeleteDevice.java | 2 +
.../plan/relational/sql/ast/DropColumn.java | 15 +-
.../plan/relational/sql/ast/ExplainAnalyze.java | 5 -
.../queryengine/plan/relational/sql/ast/Query.java | 5 -
.../plan/relational/sql/ast/Statement.java | 4 -
.../plan/statement/crud/InsertBaseStatement.java | 2 +-
.../metadata/CreateFunctionStatement.java | 24 +-
.../dag/column/leaf/NullColumnTransformer.java | 4 +-
.../AbstractCastFunctionColumnTransformer.java | 4 +-
.../dag/udf/UDAFInformationInferrer.java | 2 +-
.../transformation/dag/udf/UDTFExecutor.java | 2 +-
.../dag/udf/UDTFInformationInferrer.java | 2 +-
.../apache/iotdb/db/schemaengine/SchemaEngine.java | 52 +-
.../rescon/DataNodeSchemaQuotaManager.java | 4 +-
.../rescon/MemSchemaRegionStatistics.java | 5 +-
.../schemaengine/schemaregion/ISchemaRegion.java | 10 +
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 25 +-
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 7 +-
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 27 +-
.../reader/impl/TimeseriesReaderWithViewFetch.java | 3 +-
.../schemaengine/schemaregion/tag/TagLogFile.java | 9 +-
.../schemaregion/utils/MNodeUtils.java | 2 +-
.../schemaregion/utils/ResourceByPathUtils.java | 4 +-
.../db/schemaengine/table/DataNodeTableCache.java | 4 +-
.../iotdb/db/schemaengine/template/Template.java | 2 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 16 +-
.../db/storageengine/dataregion/DataRegion.java | 6 +-
.../impl/ReadPointCompactionPerformer.java | 2 +-
.../execute/task/InnerSpaceCompactionTask.java | 4 +
.../execute/utils/CompactionTableSchema.java | 28 +-
...BatchedFastAlignedSeriesCompactionExecutor.java | 4 +-
...edReadChunkAlignedSeriesCompactionExecutor.java | 2 +-
.../utils/AlignedSeriesBatchCompactionUtils.java | 2 +-
.../FirstBatchCompactionAlignedChunkWriter.java | 8 +-
...FollowingBatchCompactionAlignedChunkWriter.java | 2 +-
.../fast/FastAlignedSeriesCompactionExecutor.java | 2 +-
.../FastNonAlignedSeriesCompactionExecutor.java | 2 +-
.../readchunk/AlignedSeriesCompactionExecutor.java | 2 +-
.../ReadChunkAlignedSeriesCompactionExecutor.java | 4 +-
.../readchunk/SingleSeriesCompactionExecutor.java | 2 +-
.../compaction/io/CompactionTsFileWriter.java | 6 +-
.../DefaultCompactionTaskComparatorImpl.java | 12 +-
.../dataregion/flush/MemTableFlushTask.java | 2 +-
.../dataregion/memtable/AbstractMemTable.java | 17 +-
.../memtable/AlignedReadOnlyMemChunk.java | 2 +-
.../memtable/AlignedWritableMemChunk.java | 30 +-
.../memtable/AlignedWritableMemChunkGroup.java | 10 +-
.../dataregion/memtable/IWritableMemChunk.java | 5 +-
.../dataregion/memtable/TsFileProcessor.java | 1 +
.../dataregion/memtable/WritableMemChunk.java | 2 +-
.../dataregion/memtable/WritableMemChunkGroup.java | 2 +-
.../dataregion/modification/IDPredicate.java | 16 +-
.../modification/TableDeletionEntry.java | 4 +
.../dataregion/tsfile/TsFileManager.java | 11 +-
.../dataregion/utils/TsFileResourceUtils.java | 14 +-
.../file/UnsealedTsFileRecoverPerformer.java | 22 +
.../dataregion/wal/utils/WALWriteUtils.java | 4 +-
.../splitter/BatchedAlignedValueChunkData.java | 2 +-
.../iotdb/db/tools/TsFileSplitByPartitionTool.java | 4 +-
.../db/trigger/executor/TriggerFireVisitor.java | 5 +-
.../apache/iotdb/db/utils/ModificationUtils.java | 22 +-
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 10 +-
.../mtree/schemafile/WrappedSegmentTest.java | 4 +-
.../iotdb/db/metadata/path/PatternTreeMapTest.java | 27 +-
.../connector/PipeDataNodeThriftRequestTest.java | 37 +-
.../pipe/connector/PipeTabletEventSorterTest.java | 60 +-
.../pipe/event/PipeTabletInsertionEventTest.java | 12 +-
.../pipe/event/TsFileInsertionEventParserTest.java | 1 -
.../resource/PipeTsFileResourceManagerTest.java | 31 +-
.../common/schematree/ClusterSchemaTreeTest.java | 4 +-
.../AlignedSeriesAggregationScanOperatorTest.java | 2 +-
.../operator/AlignedSeriesScanOperatorTest.java | 10 +-
.../execution/operator/AlignedSeriesTestUtil.java | 12 +-
.../schema/SchemaFetchScanOperatorTest.java | 2 +-
.../plan/optimization/LimitOffsetPushDownTest.java | 71 ++
.../plan/optimization/OptimizationTestUtil.java | 2 +
.../plan/optimization/TestPlanBuilder.java | 45 +
.../plan/parser/StatementGeneratorTest.java | 6 +-
.../logical/RegionScanLogicalPlannerTest.java | 75 +-
.../node/write/RelationalDeleteDataNodeTest.java | 24 +-
.../plan/relational/analyzer/AnalyzerTest.java | 2 +-
.../plan/relational/analyzer/JoinTest.java | 2 +-
.../analyzer/LimitOffsetPushDownTest.java | 2 +-
.../plan/relational/analyzer/SortTest.java | 2 +-
.../plan/relational/analyzer/SubQueryTest.java | 2 +-
.../plan/relational/analyzer/TestUtils.java | 2 +-
.../planner/assertions/ExchangeNodeMatcher.java | 2 +-
.../planner/assertions/PlanMatchPattern.java | 2 +-
.../planner/assertions/PlanMatchingVisitor.java | 4 +-
.../storageengine/buffer/BloomFilterCacheTest.java | 12 +-
.../db/storageengine/buffer/ChunkCacheTest.java | 8 +-
.../storageengine/dataregion/DataRegionTest.java | 89 +-
.../dataregion/LastFlushTimeMapTest.java | 33 +-
.../compaction/AbstractCompactionTest.java | 2 +-
.../compaction/CompactionDataTypeNotMatchTest.java | 24 +-
.../compaction/CompactionTaskComparatorTest.java | 25 +-
.../compaction/CompactionValidationTest.java | 12 +-
.../cross/InsertionCrossSpaceCompactionTest.java | 32 +
.../dataregion/compaction/cross/MergeTest.java | 8 +-
.../compaction/cross/MergeUpgradeTest.java | 6 +-
.../cross/RewriteCompactionFileSelectorTest.java | 38 +-
.../inner/AbstractInnerSpaceCompactionTest.java | 8 +-
.../inner/FastCompactionPerformerAlignedTest.java | 16 +-
.../FastCompactionPerformerNoAlignedTest.java | 2 +-
.../inner/InnerCompactionMoreDataTest.java | 8 +-
.../compaction/inner/InnerCompactionTest.java | 8 +-
.../inner/InnerSpaceCompactionExceptionTest.java | 12 +-
.../ReadChunkCompactionPerformerAlignedTest.java | 16 +-
.../ReadChunkCompactionPerformerNoAlignedTest.java | 2 +-
.../inner/ReadChunkCompactionPerformerOldTest.java | 2 +-
.../SizeTieredCompactionRecoverTest.java | 44 +-
.../inner/sizetiered/SizeTieredCompactionTest.java | 26 +-
.../settle/SettleRequestHandlerTest.java | 2 +-
.../CompactionTableModelTestFileWriter.java | 6 +-
.../CompactionTableSchemaCollectorTest.java | 54 +-
.../compaction/utils/CompactionCheckerUtils.java | 2 +-
.../dataregion/memtable/TsFileProcessorTest.java | 48 +-
.../read/reader/series/SeriesReaderTestUtil.java | 10 +-
.../wal/recover/WALRecoverManagerTest.java | 20 +-
.../file/SealedTsFileRecoverPerformerTest.java | 36 +-
.../wal/recover/file/TsFilePlanRedoerTest.java | 20 +-
.../file/UnsealedTsFileRecoverPerformerTest.java | 67 +-
.../rescon/memory/ResourceManagerTest.java | 8 +-
.../iotdb/db/tools/TsFileAndModSettleToolTest.java | 6 +-
.../iotdb/db/tools/TsFileSelfCheckToolTest.java | 12 +-
.../iotdb/db/tools/TsFileSketchToolTest.java | 20 +-
.../org/apache/iotdb/db/utils/MemUtilsTest.java | 2 +-
.../apache/iotdb/commons/client/ClientManager.java | 11 +-
.../iotdb/commons/client/ClientPoolFactory.java | 57 +-
.../iotdb/commons/client/IClientPoolFactory.java | 4 +-
.../client/factory/AsyncThriftClientFactory.java | 6 +
.../client/request/TestConnectionUtils.java | 6 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 21 +-
.../iotdb/commons/conf/CommonDescriptor.java | 8 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 2 +
.../org/apache/iotdb/commons/path/AlignedPath.java | 2 +-
.../iotdb/commons/path/NonAlignedFullPath.java | 4 +-
.../org/apache/iotdb/commons/path/PartialPath.java | 3 +-
.../apache/iotdb/commons/path/PatternTreeMap.java | 2 +-
.../agent/plugin/builtin/BuiltinPipePlugin.java | 3 +
.../schemachange/RenameDatabaseProcessor.java} | 26 +-
.../config/constant/PipeProcessorConstant.java | 2 +
.../pipe/config/constant/SystemConstant.java | 2 +
.../connector/client/IoTDBSyncClientManager.java | 25 +-
.../schema/table/TsTableInternalRPCUtil.java | 6 +-
.../schema/table/column/TsTableColumnCategory.java | 12 +-
.../commons/schema/view/LogicalViewSchema.java | 22 +-
.../apache/iotdb/commons/udf/UDFInformation.java | 64 +-
.../org/apache/iotdb/commons/udf/UDFTable.java | 105 +-
.../java/org/apache/iotdb/commons/udf/UDFType.java | 71 ++
.../BuiltinTimeSeriesGeneratingFunction.java | 13 +
.../commons/udf/service/UDFExecutableManager.java | 46 +
.../commons/udf/service/UDFManagementService.java | 286 ++---
.../iotdb/commons/udf/utils/TreeUDFUtils.java} | 33 +-
.../iotdb/commons/client/ClientManagerTest.java | 11 +-
.../thrift-commons/src/main/thrift/common.thrift | 5 +
.../src/main/thrift/confignode.thrift | 9 +-
.../src/main/thrift/datanode.thrift | 1 +
pom.xml | 2 +-
530 files changed, 8284 insertions(+), 4538 deletions(-)
create mode 100644 .github/workflows/vulnerability-check.yml
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/db/it/IoTDBDisableDeletionTableIT.java
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/function/GetFunctionTablePlan.java
=>
iotdb-api/udf-api/src/main/java/org/apache/iotdb/udf/api/relational/AggregationFunction.java
(67%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/function/GetFunctionTablePlan.java
=>
iotdb-api/udf-api/src/main/java/org/apache/iotdb/udf/api/relational/SQLFunction.java
(67%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/function/GetFunctionTablePlan.java
=>
iotdb-api/udf-api/src/main/java/org/apache/iotdb/udf/api/relational/ScalarFunction.java
(67%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/function/GetFunctionTablePlan.java
=>
iotdb-api/udf-api/src/main/java/org/apache/iotdb/udf/api/relational/TableFunction.java
(67%)
create mode 100644
iotdb-api/udf-api/src/main/java/org/apache/iotdb/udf/api/relational/access/Record.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/data/AsyncImportData.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/data/ImportDataScanTool.java
create mode 100644 iotdb-client/client-py/iotdb/table_session.py
create mode 100644 iotdb-client/client-py/iotdb/table_session_pool.py
rename iotdb-client/client-py/{SessionAlignedTimeseriesExample.py =>
session_aligned_timeseries_example.py} (100%)
rename iotdb-client/client-py/{SessionExample.py => session_example.py} (100%)
rename iotdb-client/client-py/{SessionPoolExample.py =>
session_pool_example.py} (100%)
rename iotdb-client/client-py/{TableModelSessionExample.py =>
table_model_session_example.py} (83%)
rename iotdb-client/client-py/{TableModelSessionPoolExample.py =>
table_model_session_pool_example.py} (85%)
rename iotdb-client/client-py/{iotdb/dbapi/tests =>
tests/integration/dbapi}/__init__.py (100%)
rename iotdb-client/client-py/{iotdb/dbapi/tests =>
tests/integration/dbapi}/test_connection.py (96%)
rename iotdb-client/client-py/{iotdb/dbapi/tests =>
tests/integration/dbapi}/test_cursor.py (98%)
rename iotdb-client/client-py/{iotdb/IoTDBContainer.py =>
tests/integration/iotdb_container.py} (100%)
rename iotdb-client/client-py/{iotdb/sqlalchemy/tests =>
tests/integration/sqlalchemy}/__init__.py (100%)
rename iotdb-client/client-py/{iotdb/sqlalchemy/tests =>
tests/integration/sqlalchemy}/test_dialect.py (98%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/Statement.java
=>
iotdb-client/session/src/main/java/org/apache/iotdb/session/util/CheckedSupplier.java
(61%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/function/{GetFunctionTablePlan.java
=> GetAllFunctionTablePlan.java} (86%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/function/{DropFunctionPlan.java
=> DropTableModelFunctionPlan.java} (85%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/function/{DropFunctionPlan.java
=> DropTreeModelFunctionPlan.java} (85%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/function/{DropFunctionPlan.java
=> UpdateFunctionPlan.java} (63%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/schemachange/RenameDatabaseProcessor.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/{planner/plan/node/process
=> relational/planner/node}/ExchangeNode.java (78%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/ExplainAnalyzeNode.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/Statement.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/processor/schemachange/RenameDatabaseProcessor.java}
(63%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/udf/UDFType.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/leaf/NullColumnTransformer.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/udf/utils/TreeUDFUtils.java}
(56%)
