Package org.jumpmind.symmetric.io.data

Class DataProcessor

java.lang.Object

org.jumpmind.symmetric.io.data.DataProcessor

public class DataProcessor
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected Batch	currentBatch
protected CsvData	currentData
protected Table	currentTable
protected IDataReader	dataReader
protected IDataWriter	defaultDataWriter
protected IDataProcessorListener	listener
protected String	name

Constructor Summary

Constructors

Constructor	Description
DataProcessor()
DataProcessor(IDataReader dataReader, IDataWriter defaultDataWriter, String name)
DataProcessor(IDataReader dataReader, IDataWriter defaultDataWriter, IDataProcessorListener listener, String name)

Method Summary

Modifier and Type	Method	Description
protected IDataWriter	chooseDataWriter(Batch batch)	This method may be overridden in order to choose different IDataWriter 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	rethrow(Throwable ex)
void	setDataReader(IDataReader dataReader)
void	setDefaultDataWriter(IDataWriter dataWriter)
void	setListener(IDataProcessorListener listener)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

dataReader

protected IDataReader dataReader

defaultDataWriter

protected IDataWriter defaultDataWriter

listener

protected IDataProcessorListener listener

currentTable

protected Table currentTable

currentData

protected CsvData currentData

currentBatch

protected Batch currentBatch

name

protected String name

Constructor Details

DataProcessor

public DataProcessor()

DataProcessor

public DataProcessor(IDataReader dataReader,
 IDataWriter defaultDataWriter,
 String name)

DataProcessor

public DataProcessor(IDataReader dataReader,
 IDataWriter defaultDataWriter,
 IDataProcessorListener listener,
 String name)

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)