This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch native_raft
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from e44a03ebce0 Merge branch 'master' into native_raft
add 181b3177774 [IOTDB-5879] Pipe: logical view of pipe event (#9855)
add 89114f6e540 remove useless module integration (#10015)
add 1cfc2577a28 Add UT for PrimitiveArrayManager adaption for UNKNOWN data
type (#10014)
add 2d43abfdf43 Fix DataTimeUtils convertLongToData bug (#10016)
add 710e7fb6acf [IOTDB-5960] Fix bug in groupByCount in 1C3D
add bbbf774d661 Fix time partition interval bug (#10019)
add 92459238b3a Fix ConcurrentModificationException in updating
FileMetrics (#10022)
add 55ba6d3fc91 Merge branch 'master' into native_raft
No new revisions were added by this update.
Summary of changes:
.../iotdb/db/it/groupby/IoTDBGroupByCountIT.java | 7 +
.../apache/iotdb/db/integration/IoTDBTtlIT.java | 354 -----------------
.../java/org/apache/iotdb/pipe/api/access/Row.java | 38 +-
.../event/dml/insertion/TabletInsertionEvent.java | 9 -
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 4 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 9 +
.../iotdb/commons/conf/CommonDescriptor.java | 14 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 4 +
.../builtin/processor/DoNothingProcessor.java | 13 +-
.../utils/PipeBinaryTransformer.java} | 17 +-
.../utils/PipeDataTypeTransformer.java} | 67 ++--
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 3 -
.../planner/plan/parameter/GroupByParameter.java | 2 +
.../PipeHistoricalDataRegionTsFileCollector.java | 15 +-
.../realtime/assigner/PipeDataRegionAssigner.java | 2 +-
.../impl/iotdb/v1/IoTDBThriftConnectorV1.java | 39 +-
.../impl/iotdb/v1/IoTDBThriftReceiverV1.java | 59 ++-
.../connector/impl/iotdb/v1/PipeRequestType.java | 5 +-
.../iotdb/v1/request/PipeTransferTabletReq.java | 222 +++++++++++
.../iotdb/db/pipe/core/event/EnrichedEvent.java | 18 +-
...vent.java => PipeInsertNodeInsertionEvent.java} | 64 ++-
.../core/event/impl/PipeTabletInsertionEvent.java | 111 ++----
.../core/event/impl/PipeTsFileInsertionEvent.java | 30 +-
.../event/realtime/PipeRealtimeCollectEvent.java | 19 +-
.../realtime/PipeRealtimeCollectEventFactory.java | 6 +-
.../core/event/realtime/TsFileEpochManager.java | 12 +-
.../db/pipe/core/event/view/access/PipeRow.java | 96 +++--
.../core/event/view/access/PipeRowIterator.java | 60 ---
.../event/view/collector/PipeRowCollector.java | 45 ++-
.../TabletInsertionDataContainer.java | 430 +++++++++++++++++++++
.../TsFileInsertionDataContainer.java | 136 +++++++
.../TsFileInsertionDataTabletIterator.java | 287 ++++++++++++++
.../core/processor/PipeDoNothingProcessor.java | 44 ++-
.../db/pipe/task/stage/PipeTaskProcessorStage.java | 12 +-
.../iotdb/db/rescon/PrimitiveArrayManager.java | 4 +-
.../iotdb/db/service/metrics/FileMetrics.java | 9 +-
.../org/apache/iotdb/db/utils/DateTimeUtils.java | 4 +-
.../collector/CachedSchemaPatternMatcherTest.java | 4 +-
.../datastructure/PrimitiveArrayManagerTest.java | 75 +++-
.../apache/iotdb/tsfile/write/record/Tablet.java | 108 +++---
.../iotdb/tsfile/write/record/TabletTest.java | 14 +-
41 files changed, 1716 insertions(+), 755 deletions(-)
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/IoTDBTtlIT.java
copy
node-commons/src/main/java/org/apache/iotdb/commons/{udf/utils/UDFBinaryTransformer.java
=> pipe/utils/PipeBinaryTransformer.java} (65%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/{udf/utils/UDFDataTypeTransformer.java
=> pipe/utils/PipeDataTypeTransformer.java} (60%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/pipe/core/connector/impl/iotdb/v1/request/PipeTransferTabletReq.java
copy
server/src/main/java/org/apache/iotdb/db/pipe/core/event/impl/{PipeTabletInsertionEvent.java
=> PipeInsertNodeInsertionEvent.java} (65%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/pipe/core/event/view/access/PipeRowIterator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/pipe/core/event/view/datastructure/TabletInsertionDataContainer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/pipe/core/event/view/datastructure/TsFileInsertionDataContainer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/pipe/core/event/view/datastructure/TsFileInsertionDataTabletIterator.java
copy
node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/processor/DoNothingProcessor.java
=>
server/src/main/java/org/apache/iotdb/db/pipe/core/processor/PipeDoNothingProcessor.java
(55%)
