You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ro...@apache.org on 2023/06/21 20:05:06 UTC
[iotdb] 01/02: Merge branch 'master' of github.com:apache/iotdb into fix-pipe-tablet-with-nullable-binary-columns
This is an automated email from the ASF dual-hosted git repository.
rong pushed a commit to branch fix-pipe-tablet-with-nullable-binary-columns
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 981fd999c7630deed8ca5c31768632d2bc874b8b
Merge: a0defb64a62 4e8cb333130
Author: Steve Yurong Su <ro...@apache.org>
AuthorDate: Thu Jun 22 03:58:55 2023 +0800
Merge branch 'master' of github.com:apache/iotdb into fix-pipe-tablet-with-nullable-binary-columns
.../db/pipe/agent/plugin/PipePluginAgent.java | 11 +-
.../db/pipe/agent/runtime/PipeRuntimeAgent.java | 6 +-
.../SimpleConsensusProgressIndexAssigner.java | 5 +-
.../iotdb/db/pipe/agent/task/PipeTaskAgent.java | 135 +++++++++++----------
.../pipe/collector/IoTDBDataRegionCollector.java | 15 ++-
.../PipeHistoricalDataRegionCollector.java | 4 +-
.../PipeHistoricalDataRegionTsFileCollector.java | 8 +-
.../realtime/PipeRealtimeDataRegionCollector.java | 2 +-
.../PipeRealtimeDataRegionFakeCollector.java | 21 +++-
.../PipeRealtimeDataRegionHybridCollector.java | 27 +++--
.../PipeRealtimeDataRegionLogCollector.java | 7 +-
.../PipeRealtimeDataRegionTsFileCollector.java | 7 +-
.../realtime/epoch/TsFileEpochManager.java | 11 +-
.../matcher/CachedSchemaPatternMatcher.java | 4 +-
.../pipe/connector/legacy/IoTDBSyncConnector.java | 56 ++++-----
.../pipe/connector/legacy/IoTDBSyncReceiver.java | 37 ++----
.../legacy/pipedata/DeletionPipeData.java | 8 +-
.../pipe/connector/legacy/pipedata/PipeData.java | 5 +-
.../connector/legacy/pipedata/TsFilePipeData.java | 3 +-
.../pipe/connector/v1/IoTDBThriftConnectorV1.java | 29 ++---
.../pipe/connector/v1/IoTDBThriftReceiverV1.java | 25 ++--
.../db/pipe/connector/v1/PipeRequestType.java | 5 +-
.../PipeTransferTabletInsertionEventHandler.java | 4 +-
.../PipeTransferTsFileInsertionEventHandler.java | 2 +-
.../apache/iotdb/db/pipe/event/EnrichedEvent.java | 2 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 3 -
.../common/tablet/PipeRawTabletInsertionEvent.java | 10 +-
.../tablet/TabletInsertionDataContainer.java | 27 ++---
.../common/tsfile/PipeTsFileInsertionEvent.java | 4 +-
.../tsfile/TsFileInsertionDataContainer.java | 7 +-
.../executor/PipeSubtaskExecutorManager.java | 6 +-
.../resource/file/PipeFileResourceManager.java | 22 ++--
.../db/pipe/resource/wal/PipeWALResource.java | 10 +-
.../pipe/resource/wal/PipeWALResourceManager.java | 79 ++++--------
.../db/pipe/task/connection/EventSupplier.java | 1 +
.../db/pipe/task/stage/PipeTaskCollectorStage.java | 3 +-
.../db/pipe/task/stage/PipeTaskConnectorStage.java | 4 +-
.../iotdb/db/pipe/task/stage/PipeTaskStage.java | 25 ++--
.../db/pipe/task/subtask/PipeConnectorSubtask.java | 42 +++++--
.../task/subtask/PipeConnectorSubtaskManager.java | 13 +-
.../db/pipe/task/subtask/PipeProcessorSubtask.java | 1 -
.../iotdb/db/pipe/task/subtask/PipeSubtask.java | 46 +++++--
42 files changed, 381 insertions(+), 361 deletions(-)