Interface ExportDataConsumer

All Known Implementing Classes:
StreamingExportDataConsumer

public interface ExportDataConsumer
  • Method Summary

    Modifier and Type
    Method
    Description
    void
    Called once for every loaded partition of rows.
    void
    end()
    Called once after all rows have been fetched.
    void
    Called once at beginning.
  • Method Details

    • start

      void start(List<ExportColumn> columns) throws IOException
      Called once at beginning.
      Parameters:
      columns - the columns for the export
      Throws:
      IOException
    • acceptRows

      void acceptRows(List<Object[]> rows) throws IOException
      Called once for every loaded partition of rows. So, this method is potentially called multiple times.
      Parameters:
      rows - the rows of the loaded partition
      Throws:
      IOException
    • end

      void end() throws IOException
      Called once after all rows have been fetched.
      Throws:
      IOException