Package org.apache.iotdb.pipe.api.event.dml.insertion

Interface TabletInsertionEvent

All Superinterfaces:

Event

public interface TabletInsertionEvent
extends Event

TabletInsertionEvent is used to define the event of data insertion.

Method Summary

Modifier and Type	Method	Description
Iterable<TabletInsertionEvent>	processRowByRow(BiConsumer<Row,RowCollector> consumer)	The consumer processes the data row by row and collects the results by RowCollector.
Iterable<TabletInsertionEvent>	processTablet(BiConsumer<org.apache.tsfile.write.record.Tablet,RowCollector> consumer)	The consumer processes the Tablet directly and collects the results by RowCollector.

Method Details

processRowByRow

Iterable<TabletInsertionEvent> processRowByRow(BiConsumer<Row,RowCollector> consumer)

The consumer processes the data row by row and collects the results by RowCollector.

Returns:

Iterable<TabletInsertionEvent> a list of new TabletInsertionEvent contains the results collected by the RowCollector

processTablet

Iterable<TabletInsertionEvent> processTablet(BiConsumer<org.apache.tsfile.write.record.Tablet,RowCollector> consumer)

The consumer processes the Tablet directly and collects the results by RowCollector.

Returns:

Iterable<TabletInsertionEvent> a list of new TabletInsertionEvent contains the results collected by the RowCollector