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 3b0f1ff8f89 fix pipe adaption
add 431469fce31 Pipe/Load: Disable Pipe/Load when TSFile encryption is
enabled (#14070)
add c6fa44d3de1 Add ainode to distribution (#14090)
add 86a33773e8c Pipe IT: Add table model related IT (#14086)
add 442dc861f97 PipeConsensus: apply IoTConsensusV2 as cluster mode for
integration test (#13481)
add 7908cf720af Fix corner case of StreamAggOperator
add db1b897f2f9 Revert integration-test module change (#14096)
add 2a1dc883d73 Bump netty version to 4.1.115.Final (#14095)
add 978f14daaa3 Modify default heap dump path of confignode (#14088)
add f15ebf3dd3e [Region Migration] Support Migrate Unknown Node for IoTV2
&& Rename KillPoints to Fit IoTV2 (#14085)
add 44b348cdb06 [region migration] Fix IoTConsensus data consistency
during region member changes (#14084)
add e2788a242d7 Subscription: stream parsing tablets during the poll
process to reduce memory usage (#14101)
add cfb4c8ae30f Fix heap dump path (#14105)
add 7f56c1bc1a2 Modify env script comment #14118
add b14cdbef2ca Fix error message when there is no argument in sum, avg
and extreme
add de22d8ff928 Added version for dataNode table cache
add 0d6482789ab Support all push-able expressions in push down to metaData
& Optimized database-related error logs
add 63da4a42c94 Table model data deletion (#13878)
add 8a847870939 Fix intermediate output of MaxMinByAccumulator in
TableModel
add b5a8b47e8f6 Support using long to compare timestamp type in expression
add f3afc203633 [remove datanode] Enhance remove message on environment
with only ConfigNode #14123
add f9f23853a60 bump ratis to 3.1.2-2fe59d3-SNAPSHOT (#14120)
add 5fd2c9cd45c Implement schema quota for activation in table model
add 0fb31a70bca Make the root.__system database has a normal number of
replicas (no longer forcing the replica to be 1) (#14127)
add 921652a8c88 Fix error message when there is no argument in first,
last, first_by and last_by
add e85a7eaac69 Fix first_by and last_by with group by in TableModel
add 466c0d91326 fix trim (#14130)
add f8bcf2adec6 Fix that the row deletion mark is mistakenly use (#14138)
add 21af258bf0b Try to eliminate redundant Project and Sort For right
table of Join clause in some self-join cases
add 16c3f66519a Update release info after 1.3.3 released (#14151)
add 2dfe81feba9 Fixed the bug that limit is pushed down when there is a
filter node
add 51765342bcf Batch update inserted points metric for insertMultiTablets
(#14146)
add e37d2b9b0db Fix NPE of empty data aggregation query when there is no
push-down optimize in TableModel
add 4420f2160a9 Pipe IT: Ignore Pipe capture history TSFile test for table
model (#14153)
add 43ed86500d6 PipeConsensus: always execute flush for historical data
extraction of consensus pipe to reduce data sync delay (#14132)
add 4a76dfbabbd Fix ConfigNode Partition Metric NPE bug #14144
add 82a1dc3990a Fixed the bug that set table properties ttl='inf' cannot
be parsed && ttl='INF' does not take effect && set to default may generate NPE
on dataNodes && some minor bugs of delete devices && Enable "inf" in
databaseSchema / show ttl for databases in table model / table default ttl =
database ttl (#14147)
add 1b33c55153a Change LogicalOptimizer and DistributionOptimizer
singleton (#14158)
add 3cb544e39b2 Pipe: Reduce the memory usage & Enable insertNode memory
control for stream mode degrade and stuck restart (#14102)
add c7276b9eba4 Merge branch 'master' into share_mod_file
No new revisions were added by this update.
Summary of changes:
.github/workflows/pipe-it-2cluster.yml | 51 +-
LICENSE | 43 +-
LICENSE-binary | 118 ++-
RELEASE_NOTES.md | 363 +++++++++
distribution/pom.xml | 58 ++
.../src/assembly/{client-cpp.xml => ainode.xml} | 16 +-
integration-test/pom.xml | 44 +-
.../iotdb/it/env/cluster/ClusterConstant.java | 33 +
.../org/apache/iotdb/it/env/cluster/EnvUtils.java | 14 +
.../iotdb/it/env/cluster/env/AbstractEnv.java | 11 +-
.../it/env/cluster/node/AbstractNodeWrapper.java | 60 ++
.../iotdb/it/env/remote/env/RemoteServerEnv.java | 2 +-
...usterIT.java => MultiClusterIT2TableModel.java} | 2 +-
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 11 +-
.../IoTDBRegionMigrateReliabilityITFramework.java | 1 +
...rateCoordinatorCrashWhenRemoveRemotePeerIT.java | 7 +-
.../org/apache/iotdb/db/it/IoTDBDeletionIT.java | 32 +-
.../org/apache/iotdb/db/it/utils/TestUtils.java | 141 +++-
.../pipe/it/autocreate/AbstractPipeDualAutoIT.java | 48 ++
.../pipe/it/autocreate/IoTDBPipeAutoDropIT.java | 80 +-
.../IoTDBPipeConnectorCompressionIT.java | 7 +-
.../pipe/it/autocreate/IoTDBPipeIdempotentIT.java | 2 +-
.../pipe/it/autocreate/IoTDBPipeLifeCycleIT.java | 20 +-
.../it/autocreate/IoTDBPipeSwitchStatusIT.java | 7 +-
.../it/autocreate/IoTDBTreePatternFormatIT.java | 3 +
.../pipe/it/manual/AbstractPipeDualManualIT.java | 48 ++
.../pipe/it/manual/IoTDBPipeMetaHistoricalIT.java | 1 +
.../pipe/it/manual/IoTDBPipePermissionIT.java | 1 +
.../AbstractPipeTableModelTestIT.java} | 4 +-
.../IoTDBPipeAlterIT.java | 222 ++----
.../IoTDBPipeAutoConflictIT.java | 180 ++---
.../IoTDBPipeAutoDropIT.java | 46 +-
.../IoTDBPipeClusterIT.java | 373 ++++-----
.../IoTDBPipeConnectorCompressionIT.java | 54 +-
.../IoTDBPipeConnectorParallelIT.java | 18 +-
.../pipe/it/tablemodel/IoTDBPipeDataSinkIT.java | 219 ++++++
.../IoTDBPipeExtractorIT.java | 836 +++++++++------------
.../IoTDBPipeLifeCycleIT.java | 517 ++++---------
.../pipe/it/tablemodel/IoTDBPipeNullValueIT.java | 169 +++++
.../IoTDBPipeProtocolIT.java | 170 ++---
.../IoTDBPipeSwitchStatusIT.java | 61 +-
.../IoTDBPipeSyntaxIT.java | 271 +++----
.../IoTDBPipeWithLoadIT.java | 48 +-
.../it/tablemodel/IoTDBTablePatternFormatIT.java | 572 ++++++++++++++
.../iotdb/pipe/it/tablemodel/TableModelUtils.java | 395 ++++++++++
.../relational/it/db/it/IoTDBDeletionTableIT.java | 2 +-
.../db/it/IoTDBMultiIDsWithAttributesTableIT.java | 7 +-
.../it/query/old/query/IoTDBInTableIT.java | 89 ++-
.../it/query/recent/IoTDBTableAggregationIT.java | 91 +++
.../relational/it/schema/IoTDBDatabaseIT.java | 30 +-
.../iotdb/relational/it/schema/IoTDBTableIT.java | 73 +-
.../IoTDBDefaultTsfilePushConsumerIT.java | 6 +-
.../IoTDBRootDatasetPushConsumerIT.java | 2 +-
.../IoTDBRootPullConsumeTsfileIT.java | 2 +-
.../param/IoTDBTestParamPullConsumerIT.java | 6 +-
.../format/IoTDBDBDataSetPullConsumerIT.java | 2 +-
.../format/IoTDBDBTsfilePullConsumerIT.java | 2 +-
.../IoTDBAllTsTsfilePullConsumerIT.java | 2 +-
.../IoTDBAllTsfilePullConsumerSnapshotIT.java | 2 +-
.../IoTDBPathDeviceTsfilePullConsumerIT.java | 2 +-
.../IoTDBTimeTsTsfilePullConsumerIT.java | 2 +-
.../IoTDBSnapshotDevicePullConsumerTsfileIT.java | 2 +-
...TDBConsumer2With1TopicShareProcessTsfileIT.java | 2 +-
.../multi/IoTDBMultiGroupVsMultiConsumerIT.java | 2 +-
.../multi/IoTDBOneConsumerMultiTopicsMixIT.java | 6 +-
.../multi/IoTDBOneConsumerMultiTopicsTsfileIT.java | 2 +-
.../pattern/IoTDBDBPatternPullConsumeTsfileIT.java | 2 +-
.../IoTDBDevicePatternPullConsumeTsfileIT.java | 2 +-
...IoTDBMiddleMatchPatternPullConsumeTsfileIT.java | 2 +-
.../IoTDBRootPatternPullConsumeTsfileIT.java | 2 +-
.../pattern/IoTDBTSPatternPullConsumeTsfileIT.java | 2 +-
.../format/IoTDBTestPushConsumeDataSetIT.java | 2 +-
.../IoTDBTestPushConsumeNoTargetDirTsfileIT.java | 2 +-
.../format/IoTDBTestPushConsumeTsfileIT.java | 2 +-
.../IoTDBLooseAllTsDatasetPushConsumerIT.java | 8 +-
...TDBLooseAllTsDatasetPushConsumerSnapshotIT.java | 8 +-
.../IoTDBLooseAllTsfilePushConsumerIT.java | 12 +-
.../IoTDBPathLooseDeviceTsfilePushConsumerIT.java | 10 +-
.../IoTDBPathLooseTsDatasetPushConsumerIT.java | 2 +-
.../IoTDBPathLooseTsfilePushConsumerIT.java | 10 +-
.../IoTDBPathTsLooseDatasetPushConsumerIT.java | 2 +-
.../IoTDBTimeLooseTsDatasetPushConsumerIT.java | 4 +-
.../IoTDBTimeLooseTsTsfilePushConsumerIT.java | 12 +-
.../IoTDBTimeLooseTsfilePushConsumerIT.java | 12 +-
.../IoTDBTimeTsLooseDatasetPushConsumerIT.java | 4 +-
...oTDBSnapshotTSPatternDatasetPushConsumerIT.java | 2 +-
...IoTDBSnapshotTSPatternTsfilePushConsumerIT.java | 2 +-
...TDBConsumer2With1TopicShareProcessTsfileIT.java | 2 +-
.../multi/IoTDBMultiGroupVsMultiConsumerIT.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/IoTDBRealTimeDBTsfilePushConsumerIT.java | 2 +-
.../time/IoTDBTimeRangeDBTsfilePushConsumerIT.java | 2 +-
iotdb-client/jdbc/src/main/feature/feature.xml | 2 +-
.../SubscriptionSessionDataSetsHandler.java | 19 +-
iotdb-core/ainode/pom.xml | 1 +
.../src/assembly/resources/conf/confignode-env.sh | 35 +-
.../pipe/runtime/PipeHandleMetaChangePlan.java | 8 +-
.../response/pipe/task/PipeTableResp.java | 5 +-
.../manager/load/balancer/RouteBalancer.java | 2 +-
.../manager/partition/PartitionManager.java | 4 +-
.../manager/partition/PartitionMetrics.java | 8 +-
.../pipe/agent/task/PipeConfigNodeTaskAgent.java | 4 +-
.../runtime/PipeLeaderChangeHandler.java | 2 +-
.../runtime/heartbeat/PipeHeartbeat.java | 3 +-
.../runtime/heartbeat/PipeHeartbeatParser.java | 5 +-
.../manager/pipe/metric/PipeConfigNodeMetrics.java | 4 +-
... => PipeTemporaryMetaInCoordinatorMetrics.java} | 29 +-
.../manager/schema/ClusterSchemaManager.java | 26 +-
.../persistence/partition/PartitionInfo.java | 97 +--
.../confignode/persistence/pipe/PipeInfo.java | 16 +-
.../confignode/persistence/pipe/PipeTaskInfo.java | 4 +-
.../persistence/schema/ClusterSchemaInfo.java | 15 +-
.../confignode/persistence/schema/ConfigMTree.java | 10 +-
.../procedure/env/RegionMaintainHandler.java | 4 +-
.../impl/pipe/task/AlterPipeProcedureV2.java | 2 +-
.../impl/pipe/task/CreatePipeProcedureV2.java | 4 +-
.../impl/schema/table/AddTableColumnProcedure.java | 26 +-
.../impl/schema/table/CreateTableProcedure.java | 37 +-
.../impl/schema/table/DeleteDevicesProcedure.java | 40 +-
.../schema/table/RenameTableColumnProcedure.java | 26 +-
.../schema/table/SetTablePropertiesProcedure.java | 26 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 8 +-
.../apache/iotdb/consensus/iot/IoTConsensus.java | 19 +-
.../consensus/iot/IoTConsensusServerImpl.java | 27 +-
.../apache/iotdb/consensus/pipe/PipeConsensus.java | 17 +-
.../consensus/pipe/PipeConsensusServerImpl.java | 58 +-
.../src/assembly/resources/conf/datanode-env.sh | 23 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 62 +-
.../db/conf/rest/IoTDBRestServiceDescriptor.java | 88 ++-
.../exception/metadata/DatabaseModelException.java | 9 +-
.../db/pipe/agent/runtime/PipeAgentLauncher.java | 2 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 30 +-
.../evolvable/batch/PipeTabletEventPlainBatch.java | 10 +-
.../async/IoTDBDataRegionAsyncConnector.java | 2 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 30 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 6 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 1 -
...oricalDataRegionTsFileAndDeletionExtractor.java | 17 +
.../PipeRealtimeDataRegionHybridExtractor.java | 12 +-
.../iotdb/db/protocol/client/ConfigNodeInfo.java | 3 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 7 +-
.../common/header/ColumnHeaderConstant.java | 2 +
.../relational/aggregation/AccumulatorFactory.java | 15 +-
.../aggregation/TableMaxMinByBaseAccumulator.java | 10 +-
.../grouped/GroupedFirstByAccumulator.java | 2 +
.../grouped/GroupedLastByAccumulator.java | 1 +
.../grouped/StreamingAggregationOperator.java | 10 +-
.../grouped/StreamingHashAggregationOperator.java | 10 +-
.../relational/ColumnTransformerBuilder.java | 12 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 35 +-
.../queryengine/plan/analyze/PredicateUtils.java | 9 +-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 22 +
.../load/LoadTsFileToTableModelAnalyzer.java | 9 +-
.../load/LoadTsFileToTreeModelAnalyzer.java | 9 +-
.../execution/config/TableConfigTaskVisitor.java | 40 +-
.../config/executor/ClusterConfigTaskExecutor.java | 60 +-
.../config/metadata/relational/ShowDBTask.java | 35 +-
.../TableModelStatementMemorySourceVisitor.java | 11 +-
.../plan/planner/TableOperatorGenerator.java | 130 ++--
.../relational/analyzer/StatementAnalyzer.java | 9 +-
.../predicate/ConvertPredicateToFilterVisitor.java | 48 +-
.../ConvertPredicateToTimeFilterVisitor.java | 60 +-
.../PredicatePushIntoMetadataChecker.java | 153 +++-
.../schema/CheckSchemaPredicateVisitor.java | 51 +-
.../relational/metadata/TableMetadataImpl.java | 8 +-
.../plan/relational/planner/PlanBuilder.java | 4 +-
.../plan/relational/planner/QueryPlanner.java | 24 +-
.../plan/relational/planner/RelationPlan.java | 14 +-
.../plan/relational/planner/RelationPlanner.java | 37 +-
.../relational/planner/TableLogicalPlanner.java | 61 +-
.../plan/relational/planner/TableModelPlanner.java | 20 +-
.../distribute/TableDistributedPlanGenerator.java | 19 +-
.../distribute/TableDistributedPlanner.java | 43 +-
.../TableModelTypeProviderExtractor.java | 5 +
.../ir/GlobalTimePredicateExtractVisitor.java | 37 +-
...AddTableScanColumnsToTypeProviderOptimizer.java | 66 --
.../iterative/rule/PruneTableScanColumns.java | 12 +-
.../relational/planner/node/TableScanNode.java | 18 +
.../optimizations/LogicalOptimizeFactory.java | 4 +-
.../planner/optimizations/PlanOptimizer.java | 8 -
.../PushAggregationIntoTableScan.java | 12 +-
.../PushLimitOffsetIntoTableScan.java | 3 +-
.../optimizations/PushPredicateIntoTableScan.java | 101 +--
.../planner/optimizations/SortElimination.java | 16 +-
.../optimizations/TransformSortToStreamSort.java | 5 +-
.../plan/relational/sql/parser/AstBuilder.java | 6 +-
.../apache/iotdb/db/schemaengine/SchemaEngine.java | 33 +-
.../rescon/ISchemaRegionStatistics.java | 6 +-
.../rescon/MemSchemaRegionStatistics.java | 6 +
.../read/resp/info/impl/ShowDevicesResult.java | 4 +-
.../db/schemaengine/table/DataNodeTableCache.java | 17 +
.../db/storageengine/dataregion/DataRegion.java | 134 ++--
.../performer/impl/FastCompactionPerformer.java | 12 +-
.../execute/task/InnerSpaceCompactionTask.java | 1 -
.../compaction/execute/utils/CompactionUtils.java | 23 +-
.../execute/utils/MultiTsFileDeviceIterator.java | 2 +-
.../dataregion/memtable/AbstractMemTable.java | 35 -
.../dataregion/memtable/IMemTable.java | 3 -
.../dataregion/memtable/TsFileProcessor.java | 47 +-
.../dataregion/snapshot/SnapshotTaker.java | 25 +-
.../dataregion/tsfile/TsFileResource.java | 21 +-
.../wal/recover/file/TsFilePlanRedoer.java | 39 +-
.../dataregion/wal/utils/WALEntryHandler.java | 12 +-
.../event/batch/SubscriptionPipeEventBatch.java | 2 +-
.../batch/SubscriptionPipeTabletEventBatch.java | 200 +++--
.../response/SubscriptionEventTabletResponse.java | 73 +-
.../TsFileOverlapValidationAndRepairTool.java | 2 +-
.../db/utils/datastructure/AlignedTVList.java | 21 +-
.../plan/relational/analyzer/AnalyzerTest.java | 201 +++--
.../plan/relational/analyzer/JoinTest.java | 54 +-
.../analyzer/LimitOffsetPushDownTest.java | 50 +-
.../plan/relational/analyzer/SortTest.java | 164 +++-
.../plan/relational/analyzer/SubQueryTest.java | 39 +-
.../plan/relational/analyzer/TestUtils.java | 6 +-
.../plan/relational/planner/PlanTester.java | 3 +-
.../TsFileResourceProgressIndexTest.java | 5 +
.../TableModelCompactionWithTTLTest.java | 3 +-
.../dataregion/memtable/TsFileProcessorTest.java | 88 +--
.../reporter/iotdb/IoTDBSessionReporter.java | 2 +-
.../commons/consensus/index/ProgressIndex.java | 12 +-
.../consensus/index/impl/HybridProgressIndex.java | 36 +-
.../consensus/index/impl/IoTProgressIndex.java | 12 +
.../consensus/index/impl/MetaProgressIndex.java | 9 +-
.../consensus/index/impl/MinimumProgressIndex.java | 5 +
.../consensus/index/impl/RecoverProgressIndex.java | 13 +
.../consensus/index/impl/SimpleProgressIndex.java | 9 +-
.../consensus/index/impl/StateProgressIndex.java | 17 +-
.../index/impl/TimeWindowStateProgressIndex.java | 24 +
.../commons/pipe/agent/task/PipeTaskAgent.java | 59 ++
.../commons/pipe/agent/task/meta/PipeMeta.java | 17 +-
.../pipe/agent/task/meta/PipeTemporaryMeta.java | 73 +-
.../agent/task/meta/PipeTemporaryMetaInAgent.java | 107 +++
...ta.java => PipeTemporaryMetaInCoordinator.java} | 5 +-
.../pipe/agent/task/progress/CommitterKey.java | 2 +-
.../task/progress/PipeEventCommitManager.java | 12 +-
.../iotdb/commons/pipe/event/EnrichedEvent.java | 6 -
.../apache/iotdb/commons/schema/table/TsTable.java | 35 +-
...oTConsensusRemovePeerCoordinatorKillPoints.java | 2 +-
.../iotdb/commons/pipe/task/PipeMetaDeSerTest.java | 19 +-
iotdb-doap.rdf | 8 +
pom.xml | 5 +-
250 files changed, 6464 insertions(+), 3362 deletions(-)
copy distribution/src/assembly/{client-cpp.xml => ainode.xml} (56%)
copy
integration-test/src/main/java/org/apache/iotdb/itbase/category/{ClusterIT.java
=> MultiClusterIT2TableModel.java} (95%)
copy
integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate/AbstractPipeDualAutoIT.java
=> tablemodel/AbstractPipeTableModelTestIT.java} (96%)
copy integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate =>
tablemodel}/IoTDBPipeAlterIT.java (70%)
copy integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate =>
tablemodel}/IoTDBPipeAutoConflictIT.java (66%)
copy integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate =>
tablemodel}/IoTDBPipeAutoDropIT.java (79%)
copy integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate =>
tablemodel}/IoTDBPipeClusterIT.java (75%)
copy integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate =>
tablemodel}/IoTDBPipeConnectorCompressionIT.java (84%)
copy integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate =>
tablemodel}/IoTDBPipeConnectorParallelIT.java (84%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/tablemodel/IoTDBPipeDataSinkIT.java
copy integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate =>
tablemodel}/IoTDBPipeExtractorIT.java (58%)
copy integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate =>
tablemodel}/IoTDBPipeLifeCycleIT.java (53%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/tablemodel/IoTDBPipeNullValueIT.java
copy integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate =>
tablemodel}/IoTDBPipeProtocolIT.java (78%)
copy integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate =>
tablemodel}/IoTDBPipeSwitchStatusIT.java (85%)
copy integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate =>
tablemodel}/IoTDBPipeSyntaxIT.java (81%)
copy integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate =>
tablemodel}/IoTDBPipeWithLoadIT.java (70%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/tablemodel/IoTDBTablePatternFormatIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/tablemodel/TableModelUtils.java
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/{PipeTemporaryMetaMetrics.java
=> PipeTemporaryMetaInCoordinatorMetrics.java} (82%)
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/AddTableScanColumnsToTypeProviderOptimizer.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/meta/PipeTemporaryMetaInAgent.java
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/meta/{PipeTemporaryMeta.java
=> PipeTemporaryMetaInCoordinator.java} (94%)
