This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a change to branch beyyes/count_time_fe
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 37f9665e14c fix sonar
add d614139f71f Optimize client cpp package (#10923)
add 51e6d17b821 [IOTDB-6120] Push down limit/offset in query with group by
time
add 23340404c99 [IOTDB-6080] Pipe: Introduce batch mode for tablet
transferring (#10912)
add 1dce787c39e [Metric] Fix flush point statistics (#10915)
add 681642c3927 fix conflict with master
No new revisions were added by this update.
Summary of changes:
distribution/pom.xml | 16 +-
distribution/src/assembly/client-cpp.xml | 2 +-
.../apache/iotdb/pipe/it/IoTDBPipeDataSyncIT.java | 1 +
.../config/constant/PipeConnectorConstant.java | 11 +
.../payload/evolvable/PipeRequestType.java | 2 +
...oTDBThriftAsyncPipeTransferBatchReqBuilder.java | 98 ++++++++
...IoTDBThriftSyncPipeTransferBatchReqBuilder.java | 89 +++++++
.../builder/PipeTransferBatchReqBuilder.java | 64 +++++
.../evolvable/request/PipeTransferBatchReq.java | 172 +++++++++++++
.../request/PipeTransferFilePieceReq.java | 7 +-
.../evolvable/request/PipeTransferFileSealReq.java | 4 +-
.../request/PipeTransferHandshakeReq.java | 2 +-
.../request/PipeTransferInsertNodeReq.java | 2 +-
.../evolvable/request/PipeTransferTabletReq.java | 37 ++-
.../db/pipe/connector/protocol/IoTDBConnector.java | 11 +-
.../protocol/airgap/IoTDBAirGapConnector.java | 8 +
.../thrift/async/IoTDBThriftAsyncConnector.java | 117 +++++++--
...eTransferTabletBatchInsertionEventHandler.java} | 63 +++--
.../PipeTransferTabletInsertionEventHandler.java | 2 +-
.../thrift/sync/IoTDBThriftSyncConnector.java | 56 ++++-
.../receiver/thrift/IoTDBThriftReceiverV1.java | 93 ++++---
.../db/queryengine/plan/analyze/Analysis.java | 11 +
.../queryengine/plan/analyze/AnalyzeVisitor.java | 105 +++++---
.../plan/optimization/LimitOffsetPushDown.java | 117 +++++++++
.../db/queryengine/plan/parser/ASTVisitor.java | 15 +-
.../plan/planner/LogicalPlanVisitor.java | 12 +-
.../planner/plan/node/write/InsertRowsNode.java | 9 +-
.../plan/statement/component/OrderByComponent.java | 8 +-
.../plan/statement/crud/QueryStatement.java | 20 ++
.../dataregion/flush/MemTableFlushTask.java | 58 +++--
.../plan/optimization/LimitOffsetPushDownTest.java | 271 +++++++++++++++++++++
.../iotdb/metrics/AbstractMetricService.java | 45 ++--
.../metrics/reporter/iotdb/IoTDBReporter.java | 6 +-
33 files changed, 1318 insertions(+), 216 deletions(-)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/builder/IoTDBThriftAsyncPipeTransferBatchReqBuilder.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/builder/IoTDBThriftSyncPipeTransferBatchReqBuilder.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/builder/PipeTransferBatchReqBuilder.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/request/PipeTransferBatchReq.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/thrift/async/handler/{PipeTransferTabletInsertionEventHandler.java
=> PipeTransferTabletBatchInsertionEventHandler.java} (62%)
