This is an automated email from the ASF dual-hosted git repository.
tanxinyu pushed a change to branch wal_compression
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 4dcec3e7e95 Merge branch 'master' into wal_compression
add ae8d1b08d1a remove direct buffer
add 0b8e31456a4 Load: change the metric type of LoadDiskIO metric from
RATE to COUNTER (#12787)
add a96349e298c Enhance leader quantity metric for load scenario (#12785)
add cbdade41d5a Use milliseconds to express TTL (#12757)
add a3f996cbbc9 Fix iotdb-system.properties cluster_name comments #12791
add bc4cf473b77 Try to fix set cluster name integration test (#12794)
add 07792b11254 Fix WAL resource leak when using IoT series consensus
#12796
add 79ea1ef23d2 Pipe: Enable `'sink.format'='tsfile'` to use tsFile as
tablet event batch (#12737)
add 4912d902a8b [IOTDB-6343] Fix the device path construction bug in
visitSingleDeviceViewNode of AggragationPushDown
add 7581f84f38b Merge remote-tracking branch 'origin/master' into
wal_compression
No new revisions were added by this update.
Summary of changes:
.../org/apache/iotdb/db/it/IoTDBRestServiceIT.java | 15 +-
.../iotdb/db/it/IoTDBSetConfigurationIT.java | 31 +-
...oTDBAlignByDeviceWithTemplateAggregationIT.java | 29 ++
.../iotdb/db/it/auth/IoTDBSeriesPermissionIT.java | 2 +-
.../pipe/it/autocreate/IoTDBPipeDataSinkIT.java | 91 ++++-
.../pipe/it/autocreate/IoTDBPipeExtractorIT.java | 2 +-
.../pipe/it/manual/IoTDBPipeMetaHistoricalIT.java | 6 +-
.../iotdb/confignode/manager/TTLManager.java | 12 -
.../protocol/IoTDBConfigRegionConnector.java | 13 +-
.../manager/schema/ClusterSchemaManager.java | 5 -
.../org/apache/iotdb/consensus/IConsensus.java | 8 +
.../apache/iotdb/consensus/iot/IoTConsensus.java | 6 +
.../apache/iotdb/consensus/pipe/PipeConsensus.java | 6 +
.../iotdb/consensus/ratis/RatisConsensus.java | 10 +
.../iotdb/consensus/simple/SimpleConsensus.java | 5 +
.../apache/iotdb/consensus/iot/StabilityTest.java | 4 +
.../iotdb/consensus/ratis/RatisConsensusTest.java | 7 +
.../consensus/simple/SimpleConsensusTest.java | 6 +-
.../evolvable/batch/PipeTabletEventBatch.java | 133 ++++++++
.../PipeTabletEventPlainBatch.java} | 117 ++-----
.../batch/PipeTabletEventTsFileBatch.java | 365 +++++++++++++++++++++
.../PipeTransferBatchReqBuilder.java | 96 ++++--
.../request/PipeTransferTabletRawReq.java | 4 +-
.../protocol/legacy/IoTDBLegacyPipeConnector.java | 11 +-
.../PipeConsensusTransferBatchReqBuilder.java | 8 +-
.../async/IoTDBDataRegionAsyncConnector.java | 228 +++++++------
.../PipeTransferTabletBatchEventHandler.java | 31 +-
...Handler.java => PipeTransferTsFileHandler.java} | 134 ++++++--
.../thrift/sync/IoTDBDataRegionSyncConnector.java | 126 +++++--
.../thrift/sync/IoTDBSchemaRegionConnector.java | 13 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 18 +-
.../tsfile/TsFileInsertionDataContainer.java | 9 +-
.../db/pipe/resource/memory/PipeMemoryManager.java | 63 +---
...oryWeighUtil.java => PipeMemoryWeightUtil.java} | 63 +++-
.../pipe/resource/tsfile/PipeTsFileResource.java | 9 +-
.../subtask/connector/PipeConnectorSubtask.java | 2 +-
.../common/header/ColumnHeaderConstant.java | 3 +-
.../execution/load/LoadTsFileManager.java | 31 +-
.../operator/schema/source/DeviceSchemaSource.java | 2 +-
.../metric/load/LoadTsFileCostMetricsSet.java | 10 +-
.../analyze/cache/schema/DataNodeTTLCache.java | 31 +-
.../plan/optimization/AggregationPushDown.java | 8 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 5 +
.../plan/scheduler/load/LoadTsFileScheduler.java | 28 +-
.../statement/metadata/ShowDatabaseStatement.java | 37 +--
.../dataregion/memtable/AbstractMemTable.java | 32 +-
.../storageengine/dataregion/wal/WALManager.java | 8 +-
.../dataregion/wal/io/WALInputStream.java | 17 +-
.../SubscriptionPrefetchingTabletsQueue.java | 6 +-
.../plan/planner/node/PlanGraphPrinterTest.java | 2 +-
.../conf/iotdb-system.properties.template | 4 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 1 -
.../config/constant/PipeConnectorConstant.java | 12 +-
.../pipe/connector/protocol/IoTDBConnector.java | 40 ++-
.../connector/protocol/IoTDBSslSyncConnector.java | 16 +-
.../iotdb/commons/pipe/event/EnrichedEvent.java | 2 +-
.../task/subtask/PipeAbstractConnectorSubtask.java | 13 +-
.../apache/iotdb/commons/schema/ttl/TTLCache.java | 18 +-
.../iotdb/commons/service/metric/enums/Metric.java | 1 +
.../iotdb/commons/utils/CommonDateTimeUtils.java | 10 +
60 files changed, 1464 insertions(+), 561 deletions(-)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/batch/PipeTabletEventBatch.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/{builder/PipeEventBatch.java
=> batch/PipeTabletEventPlainBatch.java} (61%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/batch/PipeTabletEventTsFileBatch.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/{builder
=> batch}/PipeTransferBatchReqBuilder.java (55%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/thrift/async/handler/{PipeTransferTsFileInsertionEventHandler.java
=> PipeTransferTsFileHandler.java} (66%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/resource/memory/{PipeMemoryWeighUtil.java
=> PipeMemoryWeightUtil.java} (56%)
