Package org.jumpmind.symmetric.io.data.reader

Class SymXmlDataReader

java.lang.Object

org.jumpmind.symmetric.io.data.reader.AbstractDataReader

org.jumpmind.symmetric.io.data.reader.SymXmlDataReader

All Implemented Interfaces:

IDataReader, IDataResource

public class SymXmlDataReader
extends AbstractDataReader
implements IDataReader

Field Summary

Fields

Modifier and Type	Field	Description
protected Batch	batch
protected DataContext	context
protected CsvData	data
protected int	lineNumber
protected Object	next
protected org.xmlpull.v1.XmlPullParser	parser
protected Reader	reader
protected String	sourceNodeId
protected Statistics	statistics
protected Table	table

Fields inherited from class org.jumpmind.symmetric.io.data.reader.AbstractDataReader

log

Constructor Summary

Constructors

Constructor	Description
SymXmlDataReader(InputStream is)
SymXmlDataReader(Reader reader)

Method Summary

Modifier and Type	Method	Description
void	close()
Map<Batch,Statistics>	getStatistics()
Batch	nextBatch()
CsvData	nextData()
Table	nextTable()
void	open(DataContext context)
protected Object	readNext()

Methods inherited from class org.jumpmind.symmetric.io.data.reader.AbstractDataReader

logDebugAndCountBytes, toBatch, toReader, toReader

Methods inherited from class java.lang.Object

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

Field Details

reader

protected Reader reader

context

protected DataContext context

batch

protected Batch batch

table

protected Table table

data

protected CsvData data

sourceNodeId

protected String sourceNodeId

lineNumber

protected int lineNumber

parser

protected org.xmlpull.v1.XmlPullParser parser

statistics

protected Statistics statistics

next

protected Object next

Constructor Details

SymXmlDataReader

public SymXmlDataReader(InputStream is)

SymXmlDataReader

public SymXmlDataReader(Reader reader)

Method Details

open

public void open(DataContext context)

Specified by:

open in interface IDataResource

readNext

protected Object readNext()

nextBatch

public Batch nextBatch()

Specified by:

nextBatch in interface IDataReader

nextTable

public Table nextTable()

Specified by:

nextTable in interface IDataReader

nextData

public CsvData nextData()

Specified by:

nextData in interface IDataReader

close

public void close()

Specified by:

close in interface IDataResource

getStatistics

public Map<Batch,Statistics> getStatistics()

Specified by:

getStatistics in interface IDataResource