This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch pipe-parallel-connector
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 4285d48c524 merge master and fix conflicts
new 876ca930ef2 warn -> error
add 2ab05bad859 Fix admin and audit log management on view (#10119)
add 521e166c4f4 Fix delete data from alias series (#10118)
add 94062d1a10b [HOTFIX] Pipe: PipeTaskRuntimeConfiguration cannot be cast
to PipeTaskCollectorRuntimeEnvironment && unreal message when dropping pipe
(#10121)
add e7dd6b9060b [IOTDB-5938] Fix select into alias series (#10124)
new a1f9897f822 Merge branch 'master' of github.com:apache/iotdb into
pipe-parallel-connector
new 8e1af2e44ee connector v2
new 7d5e2ee24a9 v2
The 4 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:
.../manager/pipe/task/PipeTaskCoordinator.java | 5 +-
.../view/IoTDBAliasSeriesIT.java} | 73 ++---
.../it/schema/view/IoTDBCreateAndShowViewIT.java | 1 -
.../iotdb/commons/auth/entity/PrivilegeType.java | 4 +
.../async/AsyncPipeDataTransferServiceClient.java | 11 +-
.../pipe/plugin/builtin/BuiltinPipePlugin.java | 4 +
.../builtin/connector/IoTDBThriftConnector.java | 16 +-
.../builtin/connector/IoTDBThriftConnectorV1.java | 3 +
.../builtin/connector/IoTDBThriftConnectorV2.java | 3 +
.../org/apache/iotdb/db/audit/AuditLogger.java | 4 +
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 8 +
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 54 +++-
.../iotdb/db/mpp/plan/analyze/SelectIntoUtils.java | 18 ++
.../pipe/collector/IoTDBDataRegionCollector.java | 3 +-
.../config/constant/PipeConnectorConstant.java | 2 +
...orImplV1_1.java => IoTDBSyncConnectorV1_1.java} | 12 +-
.../pipe/connector/v1/IoTDBThriftConnectorV1.java | 4 +-
.../v1/request/PipeTransferTabletReq.java | 2 +-
.../pipe/connector/v2/IoTDBThriftConnectorV2.java | 312 +++++++++++++++++++++
...nsferInsertNodeTabletInsertionEventHandler.java | 32 +++
...ipeTransferRawTabletInsertionEventHandler.java} | 29 +-
.../PipeTransferTabletInsertionEventHandler.java | 131 +++++++++
.../PipeTransferTsFileInsertionEventHandler.java | 208 ++++++++++++++
.../apache/iotdb/db/pipe/event/EnrichedEvent.java | 8 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 4 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 4 +-
.../event/realtime/PipeRealtimeCollectEvent.java | 8 +-
.../db/pipe/task/stage/PipeTaskCollectorStage.java | 3 +-
.../task/subtask/PipeConnectorSubtaskManager.java | 20 +-
29 files changed, 882 insertions(+), 104 deletions(-)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/{aggregation/IoTDBAggregationDeleteIT.java
=> schema/view/IoTDBAliasSeriesIT.java} (53%)
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/IoTDBThriftConnectorV1.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/IoTDBThriftConnectorV2.java
rename
server/src/main/java/org/apache/iotdb/db/pipe/connector/lagacy/{IoTDBSyncConnectorImplV1_1.java
=> IoTDBSyncConnectorV1_1.java} (97%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/pipe/connector/v2/IoTDBThriftConnectorV2.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/pipe/connector/v2/handler/PipeTransferInsertNodeTabletInsertionEventHandler.java
copy
server/src/main/java/org/apache/iotdb/db/pipe/{agent/receiver/IoTDBThriftReceiver.java
=> connector/v2/handler/PipeTransferRawTabletInsertionEventHandler.java} (51%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/pipe/connector/v2/handler/PipeTransferTabletInsertionEventHandler.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/pipe/connector/v2/handler/PipeTransferTsFileInsertionEventHandler.java
