Package org.jumpmind.symmetric.io.data
Class DataProcessor
java.lang.Object
org.jumpmind.symmetric.io.data.DataProcessor
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected Batch
protected CsvData
protected Table
protected IDataReader
protected IDataWriter
protected IDataProcessorListener
protected String
-
Constructor Summary
ConstructorsConstructorDescriptionDataProcessor
(IDataReader dataReader, IDataWriter defaultDataWriter, String name) DataProcessor
(IDataReader dataReader, IDataWriter defaultDataWriter, IDataProcessorListener listener, String name) -
Method Summary
Modifier and TypeMethodDescriptionprotected IDataWriter
chooseDataWriter
(Batch batch) This method may be overridden in order to choose differentIDataWriter
based on the batch that is being written.protected void
close
(IDataResource dataResource) protected int
forEachDataInTable
(DataContext context, boolean processBatch, boolean processTable, Batch batch) protected int
forEachTableInBatch
(DataContext context, boolean processBatch, Batch batch) void
process()
void
process
(DataContext context) protected void
void
setDataReader
(IDataReader dataReader) void
setDefaultDataWriter
(IDataWriter dataWriter) void
setListener
(IDataProcessorListener listener)
-
Field Details
-
dataReader
-
defaultDataWriter
-
listener
-
currentTable
-
currentData
-
currentBatch
-
name
-
-
Constructor Details
-
DataProcessor
public DataProcessor() -
DataProcessor
-
DataProcessor
public DataProcessor(IDataReader dataReader, IDataWriter defaultDataWriter, IDataProcessorListener listener, String name)
-
-
Method Details
-
chooseDataWriter
This method may be overridden in order to choose differentIDataWriter
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
-
forEachTableInBatch
-
forEachDataInTable
protected int forEachDataInTable(DataContext context, boolean processBatch, boolean processTable, Batch batch) -
rethrow
-
close
-
setListener
-
setDataReader
-
setDefaultDataWriter
-