Package org.apache.iotdb.pipe.api.collector

Interface RowCollector

public interface RowCollector
Used to collect rows generated by TabletInsertionEvent.processRowByRow(BiConsumer), TabletInsertionEvent.processTablet(BiConsumer).

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    collectRow(Row row)
    Collects a row.

  • Method Details

    • collectRow

      void collectRow(Row row) throws IOException
      Collects a row.
      Parameters:
      row - Row to be collected
      Throws:
      IOException - if any I/O errors occur
      See Also: