This is an automated email from the ASF dual-hosted git repository.
yongzao pushed a change to branch multi-db-cfd
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from dc8a193e06c resolve conversation
add 49e199ef0ea fix: consider more general type of nodes in optimization
above LimitNode (#12240)
add db9530568d3 Forcibly take snapshot when upgrade procedure WAL (#12252)
add 7f88de31cb2 Modify compaction task priority comparator (#12255)
add e3d48b5e1a0 Add the import and export function of SQl files on the
basis of CSV import and export scripts (#12248)
add 4d826ef2a64 invert insertRecords to insertTablets (#12113)
add d8ac76ebe8c Fix the mistaken argument in LZ4Uncompressor
add cd6ba732a42 Subscription: fix some issues on DN and session & improve
IT (#12254)
add 611f203847f Pipe: Added handshake logic when config receiver is reset
due to receiver side DataNode redirection & Enhance IT & Refactor (#12256)
add d46dd660a67 Region migration related work (#12246)
add 4165e4c95f5 [IOTDB-6307] GCR algorithm for multi-database (#12183)
add b619e418f7b Revert "Region migration related work (#12246)"
add 424c4eb0720 resolve conflict
No new revisions were added by this update.
Summary of changes:
.../apache/iotdb/SubscriptionSessionExample.java | 16 +-
.../partition/IoTDBAutoRegionGroupExtensionIT.java | 119 +++++-----
.../scalar/IoTDBSubStringFunctionIT.java | 30 +--
.../iotdb/pipe/it/autocreate/IoTDBPipeAlterIT.java | 167 +++++++-------
.../it/autocreate/IoTDBPipeAutoConflictIT.java | 72 +++---
.../pipe/it/autocreate/IoTDBPipeClusterIT.java | 218 +++++++++---------
.../autocreate/IoTDBPipeConnectorParallelIT.java | 18 +-
.../pipe/it/autocreate/IoTDBPipeDataSinkIT.java | 32 +--
.../pipe/it/autocreate/IoTDBPipeExtractorIT.java | 200 ++++++++---------
.../pipe/it/autocreate/IoTDBPipeIdempotentIT.java | 28 +--
.../pipe/it/autocreate/IoTDBPipeLifeCycleIT.java | 180 +++++++--------
.../pipe/it/autocreate/IoTDBPipeNullValueIT.java | 29 +--
.../it/autocreate/IoTDBPipePatternFormatIT.java | 54 ++---
.../pipe/it/autocreate/IoTDBPipeProcessorIT.java | 18 +-
.../pipe/it/autocreate/IoTDBPipeProtocolIT.java | 70 +++---
.../it/autocreate/IoTDBPipeSwitchStatusIT.java | 58 ++---
.../pipe/it/autocreate/IoTDBPipeSyntaxIT.java | 218 +++++++++---------
.../iotdb/pipe/it/manual/IoTDBPipeInclusionIT.java | 48 ++--
.../pipe/it/manual/IoTDBPipeManualConflictIT.java | 52 ++---
.../pipe/it/manual/IoTDBPipeMetaHistoricalIT.java | 38 ++--
.../it/manual/IoTDBPipeMetaLeaderChangeIT.java | 34 +--
.../pipe/it/manual/IoTDBPipeMetaRestartIT.java | 32 +--
.../it/manual/IoTDBPipeMultiSchemaRegionIT.java | 29 ++-
.../iotdb/pipe/it/single/IoTDBPipeAggregateIT.java | 10 +-
.../pipe/it/single/IoTDBPipeSingleEnvDemoIT.java | 10 +-
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 37 +++
.../it/{ => dual}/AbstractSubscriptionDualIT.java | 2 +-
.../IoTDBSubscriptionConsumerGroupIT.java | 58 ++---
.../it/{ => dual}/IoTDBSubscriptionTopicIT.java | 113 +++++-----
.../it/local/IoTDBSubscriptionBasicIT.java | 157 +++++++++++++
.../it/local/IoTDBSubscriptionIdempotentIT.java | 162 +++++++++++++
.../IoTDBSubscriptionRestartIT.java} | 212 ++++++++---------
...{ExportCsvTestIT.java => ExportDataTestIT.java} | 59 ++++-
...{ImportCsvTestIT.java => ImportDataTestIT.java} | 6 +-
iotdb-client/cli/pom.xml | 4 +
.../tools/{export-csv.bat => export-data.bat} | 2 +-
.../tools/{export-csv.sh => export-data.sh} | 2 +-
.../tools/{import-csv.bat => import-data.bat} | 2 +-
.../tools/{import-csv.sh => import-data.sh} | 2 +-
.../java/org/apache/iotdb/cli/AbstractCli.java | 4 +-
...{AbstractCsvTool.java => AbstractDataTool.java} | 7 +-
.../iotdb/tool/{ExportCsv.java => ExportData.java} | 178 ++++++++++++++-
.../iotdb/tool/{ImportCsv.java => ImportData.java} | 64 +++++-
...riteCsvFileTest.java => WriteDataFileTest.java} | 6 +-
.../org/apache/iotdb/isession/SessionConfig.java | 5 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../java/org/apache/iotdb/session/Session.java | 250 ++++++++++++++++++++-
.../org/apache/iotdb/session/pool/SessionPool.java | 11 +
.../session/subscription/SubscriptionSession.java | 3 +-
.../iotdb/session/SessionCacheLeaderTest.java | 6 +-
.../java/org/apache/iotdb/session/SessionTest.java | 5 +-
.../apache/iotdb/session/pool/SessionPoolTest.java | 2 +
.../iotdb/confignode/conf/ConfigNodeConfig.java | 2 +-
.../manager/consensus/ConsensusManager.java | 3 +-
.../manager/load/balancer/RegionBalancer.java | 9 +-
.../region/GreedyCopySetRegionGroupAllocator.java | 100 ++++++---
.../region/GreedyRegionGroupAllocator.java | 40 +---
.../balancer/region/IRegionGroupAllocator.java | 3 +
.../agent/receiver/IoTDBConfigNodeReceiver.java | 21 +-
.../config/IoTDBConfigRegionAirGapConnector.java | 53 +++--
.../config/IoTDBConfigRegionConnector.java | 15 +-
.../persistence/partition/PartitionInfo.java | 4 +-
.../region/AllocatorScatterWidthManualTest.java | 5 +
.../GreedyCopySetRegionGroupAllocatorTest.java | 115 +++++++---
.../region/GreedyRegionGroupAllocatorTest.java | 4 +
.../UpgradeFromWALToConsensusLayerTest.java | 4 +-
.../airgap/IoTDBDataNodeAirGapConnector.java | 5 +
.../airgap/IoTDBDataRegionAirGapConnector.java | 20 +-
.../airgap/IoTDBSchemaRegionAirGapConnector.java | 40 ++--
.../receiver/thrift/IoTDBDataNodeReceiver.java | 2 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 6 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 31 +--
.../plan/optimization/LimitOffsetPushDown.java | 48 ++--
.../java/org/apache/iotdb/db/service/DataNode.java | 2 +-
.../DefaultCompactionTaskComparatorImpl.java | 21 +-
.../broker/SerializedEnrichedEvent.java | 2 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 14 +-
.../iotdb/commons/conf/CommonDescriptor.java | 6 +-
.../pipe/connector/client/IoTDBSyncClient.java | 13 ++
.../connector/client/IoTDBSyncClientManager.java | 35 ++-
.../connector/protocol/IoTDBAirGapConnector.java | 44 ++--
.../connector/protocol/IoTDBSslSyncConnector.java | 5 +
.../commons/pipe/receiver/IoTDBFileReceiver.java | 31 ++-
.../iotdb/commons/pipe/receiver/IoTDBReceiver.java | 2 +-
.../commons/pipe/receiver/IoTDBReceiverAgent.java | 8 +-
.../subscription/config/SubscriptionConfig.java | 8 +-
.../iotdb/tsfile/compress/IUnCompressor.java | 2 +-
.../org/apache/iotdb/tsfile/compress/LZ4Test.java | 21 ++
88 files changed, 2481 insertions(+), 1403 deletions(-)
rename integration-test/src/test/java/org/apache/iotdb/subscription/it/{ =>
dual}/AbstractSubscriptionDualIT.java (97%)
rename integration-test/src/test/java/org/apache/iotdb/subscription/it/{ =>
dual}/IoTDBSubscriptionConsumerGroupIT.java (93%)
rename integration-test/src/test/java/org/apache/iotdb/subscription/it/{ =>
dual}/IoTDBSubscriptionTopicIT.java (82%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/local/IoTDBSubscriptionBasicIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/local/IoTDBSubscriptionIdempotentIT.java
rename
integration-test/src/test/java/org/apache/iotdb/subscription/it/{IoTDBSubscriptionBasicIT.java
=> local/IoTDBSubscriptionRestartIT.java} (55%)
rename
integration-test/src/test/java/org/apache/iotdb/tools/it/{ExportCsvTestIT.java
=> ExportDataTestIT.java} (77%)
rename
integration-test/src/test/java/org/apache/iotdb/tools/it/{ImportCsvTestIT.java
=> ImportDataTestIT.java} (94%)
rename iotdb-client/cli/src/assembly/resources/tools/{export-csv.bat =>
export-data.bat} (99%)
rename iotdb-client/cli/src/assembly/resources/tools/{export-csv.sh =>
export-data.sh} (97%)
rename iotdb-client/cli/src/assembly/resources/tools/{import-csv.bat =>
import-data.bat} (99%)
rename iotdb-client/cli/src/assembly/resources/tools/{import-csv.sh =>
import-data.sh} (97%)
rename
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/{AbstractCsvTool.java =>
AbstractDataTool.java} (98%)
rename iotdb-client/cli/src/main/java/org/apache/iotdb/tool/{ExportCsv.java =>
ExportData.java} (69%)
rename iotdb-client/cli/src/main/java/org/apache/iotdb/tool/{ImportCsv.java =>
ImportData.java} (94%)
rename
iotdb-client/cli/src/test/java/org/apache/iotdb/tool/{WriteCsvFileTest.java =>
WriteDataFileTest.java} (87%)
