This is an automated email from the ASF dual-hosted git repository. justinchen pushed a commit to branch pipe-api in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 4027aec98d8be049ae01254daacc8a9bdfb6fbbb Author: Caideyipi <[email protected]> AuthorDate: Fri Dec 19 09:54:42 2025 +0800 init --- .../{RowCollector.java => DataCollector.java} | 20 +++---------------- .../iotdb/pipe/api/collector/RowCollector.java | 3 ++- .../{RowCollector.java => TabletCollector.java} | 19 +++--------------- .../db/pipe/event/common/row/PipeRowCollector.java | 1 + .../event/common/tablet/PipeTabletCollector.java | 23 ++-------------------- 5 files changed, 11 insertions(+), 55 deletions(-) diff --git a/iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/collector/RowCollector.java b/iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/collector/DataCollector.java similarity index 65% copy from iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/collector/RowCollector.java copy to iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/collector/DataCollector.java index 0518f8b2040..64ee234a993 100644 --- a/iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/collector/RowCollector.java +++ b/iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/collector/DataCollector.java @@ -19,24 +19,10 @@ package org.apache.iotdb.pipe.api.collector; -import org.apache.iotdb.pipe.api.access.Row; import org.apache.iotdb.pipe.api.event.dml.insertion.TabletInsertionEvent; -import java.io.IOException; -import java.util.function.BiConsumer; +import java.util.List; -/** - * Used to collect rows generated by {@link TabletInsertionEvent#processRowByRow(BiConsumer)}, - * {@link TabletInsertionEvent#processTablet(BiConsumer)}. - */ -public interface RowCollector { - - /** - * Collects a row. - * - * @param row Row to be collected - * @throws IOException if any I/O errors occur - * @see Row - */ - void collectRow(Row row) throws IOException; +public interface DataCollector { + List<TabletInsertionEvent> convertToTabletInsertionEvents(final boolean shouldReport); } diff --git a/iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/collector/RowCollector.java b/iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/collector/RowCollector.java index 0518f8b2040..43b30dd0e4a 100644 --- a/iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/collector/RowCollector.java +++ b/iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/collector/RowCollector.java @@ -22,6 +22,7 @@ package org.apache.iotdb.pipe.api.collector; import org.apache.iotdb.pipe.api.access.Row; import org.apache.iotdb.pipe.api.event.dml.insertion.TabletInsertionEvent; +import javax.xml.crypto.Data; import java.io.IOException; import java.util.function.BiConsumer; @@ -29,7 +30,7 @@ import java.util.function.BiConsumer; * Used to collect rows generated by {@link TabletInsertionEvent#processRowByRow(BiConsumer)}, * {@link TabletInsertionEvent#processTablet(BiConsumer)}. */ -public interface RowCollector { +public interface RowCollector extends DataCollector { /** * Collects a row. diff --git a/iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/collector/RowCollector.java b/iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/collector/TabletCollector.java similarity index 65% copy from iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/collector/RowCollector.java copy to iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/collector/TabletCollector.java index 0518f8b2040..03b2bf0c903 100644 --- a/iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/collector/RowCollector.java +++ b/iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/collector/TabletCollector.java @@ -20,23 +20,10 @@ package org.apache.iotdb.pipe.api.collector; import org.apache.iotdb.pipe.api.access.Row; -import org.apache.iotdb.pipe.api.event.dml.insertion.TabletInsertionEvent; +import org.apache.tsfile.write.record.Tablet; import java.io.IOException; -import java.util.function.BiConsumer; -/** - * Used to collect rows generated by {@link TabletInsertionEvent#processRowByRow(BiConsumer)}, - * {@link TabletInsertionEvent#processTablet(BiConsumer)}. - */ -public interface RowCollector { - - /** - * Collects a row. - * - * @param row Row to be collected - * @throws IOException if any I/O errors occur - * @see Row - */ - void collectRow(Row row) throws IOException; +public interface TabletCollector extends DataCollector { + void collectTablet(Tablet tablet) throws IOException; } diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/row/PipeRowCollector.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/row/PipeRowCollector.java index a00af1b8a5e..be21d49d725 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/row/PipeRowCollector.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/row/PipeRowCollector.java @@ -142,6 +142,7 @@ public class PipeRowCollector implements RowCollector { this.tablet = null; } + @Override public List<TabletInsertionEvent> convertToTabletInsertionEvents(final boolean shouldReport) { collectTabletInsertionEvent(); diff --git a/iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/collector/RowCollector.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tablet/PipeTabletCollector.java similarity index 57% copy from iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/collector/RowCollector.java copy to iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tablet/PipeTabletCollector.java index 0518f8b2040..070cd252c92 100644 --- a/iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/collector/RowCollector.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tablet/PipeTabletCollector.java @@ -17,26 +17,7 @@ * under the License. */ -package org.apache.iotdb.pipe.api.collector; +package org.apache.iotdb.db.pipe.event.common.tablet; -import org.apache.iotdb.pipe.api.access.Row; -import org.apache.iotdb.pipe.api.event.dml.insertion.TabletInsertionEvent; - -import java.io.IOException; -import java.util.function.BiConsumer; - -/** - * Used to collect rows generated by {@link TabletInsertionEvent#processRowByRow(BiConsumer)}, - * {@link TabletInsertionEvent#processTablet(BiConsumer)}. - */ -public interface RowCollector { - - /** - * Collects a row. - * - * @param row Row to be collected - * @throws IOException if any I/O errors occur - * @see Row - */ - void collectRow(Row row) throws IOException; +public class PipeTabletCollector { }
