Class DataProcessor

java.lang.Object
org.jumpmind.symmetric.io.data.DataProcessor

public class DataProcessor extends Object
  • Field Details

  • Constructor Details

  • Method Details

    • chooseDataWriter

      protected IDataWriter chooseDataWriter(Batch batch)
      This method may be overridden in order to choose different IDataWriter based on the batch that is being written.
      Parameters:
      batch - The batch that is about to be written
      Returns:
      The data writer to use for the writing of the batch
    • process

      public void process()
    • process

      public void process(DataContext context)
    • forEachTableInBatch

      protected int forEachTableInBatch(DataContext context, boolean processBatch, Batch batch)
    • forEachDataInTable

      protected int forEachDataInTable(DataContext context, boolean processBatch, boolean processTable, Batch batch)
    • rethrow

      protected void rethrow(Throwable ex)
    • close

      protected void close(IDataResource dataResource)
    • setListener

      public void setListener(IDataProcessorListener listener)
    • setDataReader

      public void setDataReader(IDataReader dataReader)
    • setDefaultDataWriter

      public void setDefaultDataWriter(IDataWriter dataWriter)