This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch ty/benchant
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 659b08be5ac remove cglib dependency
add 03d0feb6647 Added ITs for logical views & Fix duplicate rows in show
views. (#10024)
add 6a6d805c4d3 remove max pool size metric (#10032)
add 2021d5aacc2 Get canonical path when using IOTDB_DATA_HOME and
IOTDB_HOME (#10035)
add 322c9c68dbe [IOTDB-5965] Pipe: failed to transfer insert node when
using schema template (#10041)
add ed42e91e047 Fix SchemaTree.hasView check during query analysis (#10040)
add 48afbc54be7 Add schema_ engine_mode config to iotdb-commons.properties
and User-Guide (#10048)
add 5d78f1a915f [IOTDB-5968] Pipe: pipe task does not work properly after
cluster reboot (#10046)
add 562048d4800 [IOTDB-5966] Pipe: Revision of Tablet serialize and
deserialize (#10045)
add 387c2102600 [IOTDB-5967] Pipe: fix convertToTablet bug and introduce
PipeEmptyTabletInsertionEvent (#10044)
new 91330db04b3 Merge remote-tracking branch 'origin/master' into
ty/benchant
new 5d6c41e0ce5 update cache in flush and compacting
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../iotdb/confignode/manager/node/NodeManager.java | 9 +-
.../confignode/persistence/pipe/PipeTaskInfo.java | 9 +-
.../runtime/PipeHandleLeaderChangeProcedure.java | 8 +-
.../runtime/PipeHandleMetaChangeProcedure.java | 24 +-
.../impl/pipe/runtime/PipeMetaSyncProcedure.java | 8 +-
.../pipe/task/AbstractOperatePipeProcedureV2.java | 8 +
docs/UserGuide/Reference/Common-Config-Manual.md | 9 +
.../zh/UserGuide/Reference/Common-Config-Manual.md | 9 +
.../iotdb/db/it/view/IoTDBCreateAndShowViewIT.java | 294 ++++++++++++++
.../iotdb/pipe/api/collector/RowCollector.java | 5 +-
.../resources/conf/iotdb-common.properties | 5 +
.../commons/concurrent/ThreadPoolMetrics.java | 16 -
.../apache/iotdb/commons/conf/CommonConfig.java | 31 +-
.../consensus/index/impl/SimpleProgressIndex.java | 2 +-
.../iotdb/commons/pipe/task/meta/PipeTaskMeta.java | 5 +-
.../org/apache/iotdb/commons/utils/FileUtils.java | 12 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 21 +-
.../iotdb/db/engine/cache/BloomFilterCache.java | 4 +
.../db/engine/cache/TimeSeriesMetadataCache.java | 8 +
.../impl/ReadChunkCompactionPerformer.java | 3 +-
.../writer/AbstractCrossCompactionWriter.java | 3 +-
.../writer/AbstractInnerCompactionWriter.java | 4 +-
.../db/engine/storagegroup/TsFileProcessor.java | 3 +-
.../db/metadata/schemaregion/SchemaEngine.java | 2 -
.../metadata/schemaregion/SchemaRegionLoader.java | 77 +---
.../mpp/common/schematree/ClusterSchemaTree.java | 4 +-
.../db/pipe/agent/runtime/HeartbeatScheduler.java | 23 --
.../db/pipe/agent/runtime/PipeAgentLauncher.java | 12 +-
.../iotdb/db/pipe/agent/task/PipeTaskAgent.java | 51 ++-
.../impl/iotdb/v1/IoTDBThriftConnectorV1.java | 38 +-
.../v1/request/PipeTransferInsertNodeReq.java | 4 +-
.../event/impl/PipeEmptyTabletInsertionEvent.java | 28 +-
...ava => PipeInsertNodeTabletInsertionEvent.java} | 31 +-
...nt.java => PipeTabletTabletInsertionEvent.java} | 6 +-
.../realtime/PipeRealtimeCollectEventFactory.java | 6 +-
.../core/event/realtime/TsFileEpochManager.java | 12 +-
.../db/pipe/core/event/view/access/PipeRow.java | 22 +-
.../event/view/collector/PipeRowCollector.java | 10 +-
.../TabletInsertionDataContainer.java | 106 ++----
.../TsFileInsertionDataContainer.java | 4 +-
.../UpdateCacheRestorableTsFileIOWriter.java | 58 +++
.../db/query/reader/UpdateCacheTsFileIOWriter.java | 51 +++
.../db/sync/common/ClusterSyncInfoFetcher.java | 13 +-
.../file/AbstractTsFileRecoverPerformer.java | 3 +-
.../META-INF/native-image/reflect-config.json | 364 +-----------------
.../META-INF/native-image/resource-config.json | 3 -
.../utils/CompactionFileGeneratorUtils.java | 10 +-
.../common/schematree/ClusterSchemaTreeTest.java | 21 +
.../PipeInsertNodeTabletInsertionEventTest.java | 178 +++++++++
.../tsfile/file/metadata/TimeseriesMetadata.java | 4 +-
.../apache/iotdb/tsfile/write/record/Tablet.java | 422 +++++++++++++--------
.../iotdb/tsfile/write/writer/TsFileIOWriter.java | 11 +
.../write/writer/tsmiterator/TSMIterator.java | 18 +-
.../iotdb/tsfile/write/record/TabletTest.java | 38 ++
54 files changed, 1263 insertions(+), 867 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/view/IoTDBCreateAndShowViewIT.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/pipe/agent/runtime/HeartbeatScheduler.java
copy
iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/collector/RowCollector.java
=>
server/src/main/java/org/apache/iotdb/db/pipe/core/event/impl/PipeEmptyTabletInsertionEvent.java
(65%)
rename
server/src/main/java/org/apache/iotdb/db/pipe/core/event/impl/{PipeInsertNodeInsertionEvent.java
=> PipeInsertNodeTabletInsertionEvent.java} (83%)
rename
server/src/main/java/org/apache/iotdb/db/pipe/core/event/impl/{PipeTabletInsertionEvent.java
=> PipeTabletTabletInsertionEvent.java} (92%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/reader/UpdateCacheRestorableTsFileIOWriter.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/reader/UpdateCacheTsFileIOWriter.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/pipe/core/event/PipeInsertNodeTabletInsertionEventTest.java
