This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 16965de83a0 Implemented the "restrict_object_limit" for object
restriction (#16933)
add 2bdbd41eee8 Pipe: Implemented the processTabletWithCollect api with
tablet collector (#16930)
No new revisions were added by this update.
Summary of changes:
.../{RowCollector.java => DataCollector.java} | 17 ++---
.../{RowCollector.java => TabletCollector.java} | 14 +++--
.../event/dml/insertion/TabletInsertionEvent.java | 11 ++++
.../db/pipe/event/common/row/PipeRowCollector.java | 35 ++---------
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 12 ++++
.../common/tablet/PipeRawTabletEventConverter.java | 72 ++++++++++++++++++++++
.../common/tablet/PipeRawTabletInsertionEvent.java | 7 +++
.../event/common/tablet/PipeTabletCollector.java | 61 ++++++++++++++++++
.../tablet/parser/TabletInsertionEventParser.java | 4 ++
.../TabletInsertionEventTablePatternParser.java | 14 ++++-
.../TabletInsertionEventTreePatternParser.java | 10 +++
.../pipe/event/TsFileInsertionEventParserTest.java | 34 ++++++----
12 files changed, 230 insertions(+), 61 deletions(-)
copy
iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/collector/{RowCollector.java
=> DataCollector.java} (71%)
copy
iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/collector/{RowCollector.java
=> TabletCollector.java} (78%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tablet/PipeRawTabletEventConverter.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tablet/PipeTabletCollector.java
