Package com.illumon.iris.importers.csv

Interface RowUpdateObserver

public interface RowUpdateObserver
This is an Observer interface.

BaseAppendableColumnSink is the source observable for this observer. When the AppendableTableWrapper is constructed and identifies that there are schema only columns then the first column that is in csv source and also in the schema is registered as the observable.

This sink will publish the row chunk updates that can be propagated to all the schema only columns.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    publishRowUpdate(int size, long end)
    Publishes the current chunk attributes that are being processed in the sinks.
    void
    validateRowUpdateProcessing()
    Validates that RowUpdates were processed successfully.

  • Method Details

    • publishRowUpdate

      void publishRowUpdate(int size, long end)
      Publishes the current chunk attributes that are being processed in the sinks.
      Parameters:
      size - The size of current chunk
      end - The current end index, allows to validate if processing is for the right chunk

    • validateRowUpdateProcessing

      void validateRowUpdateProcessing() throws RowUpdateException
      Validates that RowUpdates were processed successfully.
      Throws:
      RowUpdateException - thrown when any errors are identified in RowUpdateProcessing